RabbitClient

Undocumented in source.

struct RabbitClient {

AmqpConnection conn;

amqp_socket_t* socket;

ConnectionParams params;

string replyToQueue;

this(ConnectionParams params);

CorrelationID sendMessage(string messageBody, string routingKey, string contentType);

string getResponseBlocking(CorrelationID correlationID, from!"core.time".Duration timeout);

void connect();

auto sendMessage(const(ubyte)[] message, string routingKey, from!"core.time".Duration timeout, string contentType);

}

Constructors

this this(ConnectionParams params): Undocumented in source.

Members

Functions

connect void connect(): Undocumented in source. Be warned that the author may not have intended to support it.
getResponseBlocking string getResponseBlocking(CorrelationID correlationID, from!"core.time".Duration timeout): Undocumented in source. Be warned that the author may not have intended to support it.
sendMessage CorrelationID sendMessage(string messageBody, string routingKey, string contentType): Undocumented in source. Be warned that the author may not have intended to support it.
sendMessage auto sendMessage(const(ubyte)[] message, string routingKey, from!"core.time".Duration timeout, string contentType): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

conn AmqpConnection conn;: Undocumented in source.
params ConnectionParams params;: Undocumented in source.
replyToQueue string replyToQueue;: Undocumented in source.
socket amqp_socket_t* socket;: Undocumented in source.

Meta

Source

See Implementation

symmetry api rabbitmq wrap classes

AmqpConnection

functions

structs