|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
A Broker side proxy representing mostly outbound JMS Connnection
Method Summary | |
void |
cleanUp()
Called when the transport has been terminated, so do our best to shut down any resources and deregister from any subscriptions etc |
void |
dispatch(ActiveMQMessage message)
Dispatch an ActiveMQMessage to the end client |
BrokerConnector |
getBrokerConnector()
|
int |
getCapacity()
Get the Capacity for in-progress messages at the peer (probably a JMSConnection) Legimate values between 0-100. |
TransportChannel |
getChannel()
|
String |
getClientID()
|
ConnectionInfo |
getConnectionInfo()
|
Subject |
getSubject()
|
void |
initialize(BrokerConnector brokerConnector,
TransportChannel channel)
Initialize the Brokerclient |
boolean |
isBrokerConnection()
|
boolean |
isClusteredConnection()
|
boolean |
isSlowConsumer()
Get an indication if the peer should be considered as a slow consumer |
void |
setSubject(Subject subject)
Associcates a subject with BrokerClient. |
void |
updateBrokerCapacity(int capacity)
Update the peer Connection about the Broker's capacity for messages |
void |
validateConnection(int timeout)
Tests the connection to assert that it in fact is alive by asserting that a full round-trip to the client is possible. |
Methods inherited from interface org.activemq.service.Service |
start, stop |
Method Detail |
public void initialize(BrokerConnector brokerConnector, TransportChannel channel)
brokerConnector
- channel
- public void dispatch(ActiveMQMessage message)
message
- public boolean isBrokerConnection()
public boolean isClusteredConnection()
public int getCapacity()
public boolean isSlowConsumer()
public void updateBrokerCapacity(int capacity)
capacity
- public String getClientID()
public void cleanUp()
public TransportChannel getChannel()
public BrokerConnector getBrokerConnector()
public void setSubject(Subject subject)
public Subject getSubject()
public void validateConnection(int timeout) throws JMSException
timeout
- the number of millisecods to wait before the connection is declared invalid
JMSException
- if the connection is invalidpublic ConnectionInfo getConnectionInfo()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |