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

Inheritance diagram for MyChannels.Nirvana.IConsumer:

Public Member Functions
IEnumerable< IMessage >	GetSynchronousReader (TimeSpan timeout)
	Creates a synchronous message reader. More...

Properties
IDestination	Destination `[get]`
	The destination being consumed More...

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.

IDestination MyChannels.Nirvana.IConsumer.Destination

get

The destination being consumed