Search

Class AMQPBroker

Extends java.lang.Object
AMQP Broker

Attributes

Name Type Description
acceptAllCertificates boolean Whether this broker accepts all certificates
displayName String Display name of this broker, an extended version of the name property
host String Host address of this broker
id String Unique identifier of this broker
name String User-friendly name of this broker
port Number Port number of this broker
username String User name for this broker
useSSL boolean Whether this broker uses SSL
virtualHost String Virtual host of this broker

Methods

Name Returns
bind(String queue, String exchange, Object props) void
declareExchange(String exchange, Object props) void
declareQueue(String name, Object props) void
declareQueueAndReceiveAsync(String exchange, String routingKey, Number timeoutSeconds) Trigger
deleteExchange(String exchange) void
deleteQueue(String queue) void
receive(String queue) AMQPMessage
receiveAsync(String queue, Number timeoutSeconds) Trigger
remove() void
retrieveMessage(Trigger trigger) AMQPMessage
retrieveMessage(ch.dunes.vso.sdk.api.PluginTrigger ) AMQPMessage
retrieveTriggerProperties(Trigger trigger) Properties
retrieveTriggerProperties(ch.dunes.vso.sdk.api.PluginTrigger ) Properties
send(String exchange, String routingKey, AMQPMessage message) void
sendAndReceive(String exchange, String routingKey, AMQPMessage requestMessage, Number timeoutSeconds) AMQPMessage
subscribe(String[] queues, Object props) AMQPSubscription
unbind(String queue, String exchange, Object props) void
update(Object props) AMQPBroker
validate() void

Returned by

Method Returns
AMQPBroker.update(Object props) AMQPBroker
AMQPBrokerManager.addBroker(Object props) AMQPBroker

Referenced in

None