public class PushSubscriptionsResource extends Object
Modifier and Type | Field and Description |
---|---|
protected Map<String,PushSubscription> |
consumers |
protected String |
destination |
protected TopicPushStore |
pushStore |
protected AtomicLong |
sessionCounter |
protected ClientSessionFactory |
sessionFactory |
protected String |
startup |
Constructor and Description |
---|
PushSubscriptionsResource(ConnectionFactoryOptions jmsOptions) |
Modifier and Type | Method and Description |
---|---|
void |
addRegistration(PushTopicRegistration reg) |
javax.ws.rs.core.Response |
create(javax.ws.rs.core.UriInfo uriInfo,
PushTopicRegistration registration) |
ClientSession |
createSubscription(String subscriptionName,
boolean durable) |
void |
deleteConsumer(javax.ws.rs.core.UriInfo uriInfo,
String consumerId) |
PushTopicRegistration |
getConsumer(javax.ws.rs.core.UriInfo uriInfo,
String consumerId) |
Map<String,PushSubscription> |
getConsumers() |
String |
getDestination() |
TopicPushStore |
getPushStore() |
ClientSessionFactory |
getSessionFactory() |
void |
setDestination(String destination) |
void |
setPushStore(TopicPushStore pushStore) |
void |
setSessionFactory(ClientSessionFactory sessionFactory) |
void |
stop() |
protected Map<String,PushSubscription> consumers
protected ClientSessionFactory sessionFactory
protected String destination
protected final String startup
protected final AtomicLong sessionCounter
protected TopicPushStore pushStore
public PushSubscriptionsResource(ConnectionFactoryOptions jmsOptions)
public void stop()
public TopicPushStore getPushStore()
public void setPushStore(TopicPushStore pushStore)
public ClientSession createSubscription(String subscriptionName, boolean durable)
public void addRegistration(PushTopicRegistration reg) throws Exception
Exception
@POST public javax.ws.rs.core.Response create(@Context javax.ws.rs.core.UriInfo uriInfo, PushTopicRegistration registration)
@GET @Path(value="{consumer-id}") @Produces(value="application/xml") public PushTopicRegistration getConsumer(@Context javax.ws.rs.core.UriInfo uriInfo, @PathParam(value="consumer-id") String consumerId)
@DELETE @Path(value="{consumer-id}") public void deleteConsumer(@Context javax.ws.rs.core.UriInfo uriInfo, @PathParam(value="consumer-id") String consumerId)
public Map<String,PushSubscription> getConsumers()
public ClientSessionFactory getSessionFactory()
public void setSessionFactory(ClientSessionFactory sessionFactory)
public String getDestination()
public void setDestination(String destination)
Copyright © 2016 The Apache Software Foundation. All rights reserved.