MyChannels.Nirvana.IConsumer Interface Reference

Defines an object that receive messages from the realm. More...

Inherited by MyChannels.Nirvana.BasicChannelConsumer, MyChannels.Nirvana.NamedObjectChannelConsumer, and MyChannels.Nirvana.QueueConsumer.


Public Member Functions

IEnumerable< IMessageGetSynchronousReader (TimeSpan timeout)
 Creates a synchronous message reader.

Properties

IDestination Destination [get]
 The destination being consumed.

Detailed Description

Defines an object that receive messages from the realm.

Member Function Documentation

IEnumerable<IMessage> MyChannels.Nirvana.IConsumer.GetSynchronousReader ( TimeSpan  timeout  ) 

Creates a synchronous message reader.

var messages = consumer.GetSynchronousReader(TimeSpan.FromMinutes(1)) foreach (var message in messages) { process message }

Parameters:
timeout The maximum time allowed to expire in between receiving messages.
Returns:


Property Documentation

IDestination MyChannels.Nirvana.IConsumer.Destination [get]

The destination being consumed.