Package com.webmethods.jms.loadbalance.connection

Class WmClusterConnectionConsumerImpl

java.lang.Object

com.webmethods.locks.Node

com.webmethods.jms.impl.WmConnectionConsumerImpl

com.webmethods.jms.loadbalance.connection.WmClusterConnectionConsumerImpl

All Implemented Interfaces:

WmConnectionStatusListener, javax.jms.ConnectionConsumer

public class WmClusterConnectionConsumerImpl
extends WmConnectionConsumerImpl
implements WmConnectionStatusListener

ConnectionConsumer implementation for the cluster connection.

Nested Class Summary

Nested classes/interfaces inherited from class com.webmethods.jms.impl.WmConnectionConsumerImpl

WmConnectionConsumerImpl.Dispatcher

Field Summary

Fields inherited from class com.webmethods.jms.impl.WmConnectionConsumerImpl

_closed, _connection, _consumer, _destination, _dispatcher, _isLocalTransacted, _isTransacted, _maxMessages, _messages, _messageSelector, _session, _sessionPool, _subscriptionName

Fields inherited from class com.webmethods.locks.Node

_lockManager

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	WmClusterConnectionConsumerImpl(WmConnectionImpl connection, javax.jms.Destination destination, java.lang.String subscriptionName, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)	Constructor
protected	WmClusterConnectionConsumerImpl(WmConnectionImpl connection, javax.jms.Destination destination, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	addBroker(java.lang.String brokerString)	Broker with the specified String got added in the cluster.
boolean	dispatch()	Dispatch method, implementation over clustered connection consumer.
void	removeBroker(java.lang.String brokerString)	Broker with the specified String got removed from the cluster.
java.lang.String	toString()

Methods inherited from class com.webmethods.jms.impl.WmConnectionConsumerImpl

close, getServerSessionPool

Methods inherited from class com.webmethods.locks.Node

getLockManager, getParent

Methods inherited from class java.lang.Object

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

Constructor Detail

WmClusterConnectionConsumerImpl

protected WmClusterConnectionConsumerImpl(WmConnectionImpl connection,
                                          javax.jms.Destination destination,
                                          java.lang.String messageSelector,
                                          javax.jms.ServerSessionPool sessionPool,
                                          int maxMessages)
                                   throws javax.jms.JMSException

Constructor.

Parameters:

connection -

destination -

messageSelector -

sessionPool -

maxMessages -

Throws:

javax.jms.JMSException

WmClusterConnectionConsumerImpl

protected WmClusterConnectionConsumerImpl(WmConnectionImpl connection,
                                          javax.jms.Destination destination,
                                          java.lang.String subscriptionName,
                                          java.lang.String messageSelector,
                                          javax.jms.ServerSessionPool sessionPool,
                                          int maxMessages)
                                   throws javax.jms.JMSException

Constructor

Parameters:

connection -

destination -

subscriptionName -

messageSelector -

sessionPool -

maxMessages -

Throws:

javax.jms.JMSException

Method Detail

dispatch

public boolean dispatch()

Dispatch method, implementation over clustered connection consumer.

Overrides:

dispatch in class WmConnectionConsumerImpl

toString

public java.lang.String toString()

Overrides:

toString in class WmConnectionConsumerImpl

addBroker

public void addBroker(java.lang.String brokerString)

Description copied from interface: WmConnectionStatusListener

Broker with the specified String got added in the cluster.

Specified by:

addBroker in interface WmConnectionStatusListener

removeBroker

public void removeBroker(java.lang.String brokerString)

Description copied from interface: WmConnectionStatusListener

Broker with the specified String got removed from the cluster.

Specified by:

removeBroker in interface WmConnectionStatusListener