org.apache.qpid.example.subscriber
Class Subscriber
java.lang.Object
org.apache.qpid.example.subscriber.Subscriber
- Direct Known Subclasses:
- MonitoredSubscriber
public class Subscriber
- extends Object
Subscriber which consumes messages from a queue
Method Summary |
void |
stop()
Stop consuming and close connection |
void |
subscribe()
Subscribes to example Queue and attaches listener |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
_connection
protected Connection _connection
_consumer
protected MessageConsumer _consumer
_contextHelper
protected InitialContextHelper _contextHelper
_connectionFactory
protected org.apache.qpid.client.AMQConnectionFactory _connectionFactory
_destination
protected Destination _destination
Subscriber
public Subscriber()
subscribe
public void subscribe()
- Subscribes to example Queue and attaches listener
stop
public void stop()
- Stop consuming and close connection
Licensed to the Apache Software Foundation