public class ConsumerEventSource extends Object implements Service, MessageListener
Constructor and Description |
---|
ConsumerEventSource(Connection connection,
Destination destination) |
Modifier and Type | Method and Description |
---|---|
protected int |
extractConsumerCountFromMessage(Message message,
int count)
Lets rely by default on the broker telling us what the consumer count is
as it can ensure that we are up to date at all times and have not
received messages out of order etc.
|
protected void |
fireConsumerEvent(ConsumerEvent event) |
String |
getConsumerId() |
void |
onMessage(Message message) |
void |
setConsumerListener(ConsumerListener listener) |
void |
start() |
void |
stop() |
public ConsumerEventSource(Connection connection, Destination destination) throws JMSException
JMSException
public void setConsumerListener(ConsumerListener listener)
public String getConsumerId()
public void onMessage(Message message)
onMessage
in interface MessageListener
protected int extractConsumerCountFromMessage(Message message, int count)
protected void fireConsumerEvent(ConsumerEvent event)
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.