org.mule.transport.amqp.internal.client
Class ChannelHandler
java.lang.Object
org.mule.transport.amqp.internal.client.ChannelHandler
public class ChannelHandler
- extends Object
Method Summary |
void |
closeChannel(com.rabbitmq.client.Channel channel)
|
void |
closeChannelIfNotTransacted(com.rabbitmq.client.Channel channel)
|
com.rabbitmq.client.Channel |
createChannel(org.mule.api.endpoint.ImmutableEndpoint endpoint)
|
com.rabbitmq.client.Channel |
getChannel(org.mule.api.endpoint.ImmutableEndpoint endpoint,
org.mule.api.MuleMessage message)
|
com.rabbitmq.client.Channel |
getFlowVariableChannel(org.mule.api.MuleMessage message)
|
com.rabbitmq.client.Channel |
getOrCreateChannel(org.mule.api.endpoint.ImmutableEndpoint endpoint)
|
com.rabbitmq.client.Channel |
getOrDefaultChannel(org.mule.api.endpoint.ImmutableEndpoint endpoint,
com.rabbitmq.client.Channel defaultChannel)
|
com.rabbitmq.client.Channel |
getOrDefaultChannel(org.mule.api.endpoint.ImmutableEndpoint endpoint,
org.mule.api.MuleMessage message,
com.rabbitmq.client.Channel defaultChannel)
|
com.rabbitmq.client.Channel |
getTransactedResourceChannel(org.mule.api.endpoint.ImmutableEndpoint endpoint)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ChannelHandler
public ChannelHandler()
getOrCreateChannel
public com.rabbitmq.client.Channel getOrCreateChannel(org.mule.api.endpoint.ImmutableEndpoint endpoint)
throws Exception
- Throws:
Exception
getOrDefaultChannel
public com.rabbitmq.client.Channel getOrDefaultChannel(org.mule.api.endpoint.ImmutableEndpoint endpoint,
com.rabbitmq.client.Channel defaultChannel)
throws Exception
- Throws:
Exception
getOrDefaultChannel
public com.rabbitmq.client.Channel getOrDefaultChannel(org.mule.api.endpoint.ImmutableEndpoint endpoint,
org.mule.api.MuleMessage message,
com.rabbitmq.client.Channel defaultChannel)
throws Exception
- Throws:
Exception
getChannel
public com.rabbitmq.client.Channel getChannel(org.mule.api.endpoint.ImmutableEndpoint endpoint,
org.mule.api.MuleMessage message)
throws IOException,
org.mule.api.transaction.TransactionException
- Throws:
IOException
org.mule.api.transaction.TransactionException
getFlowVariableChannel
public com.rabbitmq.client.Channel getFlowVariableChannel(org.mule.api.MuleMessage message)
getTransactedResourceChannel
public com.rabbitmq.client.Channel getTransactedResourceChannel(org.mule.api.endpoint.ImmutableEndpoint endpoint)
throws IOException,
org.mule.api.transaction.TransactionException
- Throws:
IOException
org.mule.api.transaction.TransactionException
createChannel
public com.rabbitmq.client.Channel createChannel(org.mule.api.endpoint.ImmutableEndpoint endpoint)
throws IOException
- Throws:
IOException
closeChannelIfNotTransacted
public void closeChannelIfNotTransacted(com.rabbitmq.client.Channel channel)
throws org.mule.transport.ConnectException
- Throws:
org.mule.transport.ConnectException
closeChannel
public void closeChannel(com.rabbitmq.client.Channel channel)
throws org.mule.transport.ConnectException
- Throws:
org.mule.transport.ConnectException
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.