org.apache.activemq.artemis.rest.queue

Class QueueConsumer

java.lang.Object

org.apache.activemq.artemis.rest.queue.QueueConsumer

Direct Known Subclasses:

AcknowledgedQueueConsumer, SubscriptionResource

public class QueueConsumer
extends Object

Auto-acknowledged consumer

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	autoAck
protected boolean	closed
protected org.apache.activemq.artemis.api.core.client.ClientConsumer	consumer
protected String	destination
protected org.apache.activemq.artemis.api.core.client.ClientSessionFactory	factory
protected String	id
protected ConsumedMessage	lastConsumed
protected long	lastPing
protected long	previousIndex token used to create consume-next links
protected String	selector
protected DestinationServiceManager	serviceManager
protected org.apache.activemq.artemis.api.core.client.ClientSession	session

Constructor Summary

Constructors

Constructor and Description
QueueConsumer(org.apache.activemq.artemis.api.core.client.ClientSessionFactory factory, String destination, String id, DestinationServiceManager serviceManager, String selector)

Method Summary

Modifier and Type	Method and Description
protected javax.ws.rs.core.Response	checkIndexAndPoll(long wait, javax.ws.rs.core.UriInfo info, String basePath, long index)
protected void	createSession()
long	getConsumeIndex()
String	getId()
org.apache.activemq.artemis.jms.client.ConnectionFactoryOptions	getJmsOptions()
long	getLastPingTime()
protected javax.ws.rs.core.Response.ResponseBuilder	getMessageResponse(ConsumedMessage msg, javax.ws.rs.core.UriInfo info, String basePath, String index)
DestinationServiceManager	getServiceManager()
boolean	isClosed()
protected void	ping(long offsetSecs)
javax.ws.rs.core.Response	poll(long wait, long index, javax.ws.rs.core.UriInfo info)
protected javax.ws.rs.core.Response	pollWithIndex(long wait, javax.ws.rs.core.UriInfo info, String basePath, long index)
protected org.apache.activemq.artemis.api.core.client.ClientMessage	receive(long timeoutSecs)
protected org.apache.activemq.artemis.api.core.client.ClientMessage	receiveFromConsumer(long timeoutSecs)
static void	setConsumeNextLink(LinkStrategy linkStrategy, javax.ws.rs.core.Response.ResponseBuilder response, javax.ws.rs.core.UriInfo info, String basePath, String index)
protected void	setMessageResponseLinks(javax.ws.rs.core.UriInfo info, String basePath, javax.ws.rs.core.Response.ResponseBuilder responseBuilder, String index)
protected void	setPollTimeoutLinks(javax.ws.rs.core.UriInfo info, String basePath, javax.ws.rs.core.Response.ResponseBuilder builder, String index)
void	setServiceManager(DestinationServiceManager serviceManager)
void	setSessionLink(javax.ws.rs.core.Response.ResponseBuilder response, javax.ws.rs.core.UriInfo info, String basePath)
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

factory

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

session

protected org.apache.activemq.artemis.api.core.client.ClientSession session

consumer

protected org.apache.activemq.artemis.api.core.client.ClientConsumer consumer

destination

protected String destination

closed

protected boolean closed

id

protected String id

lastPing

protected long lastPing

serviceManager

protected DestinationServiceManager serviceManager

autoAck

protected boolean autoAck

selector

protected String selector

previousIndex

protected long previousIndex

token used to create consume-next links

lastConsumed

protected ConsumedMessage lastConsumed

Constructor Detail

QueueConsumer

public QueueConsumer(org.apache.activemq.artemis.api.core.client.ClientSessionFactory factory,
                     String destination,
                     String id,
                     DestinationServiceManager serviceManager,
                     String selector)
              throws org.apache.activemq.artemis.api.core.ActiveMQException

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

Method Detail

getConsumeIndex

public long getConsumeIndex()

getServiceManager

public DestinationServiceManager getServiceManager()

setServiceManager

public void setServiceManager(DestinationServiceManager serviceManager)

getLastPingTime

public long getLastPingTime()

ping

protected void ping(long offsetSecs)

getId

public String getId()

isClosed

public boolean isClosed()

shutdown

public void shutdown()

poll

@Path(value="consume-next{index}")
 @POST
public javax.ws.rs.core.Response poll(@HeaderParam(value="Accept-Wait") @DefaultValue(value="0")
                                                                                long wait,
                                                                                @PathParam(value="index")
                                                                                long index,
                                                                                @Context
                                                                                javax.ws.rs.core.UriInfo info)

checkIndexAndPoll

protected javax.ws.rs.core.Response checkIndexAndPoll(long wait,
                                                      javax.ws.rs.core.UriInfo info,
                                                      String basePath,
                                                      long index)

pollWithIndex

protected javax.ws.rs.core.Response pollWithIndex(long wait,
                                                  javax.ws.rs.core.UriInfo info,
                                                  String basePath,
                                                  long index)

createSession

protected void createSession()
                      throws org.apache.activemq.artemis.api.core.ActiveMQException

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

receiveFromConsumer

protected org.apache.activemq.artemis.api.core.client.ClientMessage receiveFromConsumer(long timeoutSecs)
                                                                                 throws Exception

Throws:

Exception

receive

protected org.apache.activemq.artemis.api.core.client.ClientMessage receive(long timeoutSecs)
                                                                     throws Exception

Throws:

Exception

setPollTimeoutLinks

protected void setPollTimeoutLinks(javax.ws.rs.core.UriInfo info,
                                   String basePath,
                                   javax.ws.rs.core.Response.ResponseBuilder builder,
                                   String index)

getMessageResponse

protected javax.ws.rs.core.Response.ResponseBuilder getMessageResponse(ConsumedMessage msg,
                                                                       javax.ws.rs.core.UriInfo info,
                                                                       String basePath,
                                                                       String index)

setMessageResponseLinks

protected void setMessageResponseLinks(javax.ws.rs.core.UriInfo info,
                                       String basePath,
                                       javax.ws.rs.core.Response.ResponseBuilder responseBuilder,
                                       String index)

setConsumeNextLink

public static void setConsumeNextLink(LinkStrategy linkStrategy,
                                      javax.ws.rs.core.Response.ResponseBuilder response,
                                      javax.ws.rs.core.UriInfo info,
                                      String basePath,
                                      String index)

setSessionLink

public void setSessionLink(javax.ws.rs.core.Response.ResponseBuilder response,
                           javax.ws.rs.core.UriInfo info,
                           String basePath)

getJmsOptions

public org.apache.activemq.artemis.jms.client.ConnectionFactoryOptions getJmsOptions()