progress.message.jclient.mp
Interface MessageProducer

All Superinterfaces:

MessageProducer

All Known Subinterfaces:

QueueSender, TopicPublisher

public interface MessageProducer
extends MessageProducer

Title: SonicMQ Adaptive PAcing (Managed Client Message Producer)

Description: This is a Message Producer 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 send() operation that are currently waiting in the buffer.
long	getMessageCount() Returns the total number of sucessfull send() operations performed by this producer since the time it was created.
boolean	isAdaptivePacing()

Methods inherited from interface javax.jms.MessageProducer

close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive

Method Detail

isAdaptivePacing

boolean isAdaptivePacing()

getAdaptivePaceBatchSize

int getAdaptivePaceBatchSize()

getAdaptivePaceTimer

int getAdaptivePaceTimer()

getMessageCount

long getMessageCount()

Returns the total number of sucessfull send() operations performed by this producer since the time it was created.

Returns:

Total number of messages sent by this producer.

getInWaitMessageCount

int getInWaitMessageCount()

Returns the number of messages queued up by send() operation 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 buffer waiting to be sent.

getAdaptivePaceStatistics

java.lang.String getAdaptivePaceStatistics()