Subscription

Undocumented in source.

class Subscription {

this(Client client, string queueName, QueueType queueType, ushort channel, void delegate(Message) callback);

void close();

bool isClosed [@property getter];

string getQueueName();

}

Constructors

this this(Client client, string queueName, QueueType queueType, ushort channel, void delegate(Message) callback): Undocumented in source.

Members

Functions

close void close(): Undocumented in source. Be warned that the author may not have intended to support it.
getQueueName string getQueueName(): Undocumented in source. Be warned that the author may not have intended to support it.

Properties

isClosed bool isClosed [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.

Variables

fiber Fiber fiber;: Undocumented in source.

Meta

Source

See Implementation

dutils message subscription classes

Subscription