|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.broker.impl.BrokerClientImpl
public class BrokerClientImpl
A Broker client side proxy representing a JMS Connnection
Constructor Summary | |
---|---|
BrokerClientImpl()
Default Constructor of BrokerClientImpl |
Method Summary | |
---|---|
void |
cleanUp()
cleanup |
protected void |
close()
|
void |
consume(Packet packet)
Consume a Packet from the underlying TransportChannel for processing |
void |
consumeConnectionInfo(ConnectionInfo info)
register with the Broker |
void |
consumeConsumerInfo(ConsumerInfo info)
Register/deregister MessageConsumer with the Broker |
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 |
onException(JMSException jmsEx)
|
protected void |
send(Packet packet)
|
void |
setSubject(Subject subject)
Associcates a subject with BrokerClient. |
void |
start()
start consuming messages |
void |
stop()
stop consuming messages |
String |
toString()
|
void |
updateBrokerCapacity(int capacity)
Update the peer Connection about the Broker's capacity for messages |
void |
validateConnection(int timeout)
validate the connection |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public BrokerClientImpl()
Method Detail |
---|
public void initialize(BrokerConnector brokerConnector, TransportChannel channel)
initialize
in interface BrokerClient
brokerConnector
- channel
- public BrokerConnector getBrokerConnector()
getBrokerConnector
in interface BrokerClient
public ConnectionInfo getConnectionInfo()
getConnectionInfo
in interface BrokerClient
public void onException(JMSException jmsEx)
onException
in interface ExceptionListener
ExceptionListener.onException(javax.jms.JMSException)
public String toString()
toString
in class Object
public void dispatch(ActiveMQMessage message)
dispatch
in interface BrokerClient
message
- public boolean isBrokerConnection()
isBrokerConnection
in interface BrokerClient
public boolean isClusteredConnection()
isClusteredConnection
in interface BrokerClient
public int getCapacity()
getCapacity
in interface BrokerClient
public String getClientID()
getClientID
in interface BrokerClient
public TransportChannel getChannel()
getChannel
in interface BrokerClient
public boolean isSlowConsumer()
isSlowConsumer
in interface BrokerClient
public void consume(Packet packet)
consume
in interface PacketListener
packet
- public void consumeConsumerInfo(ConsumerInfo info) throws JMSException
info
-
JMSException
public void updateBrokerCapacity(int capacity)
updateBrokerCapacity
in interface BrokerClient
capacity
- public void consumeConnectionInfo(ConnectionInfo info) throws JMSException
info
-
JMSException
public void start() throws JMSException
start
in interface Service
JMSException
public void stop() throws JMSException
stop
in interface Service
JMSException
public void cleanUp()
cleanUp
in interface BrokerClient
protected void send(Packet packet)
public void validateConnection(int timeout) throws JMSException
validateConnection
in interface BrokerClient
timeout
-
JMSException
protected void close()
public void setSubject(Subject subject)
BrokerClient
setSubject
in interface BrokerClient
subject
- public Subject getSubject()
getSubject
in interface BrokerClient
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |