org.mule.modules.microsoftservicebus.amqp

Class AmqpClient

java.lang.Object

org.mule.modules.microsoftservicebus.amqp.AmqpClient

public class AmqpClient
extends Object

Constructor Summary

Constructors

Constructor and Description
AmqpClient(ConnectionStrategy connection, String address, org.mule.api.MuleContext muleContext)
AmqpClient(ConnectionStrategy connection, String address, String namespace, Boolean disableCnCheck, org.mule.api.MuleContext muleContext)

Method Summary

Methods

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AmqpClient

public AmqpClient(ConnectionStrategy connection,
          String address,
          org.mule.api.MuleContext muleContext)
           throws ServiceBusException

Throws:

ServiceBusException

AmqpClient

public AmqpClient(ConnectionStrategy connection,
          String address,
          String namespace,
          Boolean disableCnCheck,
          org.mule.api.MuleContext muleContext)
           throws ServiceBusException

Throws:

ServiceBusException

Method Detail

send

public void send(String destinationName,
        AmqpMessage amqpMessage,
        boolean storeMessageToBlobIfPossible)
          throws ServiceBusException

Throws:

ServiceBusException

createContainerForQueue

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

Throws:

ServiceBusException

createContainerForTopic

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

Throws:

ServiceBusException

disconnect

public void disconnect()
                throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getConnectionFactory

public javax.jms.ConnectionFactory getConnectionFactory()
                                                 throws ServiceBusException

Throws:

ServiceBusException