|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.BrokerFilter
org.apache.activemq.broker.cluster.ConnectionSplitBroker
public class ConnectionSplitBroker
Monitors for client connections that may fail to another broker - but this broker isn't aware they've gone. Can occur with network glitches or client error
Field Summary |
---|
Fields inherited from class org.apache.activemq.broker.BrokerFilter |
---|
next |
Constructor Summary | |
---|---|
ConnectionSplitBroker(Broker next)
|
Method Summary | |
---|---|
Subscription |
addConsumer(ConnectionContext context,
ConsumerInfo info)
Adds a consumer. |
void |
removeConsumer(ConnectionContext context,
ConsumerInfo info)
Removes a consumer. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ConnectionSplitBroker(Broker next)
Method Detail |
---|
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
Region
addConsumer
in interface Region
addConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.
java.lang.Exception
- TODOpublic void removeConsumer(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
Region
removeConsumer
in interface Region
removeConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.
java.lang.Exception
- TODO
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |