Class MessageConsumer

Namespace

Apache.NMS.ActiveMQ

Assembly

Apache.NMS.ActiveMQ.dll

public class MessageConsumer : IMessageConsumer, IDisposable, IDispatcher

Inheritance

object

MessageConsumer

Implements

IMessageConsumer

IDisposable

IDispatcher

Derived

NetTxMessageConsumer

QueueBrowser.BrowsingMessageConsumer

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Fields

disposed

protected bool disposed

Field Value

bool

Properties

ConsumerId

public ConsumerId ConsumerId { get; }

Property Value

ConsumerId

ConsumerInfo

public ConsumerInfo ConsumerInfo { get; }

Property Value

ConsumerInfo

ConsumerTransformer

public ConsumerTransformerDelegate ConsumerTransformer { get; set; }

Property Value

ConsumerTransformerDelegate

FailoverRedeliveryWaitPeriod

public long FailoverRedeliveryWaitPeriod { get; set; }

Property Value

long

FailureError

public Exception FailureError { get; set; }

Property Value

Exception

IgnoreExpiration

public bool IgnoreExpiration { get; set; }

Property Value

bool

IsAutoAcknowledgeBatch

protected bool IsAutoAcknowledgeBatch { get; }

Property Value

bool

IsAutoAcknowledgeEach

protected bool IsAutoAcknowledgeEach { get; }

Property Value

bool

IsClientAcknowledge

protected bool IsClientAcknowledge { get; }

Property Value

bool

IsIndividualAcknowledge

protected bool IsIndividualAcknowledge { get; }

Property Value

bool

LastDeliveredSequenceId

public long LastDeliveredSequenceId { get; }

Property Value

long

NonBlockingRedelivery

public bool NonBlockingRedelivery { get; set; }

Property Value

bool

OptimizeAcknowledge

public bool OptimizeAcknowledge { get; set; }

Property Value

bool

OptimizeAcknowledgeTimeOut

public long OptimizeAcknowledgeTimeOut { get; set; }

Property Value

long

OptimizedAckScheduledAckInterval

public long OptimizedAckScheduledAckInterval { get; set; }

Property Value

long

PrefetchSize

public int PrefetchSize { get; }

Property Value

int

RedeliveryPolicy

public IRedeliveryPolicy RedeliveryPolicy { get; set; }

Property Value

IRedeliveryPolicy

RedeliveryTimeout

public int RedeliveryTimeout { get; set; }

Property Value

int

TransactedIndividualAck

public bool TransactedIndividualAck { get; set; }

Property Value

bool

UnconsumedMessageCount

public long UnconsumedMessageCount { get; }

Property Value

long

Methods

AfterMessageIsConsumed(MessageDispatch, bool)

public virtual void AfterMessageIsConsumed(MessageDispatch dispatch, bool expired)

Parameters

dispatch MessageDispatch

expired bool

BeforeMessageIsConsumed(MessageDispatch)

public virtual void BeforeMessageIsConsumed(MessageDispatch dispatch)

Parameters

dispatch MessageDispatch

Close()

public virtual void Close()

DeliverAcks()

public void DeliverAcks()

Dispatch(MessageDispatch)

public virtual void Dispatch(MessageDispatch dispatch)

Parameters

dispatch MessageDispatch

Dispose()

public void Dispose()

Dispose(bool)

protected void Dispose(bool disposing)

Parameters

disposing bool

DoClientAcknowledge(ActiveMQMessage)

protected void DoClientAcknowledge(ActiveMQMessage message)

Parameters

message ActiveMQMessage

DoIndividualAcknowledge(ActiveMQMessage)

protected void DoIndividualAcknowledge(ActiveMQMessage message)

Parameters

message ActiveMQMessage

DoNothingAcknowledge(ActiveMQMessage)

protected void DoNothingAcknowledge(ActiveMQMessage message)

Parameters

message ActiveMQMessage

~MessageConsumer()

protected ~MessageConsumer()

Iterate()

public bool Iterate()

Returns

bool

Receive()

public IMessage Receive()

Returns

IMessage

Receive(TimeSpan)

public IMessage Receive(TimeSpan timeout)

Parameters

timeout TimeSpan

Returns

IMessage

ReceiveNoWait()

public IMessage ReceiveNoWait()

Returns

IMessage

SendPullRequest(long)

protected void SendPullRequest(long timeout)

Parameters

timeout long

Start()

public void Start()

Stop()

public void Stop()

Events

Listener

public event MessageListener Listener

Event Type

MessageListener