Modifier and Type | Method and Description |
---|---|
void |
MicrosoftServiceBusConnector.acknowledgeMessage(AmqpMessage amqpMessage)
Acknowledges an Aqmp message
|
ServiceBusQueue |
MicrosoftServiceBusConnector.queueCreate(String queuePath,
ServiceBusQueueDescription queueDescription)
Creates a queue in the service bus instance
|
void |
MicrosoftServiceBusConnector.queueDelete(String queuePath)
Deletes the specified queue in the service bus instance
|
ServiceBusQueue |
MicrosoftServiceBusConnector.queueGet(String queuePath)
Retrieves the specified queue from the service bus instance
|
org.mule.api.callback.StopSourceCallback |
MicrosoftServiceBusConnector.queueReceive(org.mule.api.callback.SourceCallback sourceCallback,
String sourceQueue)
Endpoint for receiving message from a Queue
|
void |
MicrosoftServiceBusConnector.queueSend(String destinationQueue,
Object body,
AmqpHeader header,
AmqpProperties properties,
org.mule.api.MuleEvent event)
Sends a message to a Queue
|
List<ServiceBusQueue> |
MicrosoftServiceBusConnector.queuesList()
Retrieves all existing queues from the service bus instance
|
ServiceBusQueue |
MicrosoftServiceBusConnector.queueUpdate(String queuePath,
ServiceBusQueueDescription queueDescription)
Updates the specified queue in the service bus instance
|
ServiceBusRule |
MicrosoftServiceBusConnector.ruleCreate(String topicPath,
String subscriptionPath,
String rulePath,
ServiceBusRuleDescription ruleDescription)
Creates a rule in the specified topic and subscription
|
void |
MicrosoftServiceBusConnector.ruleDelete(String topicPath,
String subscriptionPath,
String rulePath)
Deletes the specified rule from the specified topic and subscription
|
ServiceBusRule |
MicrosoftServiceBusConnector.ruleGet(String topicPath,
String subscriptionPath,
String rulePath)
Retrieves the specified rule from the specified topic and subscription
|
List<ServiceBusRule> |
MicrosoftServiceBusConnector.rulesList(String topicPath,
String subscriptionPath)
Retrieves all rules from the specified topic and subscription
|
ServiceBusRule |
MicrosoftServiceBusConnector.ruleUpdate(String topicPath,
String subscriptionPath,
String rulePath,
ServiceBusRuleDescription ruleDescription)
Updates the specified rule from the specified topic and subscription
|
ServiceBusSubscription |
MicrosoftServiceBusConnector.subscriptionCreate(String topicPath,
String subscriptionPath,
ServiceBusSubscriptionDescription subscriptionDescription)
Creates a subscription in the specified topic
|
void |
MicrosoftServiceBusConnector.subscriptionDelete(String topicPath,
String subscriptionPath)
Deletes the specified subscription from the specified topic
|
ServiceBusSubscription |
MicrosoftServiceBusConnector.subscriptionGet(String topicPath,
String subscriptionPath)
Retrieves the specified subscription from the specified topic
|
List<ServiceBusSubscription> |
MicrosoftServiceBusConnector.subscriptionsList(String topicPath)
Retrieves all subscriptions from the specified topic
|
ServiceBusSubscription |
MicrosoftServiceBusConnector.subscriptionUpdate(String topicPath,
String subscriptionPath,
ServiceBusSubscriptionDescription subscriptionDescription)
Updates the specified subscription from the specified topic
|
ServiceBusTopic |
MicrosoftServiceBusConnector.topicCreate(String topicPath,
ServiceBusTopicDescription topicDescription)
Creates a topic in the service bus instance
|
void |
MicrosoftServiceBusConnector.topicDelete(String topicPath)
Deletes the specified topic from the service bus instance
|
ServiceBusTopic |
MicrosoftServiceBusConnector.topicGet(String topicPath)
Retrieves the specified topic from the service bus instance
|
org.mule.api.callback.StopSourceCallback |
MicrosoftServiceBusConnector.topicReceive(org.mule.api.callback.SourceCallback sourceCallback,
String sourceTopic,
String subscription,
boolean verifySynchronous)
Endpoint for receiving message from a Topic
|
void |
MicrosoftServiceBusConnector.topicSend(String destinationTopic,
Object body,
AmqpHeader header,
AmqpProperties properties,
org.mule.api.MuleEvent event)
Sends a message to a Topic
|
List<ServiceBusTopic> |
MicrosoftServiceBusConnector.topicsList()
Retrieves all existing topics from the service bus instance
|
ServiceBusTopic |
MicrosoftServiceBusConnector.topicUpdate(String topicPath,
ServiceBusTopicDescription topicDescription)
Updates the specified topic from the service bus instance
|
Modifier and Type | Method and Description |
---|---|
org.springframework.jms.listener.DefaultMessageListenerContainer |
AmqpClient.createContainerForQueue(ResettableStopSourceCallback stopSourceCallback,
org.mule.api.callback.SourceCallback sourceCallback,
String queueName,
com.microsoft.azure.storage.blob.CloudBlobContainer cloudBlobContainer) |
org.springframework.jms.listener.DefaultMessageListenerContainer |
AmqpClient.createContainerForTopic(ResettableStopSourceCallback stopSourceCallback,
org.mule.api.callback.SourceCallback sourceCallback,
String topicName,
String subscriptionName,
com.microsoft.azure.storage.blob.CloudBlobContainer cloudBlobContainer) |
javax.jms.ConnectionFactory |
AmqpClient.getConnectionFactory() |
void |
AmqpClient.send(String destinationName,
AmqpMessage amqpMessage,
boolean storeMessageToBlobIfPossible) |
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 |
---|---|
void |
ApplicationPropertiesBuilder.withProperty(String propertyName,
Object propertyValue) |
Modifier and Type | Method and Description |
---|---|
String |
AuthenticationContext.getSASToken() |
Modifier and Type | Method and Description |
---|---|
String |
SharedAccessSignatureConnectionStrategy.getSASToken(String url) |
abstract String |
BaseConnectionStrategy.getSASToken(String url) |
String |
WindowsConnectionStrategy.getSASToken(String url) |
String |
UsernamePasswordConnectionStrategy.getSASToken(String url) |
String |
ConnectionStrategy.getSASToken(String url) |
Modifier and Type | Method and Description |
---|---|
String |
SharedAccessSignatureProvider.getSASToken(String uri) |
Modifier and Type | Method and Description |
---|---|
List<org.mule.common.metadata.MetaDataKey> |
TopicCategory.retrieveKeys() |
List<org.mule.common.metadata.MetaDataKey> |
QueueCategory.retrieveKeys() |
Copyright © 2010–2019. All rights reserved.