org.hornetq.rest.queue
Class ConsumersResource
java.lang.Object
org.hornetq.rest.queue.ConsumersResource
- All Implemented Interfaces:
- TimeoutTask.Callback
public class ConsumersResource
- extends java.lang.Object
- implements TimeoutTask.Callback
- Version:
- $Revision: 1 $
- Author:
- Bill Burke
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
queueConsumers
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,QueueConsumer> queueConsumers
sessionFactory
protected org.hornetq.api.core.client.ClientSessionFactory sessionFactory
destination
protected java.lang.String destination
startup
protected final java.lang.String startup
sessionCounter
protected java.util.concurrent.atomic.AtomicLong sessionCounter
consumerTimeoutSeconds
protected int consumerTimeoutSeconds
serviceManager
protected DestinationServiceManager serviceManager
ACKNOWLEDGED
protected static final int ACKNOWLEDGED
- See Also:
- Constant Field Values
SELECTOR_SET
protected static final int SELECTOR_SET
- See Also:
- Constant Field Values
ConsumersResource
public ConsumersResource()
getServiceManager
public DestinationServiceManager getServiceManager()
setServiceManager
public void setServiceManager(DestinationServiceManager serviceManager)
getSessionFactory
public org.hornetq.api.core.client.ClientSessionFactory getSessionFactory()
setSessionFactory
public void setSessionFactory(org.hornetq.api.core.client.ClientSessionFactory sessionFactory)
getDestination
public java.lang.String getDestination()
setDestination
public void setDestination(java.lang.String destination)
getConsumerTimeoutSeconds
public int getConsumerTimeoutSeconds()
setConsumerTimeoutSeconds
public void setConsumerTimeoutSeconds(int consumerTimeoutSeconds)
testTimeout
public void testTimeout(java.lang.String target)
- Specified by:
testTimeout
in interface TimeoutTask.Callback
stop
public void stop()
createSubscription
public javax.ws.rs.core.Response createSubscription(boolean autoAck,
java.lang.String selector,
@Context
javax.ws.rs.core.UriInfo uriInfo)
addConsumer
protected void addConsumer(QueueConsumer consumer)
createConsumer
public QueueConsumer createConsumer(java.lang.String selector)
throws org.hornetq.api.core.HornetQException
- Throws:
org.hornetq.api.core.HornetQException
createAcknowledgedConsumer
public QueueConsumer createAcknowledgedConsumer(java.lang.String selector)
throws org.hornetq.api.core.HornetQException
- Throws:
org.hornetq.api.core.HornetQException
getConsumer
public javax.ws.rs.core.Response getConsumer(int attributes,
java.lang.String consumerId,
@Context
javax.ws.rs.core.UriInfo uriInfo)
throws java.lang.Exception
- Throws:
java.lang.Exception
headConsumer
public javax.ws.rs.core.Response headConsumer(int attributes,
java.lang.String consumerId,
@Context
javax.ws.rs.core.UriInfo uriInfo)
throws java.lang.Exception
- Throws:
java.lang.Exception
findConsumer
public QueueConsumer findConsumer(int attributes,
java.lang.String consumerId,
@Context
javax.ws.rs.core.UriInfo uriInfo)
throws java.lang.Exception
- Throws:
java.lang.Exception
closeSession
public void closeSession(java.lang.String consumerId)
Copyright © 2013. All Rights Reserved.