RabbitMQConnectionMBS.QueueDelete(channel as Integer, queue as String, ifUnused as Boolean, ifEmpty as Boolean) as Dictionary

Type	Topic	Plugin	Version	macOS	Windows	Linux	iOS	Targets
method	RabbitMQ	MBS RabbitMQ Plugin	21.2	✅ Yes	✅ Yes	✅ Yes	✅ Yes	All

Delete a queue.

RabbitMQConnectionMBS.QueuePurge(channel as Integer, queue as String) as Dictionary

Type	Topic	Plugin	Version	macOS	Windows	Linux	iOS	Targets
method	RabbitMQ	MBS RabbitMQ Plugin	21.2	✅ Yes	✅ Yes	✅ Yes	✅ Yes	All

Purge a queue.

RabbitMQConnectionMBS.QueueUnbind(channel as Integer, queue as String, exchange as String, routingKey as String, arguments as Dictionary) as Dictionary

Type	Topic	Plugin	Version	macOS	Windows	Linux	iOS	Targets
method	RabbitMQ	MBS RabbitMQ Plugin	21.2	✅ Yes	✅ Yes	✅ Yes	✅ Yes	All

Unbind a queue.

Some examples using this method:

• /RabbitMQ/amqp_unbind

RabbitMQConnectionMBS.ReadMessage(channel as Integer, byref message as RabbitMQMessageMBS, flags as Integer = 0) as RabbitMQRPCReplyMBS

Type	Topic	Plugin	Version	macOS	Windows	Linux	iOS	Targets
method	RabbitMQ	MBS RabbitMQ Plugin	21.2	✅ Yes	✅ Yes	✅ Yes	✅ Yes	All

Reads the next message on a channel

Reads a complete message (header + body) on a specified channel. This function is intended to be used with amqp_basic_get() or when an AMQP_BASIC_DELIVERY_METHOD method is received.

channel: the channel on which to read the message from
message: The parameter receiving the message.
flags: currently unused.

Returns RabbitMQRPCReplyMBS, which may contain error information.
Type of the object is RabbitMQRPCReplyMBS.ResponseTypeNormal on success.

RabbitMQConnectionMBS.SendHeader as Integer

Type	Topic	Plugin	Version	macOS	Windows	Linux	iOS	Targets
method	RabbitMQ	MBS RabbitMQ Plugin	21.2	✅ Yes	✅ Yes	✅ Yes	✅ Yes	All

Send initial AMQP header to the broker.

This is a low level function intended for those who want to interact with the broker at a very low level. Use of this function without understanding what it does will result in AMQP protocol errors.

This function sends the AMQP protocol header to the broker.

Returns error code, kStatusOK on success, a negative value on failure. Possible error codes:

• kStatusConnectionClosed: the connection to the broker was closed.
• kStatusSocketError: a socket error occurred. It is likely the underlying socket has been closed. errno or WSAGetLastError() may provide further information.
• kStatusSSLError: a SSL error occurred. The connection to the broker was closed.

RabbitMQConnectionMBS.SetCACert(File as FolderItem) as Boolean

Type	Topic	Plugin	Version	macOS	Windows	Linux	iOS	Targets
method	RabbitMQ	MBS RabbitMQ Plugin	21.2	✅ Yes	✅ Yes	✅ Yes	✅ Yes	All

Sets CACert file with root certificates.

Returns true on success and false on failure.

See also:

• SetCACert(Path as String) as Boolean

RabbitMQConnectionMBS.SetCACert(Path as String) as Boolean

Type	Topic	Plugin	Version	macOS	Windows	Linux	iOS	Targets
method	RabbitMQ	MBS RabbitMQ Plugin	21.2	✅ Yes	✅ Yes	✅ Yes	✅ Yes	All

Sets CACert file with root certificates.

Returns true on success and false on failure.

See also:

• SetCACert(File as FolderItem) as Boolean

RabbitMQConnectionMBS.SetKey(CertFile as FolderItem, KeyFile as FolderItem) as Boolean

Type	Topic	Plugin	Version	macOS	Windows	Linux	iOS	Targets
method	RabbitMQ	MBS RabbitMQ Plugin	21.2	✅ Yes	✅ Yes	✅ Yes	✅ Yes	All

Sets SSL key with certificate file path and key file path.

Returns true on success and false on failure.

See also:

• SetKey(CertPath as String, KeyPath as String) as Boolean

RabbitMQConnectionMBS.SetKey(CertPath as String, KeyPath as String) as Boolean

Type	Topic	Plugin	Version	macOS	Windows	Linux	iOS	Targets
method	RabbitMQ	MBS RabbitMQ Plugin	21.2	✅ Yes	✅ Yes	✅ Yes	✅ Yes	All

