Package com.webmethods.jms.loadbalance.connection

Class WmClusterSessionQueueImpl

java.lang.Object

com.webmethods.jms.loadbalance.connection.WmClusterSessionQueueImpl

All Implemented Interfaces:

WmSessionQueue

Direct Known Subclasses:

WmClusterConsumerQueueImpl

public class WmClusterSessionQueueImpl
extends java.lang.Object
implements WmSessionQueue

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	_closed
protected boolean	_interrupt
protected java.util.concurrent.LinkedBlockingQueue<WmMessageImpl>	_queue
protected java.util.concurrent.locks.ReentrantReadWriteLock	_readWriteLock
protected boolean	_removeWaitStopped
protected boolean	_stopped

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	add(WmMessageImpl message)
void	addFirst(WmMessageImpl message)
void	addNotify(WmMessageImpl message)
void	clear()
void	close()
void	interrupt()
boolean	isClosed()
boolean	isEmpty()
boolean	isStopped()
WmMessageImpl	remove()
WmMessageImpl	removeWait()
int	size()
void	start()
void	stop(boolean wait)
java.lang.Object[]	toArray()
java.lang.Object[]	toArray(java.lang.Object[] a)

Methods inherited from class java.lang.Object

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

Field Detail

_queue

protected java.util.concurrent.LinkedBlockingQueue<WmMessageImpl> _queue

_stopped

protected boolean _stopped

_closed

protected boolean _closed

_interrupt

protected boolean _interrupt

_removeWaitStopped

protected boolean _removeWaitStopped

_readWriteLock

protected java.util.concurrent.locks.ReentrantReadWriteLock _readWriteLock

Constructor Detail

WmClusterSessionQueueImpl

public WmClusterSessionQueueImpl()

WmClusterSessionQueueImpl

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

Method Detail

isStopped

public boolean isStopped()

Specified by:

isStopped in interface WmSessionQueue

isClosed

public boolean isClosed()

Specified by:

isClosed in interface WmSessionQueue

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface WmSessionQueue

size

public int size()

Specified by:

size in interface WmSessionQueue

addNotify

public void addNotify(WmMessageImpl message)

Specified by:

addNotify in interface WmSessionQueue

add

public void add(WmMessageImpl message)

Specified by:

add in interface WmSessionQueue

addFirst

public void addFirst(WmMessageImpl message)

Specified by:

addFirst in interface WmSessionQueue

remove

public WmMessageImpl remove()

Specified by:

remove in interface WmSessionQueue

removeWait

public WmMessageImpl removeWait()

Specified by:

removeWait in interface WmSessionQueue

interrupt

public void interrupt()

Specified by:

interrupt in interface WmSessionQueue

start

public void start()

Specified by:

start in interface WmSessionQueue

stop

public void stop(boolean wait)

Specified by:

stop in interface WmSessionQueue

clear

public void clear()

Specified by:

clear in interface WmSessionQueue

close

public void close()

Specified by:

close in interface WmSessionQueue

toArray

public java.lang.Object[] toArray(java.lang.Object[] a)

Specified by:

toArray in interface WmSessionQueue

toArray

public java.lang.Object[] toArray()

Specified by:

toArray in interface WmSessionQueue