Defines Topic operations available in a session. More...
Inherited by MyChannels.Nirvana.InternalSession.
Public Member Functions | |
| IBatch | CreateBatch (string[] topics) |
| Creates a batch of Topic operations (passing null or empty array requires use of IBatch.Send(string resource, IMessage message)) More... | |
| IConsumer | CreateConsumer (string name, string filter=null, long eventId=0, bool subscribeToPurge=false) |
| Creates a Topic consumer. More... | |
| IConsumer | CreateNamedConsumer (string name, string unique, string filter=null, bool priorityEnabled=false, bool subscribeToPurge=false) |
| Creates a Topic consumer for a channel that uses "named objects". More... | |
| IProducer | CreateProducer (string name) |
| Creates a Topic producer More... | |
| IEnumerable< IProducer > | CreateProducers (IEnumerable< string > names) |
| Creates many Topic producers More... | |
| IRegisteredEvent | CreateRegisteredEvent (string topicName, string uniqueId, bool isTransactional=false) |
| Create a registered event for the specified topic More... | |
| IBatchedSubscription | CreateSubscriptionBatch () |
| Create many consumers More... | |
| ITransactionalConsumer | CreateTransactionalConsumer (string name, string unique, string filter=null, bool priorityEnabled=false, bool subscribeToPurge=false) |
| Creates a transactional Topic consumer More... | |
Defines Topic operations available in a session.
| IBatch MyChannels.Nirvana.ITopicSession.CreateBatch | ( | string[] | topics | ) |
Creates a batch of Topic operations (passing null or empty array requires use of IBatch.Send(string resource, IMessage message))
///
| topics | array of topic names to send to |
| IConsumer MyChannels.Nirvana.ITopicSession.CreateConsumer | ( | string | name, |
| string | filter = null, |
||
| long | eventId = 0, |
||
| bool | subscribeToPurge = false |
||
| ) |
Creates a Topic consumer.
| name | The name of the topic |
| filter | The event filter (channel key) |
| eventId | The event id you would like to start at. |
| subscribeToPurge | The consumer will receive purge events |
| IConsumer MyChannels.Nirvana.ITopicSession.CreateNamedConsumer | ( | string | name, |
| string | unique, | ||
| string | filter = null, |
||
| bool | priorityEnabled = false, |
||
| bool | subscribeToPurge = false |
||
| ) |
Creates a Topic consumer for a channel that uses "named objects".
| name | The name of the topic |
| unique | The named object |
| filter | The event filter (channel key) |
| priorityEnabled | Enable priority listener |
| subscribeToPurge | The consumer will receive purge events |
| IProducer MyChannels.Nirvana.ITopicSession.CreateProducer | ( | string | name | ) |
Creates a Topic producer
| name | The name of the topic |
| IEnumerable<IProducer> MyChannels.Nirvana.ITopicSession.CreateProducers | ( | IEnumerable< string > | names | ) |
Creates many Topic producers
| names | The names of the topics |
| IRegisteredEvent MyChannels.Nirvana.ITopicSession.CreateRegisteredEvent | ( | string | topicName, |
| string | uniqueId, | ||
| bool | isTransactional = false |
||
| ) |
Create a registered event for the specified topic
| topicName | The name of the topic |
| uniqueId | The registered event's unique ID |
| isTransactional | Use transactional commits |
| IBatchedSubscription MyChannels.Nirvana.ITopicSession.CreateSubscriptionBatch | ( | ) |
Create many consumers
| ITransactionalConsumer MyChannels.Nirvana.ITopicSession.CreateTransactionalConsumer | ( | string | name, |
| string | unique, | ||
| string | filter = null, |
||
| bool | priorityEnabled = false, |
||
| bool | subscribeToPurge = false |
||
| ) |
Creates a transactional Topic consumer
| name | The name of the topic |
| unique | The named object |
| filter | The event filter (channel key) |
| priorityEnabled | Enable priority listener |
| subscribeToPurge | The consumer will receive purge events |