org.hornetq.rest.topic

Class SubscriptionsResource

java.lang.Object

org.hornetq.rest.topic.SubscriptionsResource

All Implemented Interfaces:

TimeoutTask.Callback

public class SubscriptionsResource
extends Object
implements TimeoutTask.Callback

Version:

$Revision: 1 $

Author:

Bill Burke

Field Summary

Fields

Modifier and Type	Field and Description
protected int	consumerTimeoutSeconds
protected String	destination
protected ConcurrentHashMap<String,QueueConsumer>	queueConsumers
protected DestinationServiceManager	serviceManager
protected AtomicLong	sessionCounter
protected ClientSessionFactory	sessionFactory
protected String	startup

Constructor Summary

Constructors

Constructor and Description
SubscriptionsResource()

Method Summary

Modifier and Type	Method and Description
protected QueueConsumer	createConsumer(boolean durable, boolean autoAck, String subscriptionName, String selector, long timeout, boolean deleteWhenIdle)
javax.ws.rs.core.Response	createSubscription(boolean durable, boolean autoAck, String subscriptionName, String selector, Boolean destroyWhenIdle, Long timeout, javax.ws.rs.core.UriInfo uriInfo)
void	deleteAckSubscription(javax.ws.rs.core.UriInfo uriInfo, String consumerId)
void	deleteSubscription(javax.ws.rs.core.UriInfo uriInfo, String consumerId)
QueueConsumer	findAcknoledgeSubscription(String subscriptionId)
QueueConsumer	findAutoAckSubscription(String subscriptionId)
protected String	generateSubscriptionName()
javax.ws.rs.core.Response	getAcknowledgedConsumer(String consumerId, javax.ws.rs.core.UriInfo uriInfo)
javax.ws.rs.core.Response	getAutoAckSubscription(String consumerId, javax.ws.rs.core.UriInfo uriInfo)
int	getConsumerTimeoutSeconds()
String	getDestination()
DestinationServiceManager	getServiceManager()
ClientSessionFactory	getSessionFactory()
javax.ws.rs.core.Response	headAcknowledgedConsumer(String consumerId, javax.ws.rs.core.UriInfo uriInfo)
javax.ws.rs.core.Response	headAutoAckSubscription(String consumerId, javax.ws.rs.core.UriInfo uriInfo)
void	setConsumerTimeoutSeconds(int consumerTimeoutSeconds)
void	setDestination(String destination)
void	setServiceManager(DestinationServiceManager serviceManager)
void	setSessionFactory(ClientSessionFactory sessionFactory)
void	shutdown(String target)
void	stop()
boolean	testTimeout(String target, boolean autoShutdown)

Methods inherited from class java.lang.Object

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

Field Detail

queueConsumers

protected ConcurrentHashMap<String,QueueConsumer> queueConsumers

sessionFactory

protected ClientSessionFactory sessionFactory

destination

protected String destination

startup

protected final String startup

sessionCounter

protected AtomicLong sessionCounter

consumerTimeoutSeconds

protected int consumerTimeoutSeconds

serviceManager

protected DestinationServiceManager serviceManager

Constructor Detail

SubscriptionsResource

public SubscriptionsResource()

Method Detail

getServiceManager

public DestinationServiceManager getServiceManager()

setServiceManager

public void setServiceManager(DestinationServiceManager serviceManager)

getConsumerTimeoutSeconds

public int getConsumerTimeoutSeconds()

setConsumerTimeoutSeconds

public void setConsumerTimeoutSeconds(int consumerTimeoutSeconds)

getSessionFactory

public ClientSessionFactory getSessionFactory()

setSessionFactory

public void setSessionFactory(ClientSessionFactory sessionFactory)

getDestination

public String getDestination()

setDestination

public void setDestination(String destination)

testTimeout

public boolean testTimeout(String target,
                           boolean autoShutdown)

Specified by:

testTimeout in interface TimeoutTask.Callback

shutdown

public void shutdown(String target)

Specified by:

shutdown in interface TimeoutTask.Callback

stop

public void stop()

generateSubscriptionName

protected String generateSubscriptionName()

createSubscription

@POST
public javax.ws.rs.core.Response createSubscription(@FormParam(value="durable") @DefaultValue(value="false")
                                                          boolean durable,
                                                          @FormParam(value="autoAck") @DefaultValue(value="true")
                                                          boolean autoAck,
                                                          @FormParam(value="name")
                                                          String subscriptionName,
                                                          @FormParam(value="selector")
                                                          String selector,
                                                          @FormParam(value="delete-when-idle")
                                                          Boolean destroyWhenIdle,
                                                          @FormParam(value="idle-timeout")
                                                          Long timeout,
                                                          @Context
                                                          javax.ws.rs.core.UriInfo uriInfo)

createConsumer

protected QueueConsumer createConsumer(boolean durable,
                                       boolean autoAck,
                                       String subscriptionName,
                                       String selector,
                                       long timeout,
                                       boolean deleteWhenIdle)
                                throws HornetQException

Throws:

HornetQException

getAutoAckSubscription

@Path(value="auto-ack/{consumer-id}")
 @GET
public javax.ws.rs.core.Response getAutoAckSubscription(@PathParam(value="consumer-id")
                                                                                                    String consumerId,
                                                                                                    @Context
                                                                                                    javax.ws.rs.core.UriInfo uriInfo)
                                                                                             throws Exception

Throws:

Exception

headAutoAckSubscription

@Path(value="auto-ack/{consumer-id}")
 @HEAD
public javax.ws.rs.core.Response headAutoAckSubscription(@PathParam(value="consumer-id")
                                                                                                      String consumerId,
                                                                                                      @Context
                                                                                                      javax.ws.rs.core.UriInfo uriInfo)
                                                                                               throws Exception

Throws:

Exception

findAutoAckSubscription

@Path(value="auto-ack/{subscription-id}")
public QueueConsumer findAutoAckSubscription(@PathParam(value="subscription-id")
                                                                                       String subscriptionId)

getAcknowledgedConsumer

@Path(value="acknowledged/{consumer-id}")
 @GET
public javax.ws.rs.core.Response getAcknowledgedConsumer(@PathParam(value="consumer-id")
                                                                                                         String consumerId,
                                                                                                         @Context
                                                                                                         javax.ws.rs.core.UriInfo uriInfo)
                                                                                                  throws Exception

Throws:

Exception

headAcknowledgedConsumer

@Path(value="acknowledged/{consumer-id}")
 @HEAD
public javax.ws.rs.core.Response headAcknowledgedConsumer(@PathParam(value="consumer-id")
                                                                                                           String consumerId,
                                                                                                           @Context
                                                                                                           javax.ws.rs.core.UriInfo uriInfo)
                                                                                                    throws Exception

Throws:

Exception

findAcknoledgeSubscription

@Path(value="acknowledged/{subscription-id}")
public QueueConsumer findAcknoledgeSubscription(@PathParam(value="subscription-id")
                                                                                              String subscriptionId)

deleteAckSubscription

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

deleteSubscription

@Path(value="auto-ack/{subscription-id}")
 @DELETE
public void deleteSubscription(@Context
                                                                                  javax.ws.rs.core.UriInfo uriInfo,
                                                                                  @PathParam(value="subscription-id")
                                                                                  String consumerId)