org.hornetq.rest.queue.push
Class PushConsumer
java.lang.Object
org.hornetq.rest.queue.push.PushConsumer
- All Implemented Interfaces:
- org.hornetq.api.core.client.MessageHandler
public class PushConsumer
- extends java.lang.Object
- implements org.hornetq.api.core.client.MessageHandler
- Version:
- $Revision: 1 $
- Author:
- Bill Burke
Field Summary |
protected org.hornetq.api.core.client.ClientConsumer |
consumer
|
protected java.lang.String |
destination
|
protected org.hornetq.api.core.client.ClientSessionFactory |
factory
|
protected java.lang.String |
id
|
protected org.hornetq.api.core.client.ClientSession |
session
|
protected PushStrategy |
strategy
|
Constructor Summary |
PushConsumer(org.hornetq.api.core.client.ClientSessionFactory factory,
java.lang.String destination,
java.lang.String id,
PushRegistration registration)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
factory
protected org.hornetq.api.core.client.ClientSessionFactory factory
session
protected org.hornetq.api.core.client.ClientSession session
consumer
protected org.hornetq.api.core.client.ClientConsumer consumer
destination
protected java.lang.String destination
id
protected java.lang.String id
strategy
protected PushStrategy strategy
PushConsumer
public PushConsumer(org.hornetq.api.core.client.ClientSessionFactory factory,
java.lang.String destination,
java.lang.String id,
PushRegistration registration)
getRegistration
public PushRegistration getRegistration()
getDestination
public java.lang.String getDestination()
start
public void start()
throws java.lang.Exception
- Throws:
java.lang.Exception
stop
public void stop()
onMessage
public void onMessage(org.hornetq.api.core.client.ClientMessage clientMessage)
- Specified by:
onMessage
in interface org.hornetq.api.core.client.MessageHandler
Copyright © 2013. All Rights Reserved.