public class PushConsumerResource extends Object
Modifier and Type | Field and Description |
---|---|
protected Map<String,PushConsumer> |
consumers |
protected String |
destination |
protected PushStore |
pushStore |
protected AtomicLong |
sessionCounter |
protected ClientSessionFactory |
sessionFactory |
protected String |
startup |
Constructor and Description |
---|
PushConsumerResource() |
Modifier and Type | Method and Description |
---|---|
void |
addRegistration(PushRegistration reg) |
javax.ws.rs.core.Response |
create(javax.ws.rs.core.UriInfo uriInfo,
PushRegistration registration) |
void |
deleteConsumer(javax.ws.rs.core.UriInfo uriInfo,
String consumerId) |
PushRegistration |
getConsumer(javax.ws.rs.core.UriInfo uriInfo,
String consumerId) |
Map<String,PushConsumer> |
getConsumers() |
String |
getDestination() |
PushStore |
getPushStore() |
ClientSessionFactory |
getSessionFactory() |
void |
setDestination(String destination) |
void |
setJmsOptions(ConnectionFactoryOptions jmsOptions) |
void |
setPushStore(PushStore pushStore) |
void |
setSessionFactory(ClientSessionFactory sessionFactory) |
void |
start() |
void |
stop() |
protected Map<String,PushConsumer> consumers
protected ClientSessionFactory sessionFactory
protected String destination
protected final String startup
protected final AtomicLong sessionCounter
protected PushStore pushStore
public void start()
public void stop()
public PushStore getPushStore()
public void setPushStore(PushStore pushStore)
public void addRegistration(PushRegistration reg) throws Exception
Exception
@POST @Consumes(value="application/xml") public javax.ws.rs.core.Response create(@Context javax.ws.rs.core.UriInfo uriInfo, PushRegistration registration)
@GET @Path(value="{consumer-id}") @Produces(value="application/xml") public PushRegistration 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,PushConsumer> getConsumers()
public ClientSessionFactory getSessionFactory()
public void setSessionFactory(ClientSessionFactory sessionFactory)
public String getDestination()
public void setDestination(String destination)
public void setJmsOptions(ConnectionFactoryOptions jmsOptions)
Copyright © 2016 The Apache Software Foundation. All rights reserved.