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

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

public class AmqpDeclarer
extends Object


Field Summary
protected  AmqpEndpointUtil endpointUtil
           
 
Constructor Summary
AmqpDeclarer()
           
 
Method Summary
 void declareBinding(com.rabbitmq.client.Channel channel, org.mule.api.endpoint.ImmutableEndpoint endpoint, String exchangeName, String routingKey, String queueName)
           
 String declareEndpoint(com.rabbitmq.client.Channel channel, org.mule.api.endpoint.ImmutableEndpoint endpoint, boolean activeDeclarationsOnly)
           
 String declareEndpoint(com.rabbitmq.client.Channel channel, org.mule.api.endpoint.ImmutableEndpoint endpoint, boolean activeDeclarationsOnly, String exchangeName)
           
 String declareEndpoint(com.rabbitmq.client.Channel channel, org.mule.api.endpoint.ImmutableEndpoint endpoint, boolean activeDeclarationsOnly, String exchangeName, String routingKey)
           
 String declareExchange(com.rabbitmq.client.Channel channel, org.mule.api.endpoint.ImmutableEndpoint endpoint, boolean activeDeclarationsOnly)
           
 void declareQueuePassively(com.rabbitmq.client.Channel channel, String queueName)
           
 String declareTemporaryQueue(com.rabbitmq.client.Channel channel)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

endpointUtil

protected AmqpEndpointUtil endpointUtil
Constructor Detail

AmqpDeclarer

public AmqpDeclarer()
Method Detail

declareEndpoint

public String declareEndpoint(com.rabbitmq.client.Channel channel,
                              org.mule.api.endpoint.ImmutableEndpoint endpoint,
                              boolean activeDeclarationsOnly)
                       throws IOException
Throws:
IOException

declareEndpoint

public String declareEndpoint(com.rabbitmq.client.Channel channel,
                              org.mule.api.endpoint.ImmutableEndpoint endpoint,
                              boolean activeDeclarationsOnly,
                              String exchangeName)
                       throws IOException
Throws:
IOException

declareEndpoint

public String declareEndpoint(com.rabbitmq.client.Channel channel,
                              org.mule.api.endpoint.ImmutableEndpoint endpoint,
                              boolean activeDeclarationsOnly,
                              String exchangeName,
                              String routingKey)
                       throws IOException
Throws:
IOException

declareQueuePassively

public void declareQueuePassively(com.rabbitmq.client.Channel channel,
                                  String queueName)
                           throws IOException
Throws:
IOException

declareTemporaryQueue

public String declareTemporaryQueue(com.rabbitmq.client.Channel channel)
                             throws IOException
Throws:
IOException

declareBinding

public void declareBinding(com.rabbitmq.client.Channel channel,
                           org.mule.api.endpoint.ImmutableEndpoint endpoint,
                           String exchangeName,
                           String routingKey,
                           String queueName)
                    throws IOException
Throws:
IOException

declareExchange

public String declareExchange(com.rabbitmq.client.Channel channel,
                              org.mule.api.endpoint.ImmutableEndpoint endpoint,
                              boolean activeDeclarationsOnly)
                       throws IOException
Throws:
IOException


Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.