public abstract class ConsumerEvent extends EventObject
source
Constructor and Description |
---|
ConsumerEvent(ConsumerEventSource source,
Destination destination,
ConsumerId consumerId,
int consumerCount) |
Modifier and Type | Method and Description |
---|---|
ConsumerEventSource |
getAdvisor() |
int |
getConsumerCount()
Returns the current number of consumers active at the time this advisory was sent.
|
ConsumerId |
getConsumerId() |
Destination |
getDestination() |
abstract boolean |
isStarted() |
getSource, toString
public ConsumerEvent(ConsumerEventSource source, Destination destination, ConsumerId consumerId, int consumerCount)
public ConsumerEventSource getAdvisor()
public Destination getDestination()
public int getConsumerCount()
ConsumerListener
after many consumers have started, you will receive a ConsumerEvent for each consumer. However the
getConsumerCount()
method will always return the current active consumer count on each event.public ConsumerId getConsumerId()
public abstract boolean isStarted()
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.