- addQueue
void addQueue(Queue queue, BufferType readyBufferType)
Undocumented in source. Be warned that the author may not have intended to support it.
- clearRequestLists
void clearRequestLists()
Undocumented in source. Be warned that the author may not have intended to support it.
- findTopic
Topic* findTopic(string topic)
Undocumented in source. Be warned that the author may not have intended to support it.
- getOrCreateTopic
Topic* getOrCreateTopic(string topic)
Undocumented in source. Be warned that the author may not have intended to support it.
- queueHasReadyBuffers
void queueHasReadyBuffers(Queue queue)
Undocumented in source. Be warned that the author may not have intended to support it.
- queueHasReadyBuffers
void queueHasReadyBuffers(Topic* ptopic, Partition* ppartition)
Undocumented in source. Be warned that the author may not have intended to support it.
- queues
int queues(int delegate(Queue) dg)
Undocumented in source. Be warned that the author may not have intended to support it.
- removeQueue
void removeQueue(Topic* topic, Partition* partition)
Undocumented in source. Be warned that the author may not have intended to support it.
- mutex
auto mutex [@property getter]
Undocumented in source. Be warned that the author may not have intended to support it.
- queueCount
auto queueCount [@property getter]
Undocumented in source. Be warned that the author may not have intended to support it.
- readyCondition
auto readyCondition [@property getter]
Undocumented in source. Be warned that the author may not have intended to support it.
- requestsCollected
auto requestsCollected [@property getter]
Undocumented in source. Be warned that the author may not have intended to support it.
- topics
auto topics [@property getter]
- requestTopicsBack
Topic* requestTopicsBack;
Undocumented in source. Be warned that the author may not have intended to support it.