AmqpConnection

Undocumented in source.

Constructors

this
this(AmqpConnectionState conn)
Undocumented in source.

Alias This

conn

Members

Functions

basicPublish
void basicPublish(string exchange, string routingKey, amqp_basic_properties_t props, string messageBody)
Undocumented in source. Be warned that the author may not have intended to support it.
channel
ushort channel()
Undocumented in source. Be warned that the author may not have intended to support it.
consumeQueue
void consumeQueue(string queueName, bool noLocal, bool noAck, bool exclusive)
Undocumented in source. Be warned that the author may not have intended to support it.
declareQueue
amqp_queue_declare_ok_t* declareQueue(string queue, bool isPassive, bool isDurable, bool isExclusive, bool autoDelete, bool noWait, amqp_table_t arguments)
Undocumented in source. Be warned that the author may not have intended to support it.
declareReplyToQueue
string declareReplyToQueue()
Undocumented in source. Be warned that the author may not have intended to support it.
getBody
string getBody(size_t bodyTarget, from!"core.time".Duration timeout)
Undocumented in source. Be warned that the author may not have intended to support it.
getFrame
FrameResult getFrame(from!"core.time".Duration timeout)
Undocumented in source. Be warned that the author may not have intended to support it.
login
void login(string vhost, int channelMax, int frameMax, int heartBeat, SaslMethod saslMethod, string user, string pass)
Undocumented in source. Be warned that the author may not have intended to support it.
maybeReleaseBuffers
void maybeReleaseBuffers()
Undocumented in source. Be warned that the author may not have intended to support it.
openChannel
void openChannel(ushort channel)
Undocumented in source. Be warned that the author may not have intended to support it.
openSocket
amqp_socket_t* openSocket(string hostname, ushort port, bool useSSL, bool verifyPeer, bool verifyHostname, string caCert, string certFile, string keyFile)
Undocumented in source. Be warned that the author may not have intended to support it.
simpleWaitFrame
FrameResult simpleWaitFrame(from!"core.time".Duration duration)
Undocumented in source. Be warned that the author may not have intended to support it.

Static functions

newConnection
AmqpConnection newConnection()
Undocumented in source. Be warned that the author may not have intended to support it.

Variables

conn
RefCounted!AmqpConnectionState conn;
Undocumented in source.

Meta