@MetaDataScope(value=TopicCategory.class) @Connector(name="microsoftservicebus", schemaVersion="1.0", friendlyName="Microsoft Service Bus") @RequiresEnterpriseLicense(allowEval=true) public class MicrosoftServiceBusConnector extends Object
Constructor and Description |
---|
MicrosoftServiceBusConnector() |
Modifier and Type | Method and Description |
---|---|
ConnectionStrategy |
getConnection() |
ServiceBusQueue |
queueCreate(String queuePath,
ServiceBusQueueDescription queueDescription)
Creates a queue in the service bus instance
|
void |
queueDelete(String queuePath)
Deletes the specified queue in the service bus instance
|
ServiceBusQueue |
queueGet(String queuePath)
Retrieves the specified queue from the service bus instance
|
org.mule.api.callback.StopSourceCallback |
queueReceive(org.mule.api.callback.SourceCallback sourceCallback,
String sourceQueue)
Endpoint for receiving message from a Queue
|
void |
queueSend(String destinationQueue,
Object body,
AmqpHeader header,
AmqpProperties properties,
org.mule.api.MuleEvent event)
Sends a message to a Queue
|
List<ServiceBusQueue> |
queuesList()
Retrieves all existing queues from the service bus instance
|
ServiceBusQueue |
queueUpdate(String queuePath,
ServiceBusQueueDescription queueDescription)
Updates the specified queue in the service bus instance
|
ServiceBusRule |
ruleCreate(String topicPath,
String subscriptionPath,
String rulePath,
ServiceBusRuleDescription ruleDescription)
Creates a rule in the specified topic and subscription
|
void |
ruleDelete(String topicPath,
String subscriptionPath,
String rulePath)
Deletes the specified rule from the specified topic and subscription
|
ServiceBusRule |
ruleGet(String topicPath,
String subscriptionPath,
String rulePath)
Retrieves the specified rule from the specified topic and subscription
|
List<ServiceBusRule> |
rulesList(String topicPath,
String subscriptionPath)
Retrieves all rules from the specified topic and subscription
|
ServiceBusRule |
ruleUpdate(String topicPath,
String subscriptionPath,
String rulePath,
ServiceBusRuleDescription ruleDescription)
Updates the specified rule from the specified topic and subscription
|
void |
setConnection(ConnectionStrategy connection) |
ServiceBusSubscription |
subscriptionCreate(String topicPath,
String subscriptionPath,
ServiceBusSubscriptionDescription subscriptionDescription)
Creates a subscription in the specified topic
|
void |
subscriptionDelete(String topicPath,
String subscriptionPath)
Deletes the specified subscription from the specified topic
|
ServiceBusSubscription |
subscriptionGet(String topicPath,
String subscriptionPath)
Retrieves the specified subscription from the specified topic
|
List<ServiceBusSubscription> |
subscriptionsList(String topicPath)
Retrieves all subscriptions from the specified topic
|
ServiceBusSubscription |
subscriptionUpdate(String topicPath,
String subscriptionPath,
ServiceBusSubscriptionDescription subscriptionDescription)
Updates the specified subscription from the specified topic
|
ServiceBusTopic |
topicCreate(String topicPath,
ServiceBusTopicDescription topicDescription)
Creates a topic in the service bus instance
|
void |
topicDelete(String topicPath)
Deletes the specified topic from the service bus instance
|
ServiceBusTopic |
topicGet(String topicPath)
Retrieves the specified topic from the service bus instance
|
org.mule.api.callback.StopSourceCallback |
topicReceive(org.mule.api.callback.SourceCallback sourceCallback,
String sourceTopic,
String subscription)
Endpoint for receiving message from a Topic
|
void |
topicSend(String destinationTopic,
Object body,
AmqpHeader header,
AmqpProperties properties,
org.mule.api.MuleEvent event)
Sends a message to a Topic
|
List<ServiceBusTopic> |
topicsList()
Retrieves all existing topics from the service bus instance
|
ServiceBusTopic |
topicUpdate(String topicPath,
ServiceBusTopicDescription topicDescription)
Updates the specified topic from the service bus instance
|
@Processor public void topicSend(@MetaDataKeyParam(affects=INPUT) String destinationTopic, @Default(value="#[payload]") Object body, @Optional@Placement(group="Amqp Header") AmqpHeader header, @Optional@Placement(group="Amqp Properties") AmqpProperties properties, org.mule.api.MuleEvent event) throws ServiceBusException
destinationTopic
- The name of the destination of the messagebody
- The content of the messageheader
- The supported Header fields defined in the AMQP 1.0 standardproperties
- The supported Amqp Properties defined in the AMQP 1.0 Standardevent
- ServiceBusException
- when there is an error@MetaDataScope(value=QueueCategory.class) @Processor public void queueSend(@MetaDataKeyParam(affects=INPUT) String destinationQueue, @Default(value="#[payload]") Object body, @Optional@Placement(group="Amqp Header") AmqpHeader header, @Optional@Placement(group="Amqp Properties") AmqpProperties properties, org.mule.api.MuleEvent event) throws ServiceBusException
destinationQueue
- The name of the destination of the messagebody
- The content of the messageheader
- The supported Header fields defined in the AMQP 1.0 standardproperties
- The supported Amqp Properties defined in the AMQP 1.0 Standardevent
- ServiceBusException
- when there is an error@MetaDataScope(value=QueueCategory.class) @Source(threadingModel=NONE, sourceStrategy=NONE) @ReconnectOn(exceptions=java.lang.Exception.class) public org.mule.api.callback.StopSourceCallback queueReceive(org.mule.api.callback.SourceCallback sourceCallback, @MetaDataKeyParam(affects=OUTPUT) String sourceQueue) throws ServiceBusException
sourceCallback
- Source callbacksourceQueue
- The name of the source from where the messages will be retrievedServiceBusException
- when there is an error@Source(threadingModel=NONE, sourceStrategy=NONE) @ReconnectOn(exceptions=java.lang.Exception.class) public org.mule.api.callback.StopSourceCallback topicReceive(org.mule.api.callback.SourceCallback sourceCallback, @MetaDataKeyParam(affects=OUTPUT) String sourceTopic, String subscription) throws ServiceBusException
sourceCallback
- Source callbacksourceTopic
- The name of the source from where the messages will be retrievedsubscription
- The name of the subscription from where the messages will be retrievedServiceBusException
- when there is an error@Processor public List<ServiceBusQueue> queuesList() throws ServiceBusException
ServiceBusException
- when there is an error@MetaDataScope(value=QueueCategory.class) @Processor public ServiceBusQueue queueGet(@MetaDataKeyParam(affects=OUTPUT) String queuePath) throws ServiceBusException
queuePath
- The name of the queueServiceBusException
- when there is an error@MetaDataScope(value=QueueCategory.class) @Processor public ServiceBusQueue queueCreate(@MetaDataKeyParam(affects=BOTH) String queuePath, @Placement(group="Queue Description")@Default(value="#[payload]") ServiceBusQueueDescription queueDescription) throws ServiceBusException
queuePath
- The name of the queuequeueDescription
- A ServiceBusQueueDescription object containing the desired values of the queue’s properties that will be createdServiceBusException
- when there is an error@MetaDataScope(value=QueueCategory.class) @Processor public ServiceBusQueue queueUpdate(@MetaDataKeyParam(affects=BOTH) String queuePath, @Placement(group="Queue Description")@Default(value="#[payload]") ServiceBusQueueDescription queueDescription) throws ServiceBusException
queuePath
- The name of the queuequeueDescription
- A ServiceBusQueueDescription oject containing the desired values of the queue’s properties that will be updatedServiceBusException
- when there is an error@MetaDataScope(value=QueueCategory.class) @Processor public void queueDelete(@MetaDataKeyParam String queuePath) throws ServiceBusException
queuePath
- The name of the queueServiceBusException
- when there is an error@Processor public List<ServiceBusTopic> topicsList() throws ServiceBusException
ServiceBusException
- when there is an error@Processor public ServiceBusTopic topicGet(@MetaDataKeyParam(affects=OUTPUT) String topicPath) throws ServiceBusException
topicPath
- The name of the topicServiceBusException
- when there is an error@Processor public ServiceBusTopic topicCreate(@MetaDataKeyParam(affects=BOTH) String topicPath, @Placement(group="Topic Description")@Default(value="#[payload]") ServiceBusTopicDescription topicDescription) throws ServiceBusException
topicPath
- The name of the topictopicDescription
- A ServiceBusTopicDescription object containing the desired values of the topic’s properties that will be created.ServiceBusException
- when there is an error@Processor public ServiceBusTopic topicUpdate(@MetaDataKeyParam(affects=BOTH) String topicPath, @Placement(group="Topic Description")@Default(value="#[payload]") ServiceBusTopicDescription topicDescription) throws ServiceBusException
topicPath
- The name of the topictopicDescription
- A ServiceBusTopicDescription object containing the desired values of the topic’s properties that will be updated.ServiceBusException
- when there is an error@Processor public void topicDelete(@MetaDataKeyParam String topicPath) throws ServiceBusException
topicPath
- The name of the topicServiceBusException
- when there is an error@Processor public List<ServiceBusSubscription> subscriptionsList(@MetaDataKeyParam(affects=OUTPUT) String topicPath) throws ServiceBusException
topicPath
- The name of the topicServiceBusException
- when there is an error@Processor public ServiceBusSubscription subscriptionGet(@MetaDataKeyParam(affects=OUTPUT)@Placement(order=1) String topicPath, @Placement(order=2) String subscriptionPath) throws ServiceBusException
topicPath
- The name of the topicsubscriptionPath
- The name of the subscriptionServiceBusException
- when there is an error@Processor public ServiceBusSubscription subscriptionCreate(@MetaDataKeyParam(affects=BOTH)@Placement(order=1) String topicPath, @Placement(order=2) String subscriptionPath, @Placement(group="Subscription Description")@Default(value="#[payload]") ServiceBusSubscriptionDescription subscriptionDescription) throws ServiceBusException
topicPath
- The name of the topicsubscriptionPath
- The name of the subscriptionsubscriptionDescription
- A ServiceBusSubscriptionDescription object containing the desired values of the subscription’s properties that will be createdServiceBusException
- when there is an error@Processor public ServiceBusSubscription subscriptionUpdate(@MetaDataKeyParam(affects=BOTH)@Placement(order=1) String topicPath, @Placement(order=2) String subscriptionPath, @Placement(group="Subscription Description")@Default(value="#[payload]") ServiceBusSubscriptionDescription subscriptionDescription) throws ServiceBusException
topicPath
- The name of the topicsubscriptionPath
- The name of the subscriptionsubscriptionDescription
- A ServiceBusSubscriptionDescription object containing the desired values of the subscription’s properties that will be updatedServiceBusException
- when there is an error@Processor public void subscriptionDelete(@MetaDataKeyParam@Placement(order=1) String topicPath, @Placement(order=2) String subscriptionPath) throws ServiceBusException
topicPath
- The name of the topicsubscriptionPath
- The name of the subscriptionServiceBusException
- when there is an error@Processor public List<ServiceBusRule> rulesList(@MetaDataKeyParam(affects=OUTPUT)@Placement(order=1) String topicPath, @Placement(order=2) String subscriptionPath) throws ServiceBusException
topicPath
- The name of the topicsubscriptionPath
- The name of the subscriptionServiceBusException
- when there is an error@Processor public ServiceBusRule ruleGet(@MetaDataKeyParam(affects=OUTPUT)@Placement(order=1) String topicPath, @Placement(order=2) String subscriptionPath, @Placement(order=3) String rulePath) throws ServiceBusException
topicPath
- The name of the topicsubscriptionPath
- The name of the subscriptionrulePath
- The name of the ruleServiceBusException
- when there is an error@Processor public ServiceBusRule ruleCreate(@MetaDataKeyParam(affects=BOTH)@Placement(order=1) String topicPath, @Placement(order=2) String subscriptionPath, @Placement(order=3) String rulePath, @Placement(group="Rule Description")@Default(value="#[payload]") ServiceBusRuleDescription ruleDescription) throws ServiceBusException
topicPath
- The name of the topicsubscriptionPath
- The name of the subscriptionrulePath
- The name of the ruleruleDescription
- A ServiceBusRuleDescription object containing the desired values of the rule’s properties that will be createdServiceBusException
- when there is an error@Processor public ServiceBusRule ruleUpdate(@MetaDataKeyParam(affects=BOTH)@Placement(order=1) String topicPath, @Placement(order=2) String subscriptionPath, @Placement(order=3) String rulePath, @Placement(group="Rule Description")@Default(value="#[payload]") ServiceBusRuleDescription ruleDescription) throws ServiceBusException
topicPath
- The name of the topicsubscriptionPath
- The name of the subscriptionrulePath
- The name of the ruleruleDescription
- A ServiceBusRuleDescription object containing the desired values of the rule’s properties that will be updatedServiceBusException
- when there is an error@Processor public void ruleDelete(@MetaDataKeyParam@Placement(order=1) String topicPath, @Placement(order=2) String subscriptionPath, @Placement(order=3) String rulePath) throws ServiceBusException
topicPath
- The name of the topicsubscriptionPath
- The name of the subscriptionrulePath
- The name of the ruleServiceBusException
- when there is an errorpublic ConnectionStrategy getConnection()
public void setConnection(ConnectionStrategy connection)
Copyright © 2010–2017. All rights reserved.