org.hornetq.rest.queue

Class ConsumersResource

java.lang.Object

org.hornetq.rest.queue.ConsumersResource

All Implemented Interfaces:

TimeoutTask.Callback

public class ConsumersResource
extends Object
implements TimeoutTask.Callback

Version:

$Revision: 1 $

Author:

Bill Burke

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
ConsumersResource()

Method Summary

Modifier and Type	Method and Description
protected void	addConsumer(QueueConsumer consumer)
void	closeSession(String consumerId, javax.ws.rs.core.UriInfo uriInfo)
QueueConsumer	createAcknowledgedConsumer(String selector)
QueueConsumer	createConsumer(String selector)
javax.ws.rs.core.Response	createSubscription(boolean autoAck, String selector, javax.ws.rs.core.UriInfo uriInfo)
QueueConsumer	findConsumer(int attributes, String consumerId, javax.ws.rs.core.UriInfo uriInfo)
javax.ws.rs.core.Response	getConsumer(int attributes, String consumerId, javax.ws.rs.core.UriInfo uriInfo)
int	getConsumerTimeoutSeconds()
String	getDestination()
DestinationServiceManager	getServiceManager()
ClientSessionFactory	getSessionFactory()
javax.ws.rs.core.Response	headConsumer(int attributes, 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

ACKNOWLEDGED

protected static final int ACKNOWLEDGED

See Also:

Constant Field Values

SELECTOR_SET

protected static final int SELECTOR_SET

See Also:

Constant Field Values

Constructor Detail

ConsumersResource

public ConsumersResource()

Method Detail

getServiceManager

public DestinationServiceManager getServiceManager()

setServiceManager

public void setServiceManager(DestinationServiceManager serviceManager)

getSessionFactory

public ClientSessionFactory getSessionFactory()

setSessionFactory

public void setSessionFactory(ClientSessionFactory sessionFactory)

getDestination

public String getDestination()

setDestination

public void setDestination(String destination)

getConsumerTimeoutSeconds

public int getConsumerTimeoutSeconds()

setConsumerTimeoutSeconds

public void setConsumerTimeoutSeconds(int consumerTimeoutSeconds)

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

createSubscription

@POST
public javax.ws.rs.core.Response createSubscription(@FormParam(value="autoAck") @DefaultValue(value="true")
                                                          boolean autoAck,
                                                          @FormParam(value="selector")
                                                          String selector,
                                                          @Context
                                                          javax.ws.rs.core.UriInfo uriInfo)

addConsumer

protected void addConsumer(QueueConsumer consumer)

createConsumer

public QueueConsumer createConsumer(String selector)
                             throws HornetQException

Throws:

HornetQException

createAcknowledgedConsumer

public QueueConsumer createAcknowledgedConsumer(String selector)
                                         throws HornetQException

Throws:

HornetQException

getConsumer

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

Throws:

Exception

headConsumer

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

Throws:

Exception

findConsumer

@Path(value="attributes-{attributes}/{consumer-id}")
public QueueConsumer findConsumer(@PathParam(value="attributes")
                                                                                       int attributes,
                                                                                       @PathParam(value="consumer-id")
                                                                                       String consumerId,
                                                                                       @Context
                                                                                       javax.ws.rs.core.UriInfo uriInfo)
                                                                                throws Exception

Throws:

Exception

closeSession

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