org.apache.activemq.artemis.rest.topic

Class PushSubscriptionsResource

java.lang.Object

org.apache.activemq.artemis.rest.topic.PushSubscriptionsResource

public class PushSubscriptionsResource
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,PushSubscription>	consumers
protected String	destination
protected TopicPushStore	pushStore
protected AtomicLong	sessionCounter
protected org.apache.activemq.artemis.api.core.client.ClientSessionFactory	sessionFactory
protected String	startup

Constructor Summary

Constructors

Constructor and Description
PushSubscriptionsResource(org.apache.activemq.artemis.jms.client.ConnectionFactoryOptions jmsOptions)

Method Summary

Modifier and Type	Method and Description
void	addRegistration(PushTopicRegistration reg)
javax.ws.rs.core.Response	create(javax.ws.rs.core.UriInfo uriInfo, PushTopicRegistration registration)
org.apache.activemq.artemis.api.core.client.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()
org.apache.activemq.artemis.api.core.client.ClientSessionFactory	getSessionFactory()
void	setDestination(String destination)
void	setPushStore(TopicPushStore pushStore)
void	setSessionFactory(org.apache.activemq.artemis.api.core.client.ClientSessionFactory sessionFactory)
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

consumers

protected Map<String,PushSubscription> consumers

sessionFactory

protected org.apache.activemq.artemis.api.core.client.ClientSessionFactory sessionFactory

destination

protected String destination

startup

protected final String startup

sessionCounter

protected final AtomicLong sessionCounter

pushStore

protected TopicPushStore pushStore

Constructor Detail

PushSubscriptionsResource

public PushSubscriptionsResource(org.apache.activemq.artemis.jms.client.ConnectionFactoryOptions jmsOptions)

Method Detail

stop

public void stop()

getPushStore

public TopicPushStore getPushStore()

setPushStore

public void setPushStore(TopicPushStore pushStore)

createSubscription

public org.apache.activemq.artemis.api.core.client.ClientSession createSubscription(String subscriptionName,
                                                                                    boolean durable)

addRegistration

public void addRegistration(PushTopicRegistration reg)
                     throws Exception

Throws:

Exception

create

@POST
public javax.ws.rs.core.Response create(@Context
                                              javax.ws.rs.core.UriInfo uriInfo,
                                              PushTopicRegistration registration)

getConsumer

@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)

deleteConsumer

@DELETE
 @Path(value="{consumer-id}")
public void deleteConsumer(@Context
                                                                 javax.ws.rs.core.UriInfo uriInfo,
                                                                 @PathParam(value="consumer-id")
                                                                 String consumerId)

getConsumers

public Map<String,PushSubscription> getConsumers()

getSessionFactory

public org.apache.activemq.artemis.api.core.client.ClientSessionFactory getSessionFactory()

setSessionFactory

public void setSessionFactory(org.apache.activemq.artemis.api.core.client.ClientSessionFactory sessionFactory)

getDestination

public String getDestination()

setDestination

public void setDestination(String destination)