org.mule.transport.amqp.internal.client
Class AmqpDeclarer
java.lang.Object
org.mule.transport.amqp.internal.client.AmqpDeclarer
public class AmqpDeclarer
- extends Object
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 |
endpointUtil
protected AmqpEndpointUtil endpointUtil
AmqpDeclarer
public AmqpDeclarer()
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.