|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.region.policy.AbortSlowConsumerStrategy
public class AbortSlowConsumerStrategy
Abort slow consumers when they reach the configured threshold of slowness, default is slow for 30 seconds
Constructor Summary | |
---|---|
AbortSlowConsumerStrategy()
|
Method Summary | |
---|---|
void |
abortConsumer(Subscription sub,
boolean abortSubscriberConnection)
|
long |
getCheckPeriod()
|
long |
getMaxSlowCount()
|
long |
getMaxSlowDuration()
|
java.lang.String |
getName()
|
java.util.Map<Subscription,SlowConsumerEntry> |
getSlowConsumers()
|
boolean |
isAbortConnection()
|
void |
run()
|
void |
setAbortConnection(boolean abortConnection)
abort the consumers connection rather than sending a stop command to the remote consumer |
void |
setBrokerService(Broker broker)
|
void |
setCheckPeriod(long checkPeriod)
time in milliseconds between checks for slow subscriptions |
void |
setMaxSlowCount(long maxSlowCount)
number of times a subscription can be deemed slow before triggering abort effect depends on dispatch rate as slow determination is done on dispatch |
void |
setMaxSlowDuration(long maxSlowDuration)
time in milliseconds that a sub can remain slow before triggering an abort. |
void |
setName(java.lang.String name)
|
void |
slowConsumer(ConnectionContext context,
Subscription subs)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AbortSlowConsumerStrategy()
Method Detail |
---|
public void setBrokerService(Broker broker)
setBrokerService
in interface SlowConsumerStrategy
public void slowConsumer(ConnectionContext context, Subscription subs)
slowConsumer
in interface SlowConsumerStrategy
public void run()
run
in interface java.lang.Runnable
public void abortConsumer(Subscription sub, boolean abortSubscriberConnection)
public long getMaxSlowCount()
public void setMaxSlowCount(long maxSlowCount)
public long getMaxSlowDuration()
public void setMaxSlowDuration(long maxSlowDuration)
maxSlowDuration
- public long getCheckPeriod()
public void setCheckPeriod(long checkPeriod)
checkPeriod
- public boolean isAbortConnection()
public void setAbortConnection(boolean abortConnection)
abortConnection
- public void setName(java.lang.String name)
public java.lang.String getName()
public java.util.Map<Subscription,SlowConsumerEntry> getSlowConsumers()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |