org.hornetq.rest.topic
Class PushSubscriptionsResource
java.lang.Object
org.hornetq.rest.topic.PushSubscriptionsResource
public class PushSubscriptionsResource
- extends java.lang.Object
- Version:
- $Revision: 1 $
- Author:
- Bill Burke
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
consumers
protected java.util.Map<java.lang.String,PushConsumer> consumers
sessionFactory
protected org.hornetq.api.core.client.ClientSessionFactory sessionFactory
destination
protected java.lang.String destination
startup
protected final java.lang.String startup
sessionCounter
protected final java.util.concurrent.atomic.AtomicLong sessionCounter
pushStore
protected TopicPushStore pushStore
PushSubscriptionsResource
public PushSubscriptionsResource()
stop
public void stop()
getPushStore
public TopicPushStore getPushStore()
setPushStore
public void setPushStore(TopicPushStore pushStore)
createSubscription
public org.hornetq.api.core.client.ClientSession createSubscription(java.lang.String subscriptionName,
boolean durable)
addRegistration
public void addRegistration(PushTopicRegistration reg)
throws java.lang.Exception
- Throws:
java.lang.Exception
create
public javax.ws.rs.core.Response create(@Context
javax.ws.rs.core.UriInfo uriInfo,
PushTopicRegistration registration)
getConsumer
public PushTopicRegistration getConsumer(java.lang.String consumerId)
deleteConsumer
public void deleteConsumer(java.lang.String consumerId)
getConsumers
public java.util.Map<java.lang.String,PushConsumer> getConsumers()
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)
Copyright © 2013. All Rights Reserved.