org.mule.transport.amqp.internal.endpoint
Class AmqpEndpointUtil
java.lang.Object
org.mule.transport.amqp.internal.endpoint.AmqpEndpointUtil
public class AmqpEndpointUtil
- extends Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AmqpEndpointUtil
public AmqpEndpointUtil()
getQueueName
public String getQueueName(String endpointAddress)
getExchangeName
public String getExchangeName(org.mule.api.endpoint.ImmutableEndpoint endpoint)
getExchangeName
public String getExchangeName(org.mule.api.endpoint.ImmutableEndpoint endpoint,
org.mule.api.MuleEvent muleEvent)
getExchangeName
public String getExchangeName(String endpointAddress,
String protocol)
isDefaultExchange
public boolean isDefaultExchange(String exchangeName)
isExchangeDurable
public boolean isExchangeDurable(org.mule.api.endpoint.ImmutableEndpoint endpoint)
isExchangeAutoDelete
public boolean isExchangeAutoDelete(org.mule.api.endpoint.ImmutableEndpoint endpoint)
getEndpointType
public String getEndpointType(org.mule.api.endpoint.ImmutableEndpoint endpoint)
getRoutingKey
public String getRoutingKey(org.mule.api.endpoint.ImmutableEndpoint endpoint)
getRoutingKey
public String getRoutingKey(org.mule.api.endpoint.ImmutableEndpoint endpoint,
org.mule.api.MuleEvent muleEvent)
getArguments
public Map<String,Object> getArguments(org.mule.api.endpoint.ImmutableEndpoint endpoint,
String argumentPrefix)
getNumberOfChannels
public int getNumberOfChannels(org.mule.api.endpoint.ImmutableEndpoint endpoint)
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.