progress.message.jclient.mp
Interface MessageConsumer

All Superinterfaces:

MessageConsumer

All Known Subinterfaces:

QueueReceiver, TopicSubscriber

public interface MessageConsumer
extends MessageConsumer

Title: SonicMQ Adaptive Pacing (Managed Client Message Consumer)

Description: This is a Message Consumer implementation of Managed Client that supports Adaptive Pacing.

Copyright: Copyright (c) 2006

Company: Progress Software

Version:

2.2

Author:

Dmitry Lelchuk

Method Summary

int	getAdaptivePaceBatchSize()
java.lang.String	getAdaptivePaceStatistics()
int	getAdaptivePaceTimer()
int	getInWaitMessageCount() Returns the number of messages queued up by receive() operation or by the async listener that are currently waiting in the buffer.
long	getMessageCount() Returns the total number of sucessful receive() operations performed by this consumer since the time it was created.
boolean	isAdaptivePacing()

Methods inherited from interface progress.message.jclient.MessageConsumer

getPrefetchCount, getPrefetchThreshold, setPrefetchCount, setPrefetchThreshold

Methods inherited from interface javax.jms.MessageConsumer

close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener

Method Detail

isAdaptivePacing

boolean isAdaptivePacing()

getAdaptivePaceBatchSize

int getAdaptivePaceBatchSize()

getAdaptivePaceTimer

int getAdaptivePaceTimer()

getMessageCount

long getMessageCount()

Returns the total number of sucessful receive() operations performed by this consumer since the time it was created.

Returns:

Total number of messages received by this consumer.

getInWaitMessageCount

int getInWaitMessageCount()

Returns the number of messages queued up by receive() operation or by the async listener that are currently waiting in the buffer. This method is only relevant for Sessions that implement Adaptive Pacing. In all other cases it returns 0;

Returns:

Number of messages in the receive buffer waiting to be acknowledged.

getAdaptivePaceStatistics

java.lang.String getAdaptivePaceStatistics()