Package com.webmethods.jms.loadbalance.connection

Class WmClusterConsumerQueueImpl

java.lang.Object

com.webmethods.jms.loadbalance.connection.WmClusterSessionQueueImpl

com.webmethods.jms.loadbalance.connection.WmClusterConsumerQueueImpl

All Implemented Interfaces:

WmConsumerQueue, WmSessionQueue

public class WmClusterConsumerQueueImpl
extends WmClusterSessionQueueImpl
implements WmConsumerQueue

Field Summary

Fields inherited from class com.webmethods.jms.loadbalance.connection.WmClusterSessionQueueImpl

_closed, _interrupt, _queue, _readWriteLock, _removeWaitStopped, _stopped

Constructor Summary

Constructors

Constructor	Description
WmClusterConsumerQueueImpl()
WmClusterConsumerQueueImpl(java.util.concurrent.LinkedBlockingQueue<WmMessageImpl> queue, java.util.concurrent.locks.ReentrantReadWriteLock readWriteLock)

Method Summary

Modifier and Type	Method	Description
void	clearMessages(WmMessageConsumerImpl consumer)	Clears the messages of a specific consumer
java.util.List<WmMessageImpl>	removeConsumerQueueMessages(WmMessageConsumerImpl consumer)
WmMessageImpl	removeWait()
WmMessageImpl	removeWait(long timeout)
void	setTimeOut(long time)
void	start()
void	stop()
boolean	waitForMessages(long timeout)	Waits for a message to come until timeout.

Methods inherited from class com.webmethods.jms.loadbalance.connection.WmClusterSessionQueueImpl

add, addFirst, addNotify, clear, close, interrupt, isClosed, isEmpty, isStopped, remove, size, stop, toArray, toArray

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.webmethods.jms.impl.WmSessionQueue

add, addFirst, addNotify, clear, close, interrupt, isClosed, isEmpty, isStopped, remove, size, stop, toArray, toArray

Constructor Detail

WmClusterConsumerQueueImpl

public WmClusterConsumerQueueImpl()

WmClusterConsumerQueueImpl

public WmClusterConsumerQueueImpl(java.util.concurrent.LinkedBlockingQueue<WmMessageImpl> queue,
                                  java.util.concurrent.locks.ReentrantReadWriteLock readWriteLock)

Method Detail

removeWait

public WmMessageImpl removeWait()

Specified by:

removeWait in interface WmSessionQueue

Overrides:

removeWait in class WmClusterSessionQueueImpl

clearMessages

public void clearMessages(WmMessageConsumerImpl consumer)

Clears the messages of a specific consumer

Specified by:

clearMessages in interface WmConsumerQueue

removeConsumerQueueMessages

public java.util.List<WmMessageImpl> removeConsumerQueueMessages(WmMessageConsumerImpl consumer)

Specified by:

removeConsumerQueueMessages in interface WmConsumerQueue

waitForMessages

public boolean waitForMessages(long timeout)

Waits for a message to come until timeout.

Specified by:

waitForMessages in interface WmConsumerQueue

Parameters:

timeout -

Returns:

true if the queue gets a message

removeWait

public WmMessageImpl removeWait(long timeout)

Specified by:

removeWait in interface WmConsumerQueue

start

public void start()

Specified by:

start in interface WmConsumerQueue

Specified by:

start in interface WmSessionQueue

Overrides:

start in class WmClusterSessionQueueImpl

stop

public void stop()

Specified by:

stop in interface WmConsumerQueue

setTimeOut

public void setTimeOut(long time)

Specified by:

setTimeOut in interface WmConsumerQueue