Defines Queue operations available in a session. More...
Inherited by MyChannels.Nirvana.InternalSession.
Public Member Functions | |
IBatch | CreateBatch (string[] queues) |
Creates a batch of Queue operations (passing null or empty array requires use of IBatch.Send(string resource, IMessage message)) More... | |
IConsumer | CreateConsumer (string name, string filter=null) |
Create a consumer for a Queue More... | |
IProducer | CreateProducer (string name) |
Create a producer for a Queue More... | |
IEnumerable< IProducer > | CreateProducers (IEnumerable< string > names) |
Creates many Queue producers More... | |
ITransactionalConsumer | CreateTransactionalConsumer (string name, string filter=null, int windowSize=1) |
Create a consumer for a Queue More... | |
Defines Queue operations available in a session.
IBatch MyChannels.Nirvana.IQueueSession.CreateBatch | ( | string[] | queues | ) |
Creates a batch of Queue operations (passing null or empty array requires use of IBatch.Send(string resource, IMessage message))
queues | array of queue names to send to |
IConsumer MyChannels.Nirvana.IQueueSession.CreateConsumer | ( | string | name, |
string | filter = null |
||
) |
Create a consumer for a Queue
name | The name of the queue |
filter | The event filter (channel key) |
IProducer MyChannels.Nirvana.IQueueSession.CreateProducer | ( | string | name | ) |
Create a producer for a Queue
name | The name of the queue |
IEnumerable<IProducer> MyChannels.Nirvana.IQueueSession.CreateProducers | ( | IEnumerable< string > | names | ) |
Creates many Queue producers
names | The names of the queues |
ITransactionalConsumer MyChannels.Nirvana.IQueueSession.CreateTransactionalConsumer | ( | string | name, |
string | filter = null , |
||
int | windowSize = 1 |
||
) |
Create a consumer for a Queue
name | The name of the queue |
filter | The event filter (channel key) |
windowSize | The window size |