|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface BrokerClient
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 |
---|
void initialize(BrokerConnector brokerConnector, TransportChannel channel)
brokerConnector
- channel
- void dispatch(ActiveMQMessage message)
message
- boolean isBrokerConnection()
boolean isClusteredConnection()
int getCapacity()
boolean isSlowConsumer()
void updateBrokerCapacity(int capacity)
capacity
- String getClientID()
void cleanUp()
TransportChannel getChannel()
BrokerConnector getBrokerConnector()
void setSubject(Subject subject)
Subject getSubject()
void validateConnection(int timeout) throws JMSException
timeout
- the number of millisecods to wait before the connection is declared invalid
JMSException
- if the connection is invalidConnectionInfo getConnectionInfo()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |