org.mule.transport.amqp.internal.client
Class ChannelHandler

java.lang.Object
  extended by org.mule.transport.amqp.internal.client.ChannelHandler

public class ChannelHandler
extends Object


Constructor Summary
ChannelHandler()
           
 
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
 

Constructor Detail

ChannelHandler

public ChannelHandler()
Method Detail

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.