Sets SSL key with certificate file path and key file path.

Returns true on success and false on failure.

See also:

• SetKey(CertFile as FolderItem, KeyFile as FolderItem) as Boolean

RabbitMQConnectionMBS.SetKeyData(CertFile as FolderItem, KeyData as String) as Boolean

Type	Topic	Plugin	Version	macOS	Windows	Linux	iOS	Targets
method	RabbitMQ	MBS RabbitMQ Plugin	21.2	✅ Yes	✅ Yes	✅ Yes	✅ Yes	All

Sets SSL key with certificate file and key data as PEM.

Returns true on success and false on failure.

See also:

• SetKeyData(CertPath as String, KeyData as String) as Boolean

RabbitMQConnectionMBS.SetKeyData(CertPath as String, KeyData as String) as Boolean

Type	Topic	Plugin	Version	macOS	Windows	Linux	iOS	Targets
method	RabbitMQ	MBS RabbitMQ Plugin	21.2	✅ Yes	✅ Yes	✅ Yes	✅ Yes	All

Sets SSL key with certificate file and key data as PEM.

Returns true on success and false on failure.

See also:

• SetKeyData(CertFile as FolderItem, KeyData as String) as Boolean

RabbitMQConnectionMBS.SimpleWaitFrame(byref Frame as RabbitMQFrameMBS, timeoutValue as double = 30) as Integer

Type	Topic	Plugin	Version	macOS	Windows	Linux	iOS	Targets
method	RabbitMQ	MBS RabbitMQ Plugin	21.2	✅ Yes	✅ Yes	✅ Yes	✅ Yes	All

Read a single frame with a timeout.

Waits for the next frame to be read from the broker, up to a timespan specified by tv. The function will return kStatusTimeout if the timeout is reached. The tv value is not modified by the function.

The library may buffer frames. When an connection object has frames buffered calling SimpleWaitFrame_noblock() will return an frame without entering a blocking read(). You can test to see if an connection object has frames buffered by calling the FramesEnqueued() function.

The library has a socket read buffer. When there is data in an connection read buffer, SimpleWaitFrame() may return an frame without entering a blocking read(). You can test to see if an connection object has data in its read buffer by calling the DataInBuffer() function.

This function does not return heartbeat frames. When enabled, heartbeating is handed internally internally by the library.

Frame: receives decoded frame the frame
timeoutValue: the maximum time to wait for a frame to be read in seconds. Setting
to 0 will do a non-blocking read.

Returns kStatusOK on success. An kStatus value is returned otherwise. Possible errors include:

• kStatusTimeout the timeout was reached while waiting for a frame from the broker.
• kStatusInvalidParameter the tv parameter contains an invalid value.
• kStatusNoMemory failure in allocating memory. The library is likely in an indeterminate state making recovery unlikely. Client should note the error and terminate the application
• kStatusBadAMQPData bad AMQP data was received. The connection should be shutdown immediately
• kStatusUnknownMethod: an unknown method was received from the broker. This is likely a protocol error and the connection should be shutdown immediately
• kStatusUnknownClass: a properties frame with an unknown class was received from the broker. This is likely a protocol error and the connection should be shutdown immediately
• kStatusHeartbeatTimeout: timed out while waiting for heartbeat from the broker. The connection has been closed.
• kStatusTimerFailure: system timer indicated failure.
• kStatusSocketError: a socket error occurred. The connection has been closed
• kStatusSSLError: a SSL socket error occurred. The connection has been closed.

Some examples using this method:

• /RabbitMQ/amqp_consumer
• /RabbitMQ/amqp_rpc_sendstring_client
• /RabbitMQ/RabbitMQTutorial/RabbitMQTutorial

RabbitMQConnectionMBS.TXCommit(channel as Integer) as Dictionary

Type	Topic	Plugin	Version	macOS	Windows	Linux	iOS	Targets
method	RabbitMQ	MBS RabbitMQ Plugin	21.2	✅ Yes	✅ Yes	✅ Yes	✅ Yes	All

Commit.

RabbitMQConnectionMBS.TXRollback(channel as Integer) as Dictionary

Type	Topic	Plugin	Version	macOS	Windows	Linux	iOS	Targets
method	RabbitMQ	MBS RabbitMQ Plugin	21.2	✅ Yes	✅ Yes	✅ Yes	✅ Yes	All

Rollback.

RabbitMQConnectionMBS.TXSelect(channel as Integer) as Dictionary

Type	Topic	Plugin	Version	macOS	Windows	Linux	iOS	Targets
method	RabbitMQ	MBS RabbitMQ Plugin	21.2	✅ Yes	✅ Yes	✅ Yes	✅ Yes	All

Select.