Arguments

Name	Description	Default
queueName R	The name of the queue to use
routingKey	Comma-seperated list of routing keys used to bind the queue for direct and topic exchanges

SQL Call

EXEC RabbitMQ.CreateQueue 'myqueue' -- default or fanout
EXEC RabbitMQ.CreateQueue 'myqueue', 'white,green' -- direct
EXEC RabbitMQ.CreateQueue 'myqueue', '*.white.#,*.orange.large.*' -- topic

Http Call

/bsc/rabbitmq/createqueue

Output Columns

This call does not return data.

Arguments

Name	Description	Default
queueName R	The name of the queue to use

SQL Call

EXEC RabbitMQ.DeleteQueue 'myqueue' 

Http Call

/bsc/rabbitmq/deletequeue

Output Columns

This call does not return data.

Arguments

Name	Description	Default
queueName	The queue to read from (uses the config settings if empty)
count	Number of messages returned (1 by default); must be between 1 and 100; use TOP N in a SELECT command	1
peek	When 0 automatically ACKs the messages (0 by default)	False

SQL Call

SELECT * FROM RabbitMQ.Messages
EXEC RabbitMQ.GetMessage 
EXEC RabbitMQ.GetMessage 'myqueue', 5

Http Call

/bsc/rabbitmq/getmessage

Output Columns

String routingKey
String exchange
String message
String replyTo
String appId
String messageId
String deliveryTag
Boolean redelivered

Arguments

SQL Call

EXEC RabbitMQ.ping

Http Call

/bsc/rabbitmq/ping

Output Columns

String Status

Arguments

Name	Description	Default
message R	The message to send
routingKey	Comma-separated routing keys (leave blank for the default exchange; ignore by fanout exchanges)
expiration	The message expiration in ms	0
replyTo	The reply to address
appId	An application identifier
priority	The message priority (1-9)	1
persist	Indicates whether the message should be persisted
messageId	The message unique identifier (will be set to a random Guid if not provided)

SQL Call

EXEC RabbitMQ.SendMessage 'test'

Http Call

/bsc/rabbitmq/sendmessage

Output Columns

This call does not return data.

Arguments

Name	Description	Default
hostname	The name of the host where RabbitMQ is running

SQL Call

EXEC RabbitMQ.Status

Http Call

/bsc/rabbitmq/status

Output Columns

String host
Int32 port
String apiName
Int32 majVersion
Int32 minVersion
Int32 revision
String ssl