Platforms to show: All Mac Windows Linux Cross-Platform
RabbitMQConnectionMBS class
Type | Topic | Plugin | Version | macOS | Windows | Linux | iOS | Targets |
class | RabbitMQ | MBS RabbitMQ Plugin | 21.2 | ✅ Yes | ✅ Yes | ✅ Yes | ✅ Yes | All |
Our plugin converts from dictionary/array/variant to/from the encoded representation used in MQ automatically.
- 20 properties
- property ClientProperties as Dictionary
- property DataInBuffer as Boolean
- property FramesEnqueued as Boolean
- property Handle as Integer
- property HandshakeTimeout as Double
- property Heartbeat as Integer
- property MaximumChannel as Integer
- property MaximumFrameSize as Integer
- property RPCReply as RabbitMQRPCReplyMBS
- property RPCTimeout as Double
- property ServerProperties as Dictionary
- property SocketFileDescriptor as Integer
- property SSLCACertPath as String
- property SSLCertPath as String
- property SSLKeyData as String
- property SSLKeyPath as String
- property SSLMaxVersion as Integer
- property SSLMinVersion as Integer
- property SSLVerifyHostname as Boolean
- property SSLVerifyPeer as Boolean
- 2 shared properties
- shared property Version as String
- shared property VersionNumber as Integer
- 44 methods
- method BasicAck(channel as Integer, deliveryTag as UInt64, multiple as Boolean = false) as Integer
- method BasicCancel(channel as Integer, consumerTag as String) as Dictionary
- method BasicConsume(channel as Integer, queue as String, consumerTag as String, noLocal as Boolean, noAck as Boolean, exclusive as Boolean, arguments as Dictionary) as Dictionary
- method BasicGet(channel as Integer, queue as String, noAck as Boolean) as RabbitMQRPCReplyMBS
- method BasicNAck(channel as Integer, deliveryTag as UInt64, multiple as Boolean = false, requeue as Boolean = false) as Integer
- method BasicPublish(channel as Integer, exchange as String, routingKey as String, mandatory as Boolean, immediate as Boolean, properties as RabbitMQBasicPropertiesMBS, body as String) as Integer
- method BasicQOS(channel as Integer, prefetchSize as Integer, prefetchCount as Integer, isGlobal as boolean) as Dictionary
- method BasicRecover(channel as Integer, requeue as Boolean) as Dictionary
- method BasicReject(channel as Integer, deliveryTag as UInt64, requeue as Boolean = false) as Integer
- method ChannelClose(Channel as Integer, Code as Integer = 200) as RabbitMQRPCReplyMBS
- method ChannelFlow(channel as Integer, active as Boolean) as Dictionary
- method ChannelOpen(Channel as Integer) as Dictionary
- method ConfirmSelect(channel as Integer) as Dictionary
- method ConnectionClose(Code as Integer = 200) as RabbitMQRPCReplyMBS
- method Constructor
- method ConsumeMessage(byref envelope as RabbitMQEnvelopeMBS, timeoutValue as double = 30, flags as Integer = 0) as RabbitMQRPCReplyMBS
- method Destructor
- method ExchangeBind(channel as Integer, destination as String, source as String, routingKey as String, arguments as Dictionary) as Dictionary
- method ExchangeDeclare(channel as Integer, exchange as String, type as String, passive as Boolean, durable as Boolean, autoDelete as Boolean, internal as Boolean, arguments as Dictionary) as Dictionary
- method ExchangeDelete(channel as Integer, exchange as String, ifUsed as Boolean) as Dictionary
- method ExchangeUnbind(channel as Integer, destination as String, source as String, routingKey as String, arguments as Dictionary) as Dictionary
- method LoginExternal(vhost as String, channelMax as Integer, frameMax as Integer, heartbeat as Integer, Identity as String, properties as Dictionary = nil) as RabbitMQRPCReplyMBS
- method LoginPlain(vhost as String, channelMax as Integer, frameMax as Integer, heartbeat as Integer, Username as String, Password as String, properties as Dictionary = nil) as RabbitMQRPCReplyMBS
- method MaybeReleaseBuffers
- method MaybeReleaseBuffersOnChannel(channel as Integer)
- method NewTCPSocket(UseSSL as boolean = false) as Boolean
- method OpenSocket(Host as String, Port as Integer, TimeOut as Double = 10) as Integer
- method QueueBind(channel as Integer, queue as String, exchange as String, routingKey as String, arguments as Dictionary) as Dictionary
- method QueueDeclare(channel as Integer, queue as String, passive as Boolean, durable as Boolean, exclusive as Boolean, autoDelete as Boolean, arguments as Dictionary) as Dictionary
- method QueueDelete(channel as Integer, queue as String, ifUnused as Boolean, ifEmpty as Boolean) as Dictionary
- method QueuePurge(channel as Integer, queue as String) as Dictionary
- method QueueUnbind(channel as Integer, queue as String, exchange as String, routingKey as String, arguments as Dictionary) as Dictionary
- method ReadMessage(channel as Integer, byref message as RabbitMQMessageMBS, flags as Integer = 0) as RabbitMQRPCReplyMBS
- method SendHeader as Integer
- method SetCACert(File as FolderItem) as Boolean
- method SetCACert(Path as String) as Boolean
- method SetKey(CertFile as FolderItem, KeyFile as FolderItem) as Boolean
- method SetKey(CertPath as String, KeyPath as String) as Boolean
- method SetKeyData(CertFile as FolderItem, KeyData as String) as Boolean
- method SetKeyData(CertPath as String, KeyData as String) as Boolean
- method SimpleWaitFrame(byref Frame as RabbitMQFrameMBS, timeoutValue as double = 30) as Integer
- method TXCommit(channel as Integer) as Dictionary
- method TXRollback(channel as Integer) as Dictionary
- method TXSelect(channel as Integer) as Dictionary
- 5 shared methods
- shared method ConstantIsHardError(constantNumber as Integer) as Boolean
- shared method ConstantName(constantNumber as Integer) as String
- shared method ErrorString(ErrorCode as Integer) as String
- shared method MethodHasContent(constantNumber as Integer) as Boolean
- shared method MethodName(constantNumber as Integer) as String
- 39 constants
Constants
Constant | Value | Description |
---|---|---|
kDefaultFrameSize | 131072 | Default frame size (128Kb) |
kDefaultHeartbeat | 0 | Default heartbeat interval (0, heartbeat disabled) |
kDefaultVHost | "/" | Default RabbitMQ vhost: "/". |
kMaxChannels | 2047 |
Default maximum number of channels (2047, RabbitMQ default limit of 2048, minus 1 for channel 0).
RabbitMQ set a default limit of 2048 channels per connection in v3.7.5 to prevent broken clients from leaking too many channels. |
kProtocolPort | 5672 | Default AMQP Port. |
kProtocolVersionMajor | 0 | AMQP protocol version major |
kProtocolVersionMinor | 9 | AMQP protocol version minor. |
kProtocolVersionRevision | 1 | AMQP protocol version revision. |
Status constants.
Constant | Value | Description |
---|---|---|
kStatusBadAmqpData | -2 |
Incorrect or corrupt data was received from the broker. This is a protocol error. |
kStatusBadUrl | -8 |
malformed AMQP URL |
kStatusBrokerUnsupportedSaslMethod | -19 |
Broker does not support the requested SASL mechanism. |
kStatusConnectionClosed | -7 |
The connection to the broker has been closed. |
kStatusHeartbeatTimeout | -15 |
Timed out waiting for heartbeat. |
kStatusHostnameResolutionFailed | -5 |
Unable to resolve the hostname. |
kStatusIncompatibleAmqpVersion | -6 |
The broker advertised an incompaible AMQP version. |
kStatusInvalidParameter | -10 |
An invalid parameter was passed into the function. |
kStatusNoMemory | -1 |
Memory allocation failed. |
kStatusOk | 0 |
Operation successful. |
kStatusSocketClosed | -17 |
Underlying socket is closed. |
kStatusSocketError | -9 |
A socket error occurred. |
kStatusSocketInuse | -18 |
Underlying socket is already open. |
kStatusSslConnectionFailed | -515 |
SSL handshake failed. |
kStatusSslError | -512 |
A generic SSL error occurred. |
kStatusSslHostnameVerifyFailed | -513 |
SSL validation of hostname against peer certificate failed. |
kStatusSslPeerVerifyFailed | -514 |
SSL validation of peer certificate failed. |
kStatusTableTooBig | -11 |
The dictionary object cannot be serialized because the output buffer is too small. |
kStatusTcpError | -256 |
A generic TCP error occurred. |
kStatusTcpSocketlibInitError | -257 |
An error occurred trying to initialize the socket library |
kStatusTimeout | -13 |
Operation timed out. |
kStatusTimerFailure | -14 |
The underlying system timer facility failed. |
kStatusUnexpectedState | -16 |
Unexpected protocol state |
kStatusUnknownClass | -3 |
An unknown AMQP class was received. This is a protocol error. |
kStatusUnknownMethod | -4 |
An unknown AMQP method was received. This is a protocol error. |
kStatusUnsupported | -20 |
Parameter is unsupported in this version. |
kStatusWrongMethod | -12 |
The wrong method was received. |
TLS Version
Constant | Value | Description |
---|---|---|
kTLSv10 | 1 |
TLS v1.0 |
kTLSv11 | 2 |
TLS v1.1 |
kTLSv12 | 3 |
TLS v1.2 |
kTLSvLatest | 65535 |
Latest TLS version available. |
This class has no sub classes.
Some examples using this class:
- /RabbitMQ/amqp_bind
- /RabbitMQ/amqp_consumer
- /RabbitMQ/amqp_exchange_declare
- /RabbitMQ/amqp_listen
- /RabbitMQ/amqp_listenq
- /RabbitMQ/amqp_producer
- /RabbitMQ/amqp_rpc_sendstring_client
- /RabbitMQ/amqp_sendstring
- /RabbitMQ/amqp_ssl_connect
- /RabbitMQ/RabbitMQTutorial/RabbitMQTutorial
Blog Entries
The items on this page are in the following plugins: MBS RabbitMQ Plugin.
RabbitMQConnectionInfoMBS - RabbitMQEnvelopeMBS