public class AmqpClient extends Object
Constructor and Description |
---|
AmqpClient(ConnectionStrategy connection,
String address,
org.mule.api.MuleContext muleContext,
int maxConnections) |
AmqpClient(ConnectionStrategy connection,
String address,
String namespace,
Boolean disableCnCheck,
org.mule.api.MuleContext muleContext,
int maxConnections) |
Modifier and Type | Method and Description |
---|---|
org.springframework.jms.listener.DefaultMessageListenerContainer |
createContainerForQueue(ResettableStopSourceCallback stopSourceCallback,
org.mule.api.callback.SourceCallback sourceCallback,
String queueName,
com.microsoft.azure.storage.blob.CloudBlobContainer cloudBlobContainer) |
org.springframework.jms.listener.DefaultMessageListenerContainer |
createContainerForTopic(ResettableStopSourceCallback stopSourceCallback,
org.mule.api.callback.SourceCallback sourceCallback,
String topicName,
String subscriptionName,
com.microsoft.azure.storage.blob.CloudBlobContainer cloudBlobContainer) |
void |
disconnect() |
javax.jms.ConnectionFactory |
getConnectionFactory() |
void |
send(String destinationName,
AmqpMessage amqpMessage,
boolean storeMessageToBlobIfPossible) |
public AmqpClient(ConnectionStrategy connection, String address, org.mule.api.MuleContext muleContext, int maxConnections) throws ServiceBusException
ServiceBusException
public AmqpClient(ConnectionStrategy connection, String address, String namespace, Boolean disableCnCheck, org.mule.api.MuleContext muleContext, int maxConnections) throws ServiceBusException
ServiceBusException
public void send(String destinationName, AmqpMessage amqpMessage, boolean storeMessageToBlobIfPossible) throws ServiceBusException
ServiceBusException
public org.springframework.jms.listener.DefaultMessageListenerContainer createContainerForQueue(ResettableStopSourceCallback stopSourceCallback, org.mule.api.callback.SourceCallback sourceCallback, String queueName, com.microsoft.azure.storage.blob.CloudBlobContainer cloudBlobContainer) throws ServiceBusException
ServiceBusException
public org.springframework.jms.listener.DefaultMessageListenerContainer createContainerForTopic(ResettableStopSourceCallback stopSourceCallback, org.mule.api.callback.SourceCallback sourceCallback, String topicName, String subscriptionName, com.microsoft.azure.storage.blob.CloudBlobContainer cloudBlobContainer) throws ServiceBusException
ServiceBusException
public void disconnect() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.ConnectionFactory getConnectionFactory() throws ServiceBusException
ServiceBusException
Copyright © 2010–2019. All rights reserved.