public class AcknowledgedQueueConsumer extends QueueConsumer
Modifier and Type | Field and Description |
---|---|
protected Acknowledgement |
ack |
protected long |
counter |
protected String |
startup |
autoAck, closed, consumer, destination, factory, id, lastConsumed, lastPing, previousIndex, selector, serviceManager, session
Constructor and Description |
---|
AcknowledgedQueueConsumer(ClientSessionFactory factory,
String destination,
String id,
DestinationServiceManager serviceManager,
String selector) |
Modifier and Type | Method and Description |
---|---|
javax.ws.rs.core.Response |
acknowledge(String ackToken,
boolean doAcknowledge,
javax.ws.rs.core.UriInfo uriInfo) |
Acknowledgement |
getAck() |
protected String |
getAckToken() |
javax.ws.rs.core.Response |
poll(long wait,
long index,
javax.ws.rs.core.UriInfo info) |
protected ClientMessage |
receive(long timeoutSecs) |
protected ClientMessage |
receiveFromConsumer(long timeoutSecs) |
protected void |
setAcknowledgeLinks(javax.ws.rs.core.UriInfo uriInfo,
String basePath,
javax.ws.rs.core.Response.ResponseBuilder builder,
String index) |
void |
setAcknowledgementLink(javax.ws.rs.core.Response.ResponseBuilder response,
javax.ws.rs.core.UriInfo info,
String basePath) |
static void |
setAcknowledgeNextLink(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 builder,
String index) |
protected void |
setPollTimeoutLinks(javax.ws.rs.core.UriInfo info,
String basePath,
javax.ws.rs.core.Response.ResponseBuilder builder,
String index) |
void |
shutdown() |
protected void |
unacknowledge() |
checkIndexAndPoll, createSession, getConsumeIndex, getId, getJmsOptions, getLastPingTime, getMessageResponse, getServiceManager, isClosed, ping, pollWithIndex, setConsumeNextLink, setServiceManager, setSessionLink
protected long counter
protected String startup
protected volatile Acknowledgement ack
public AcknowledgedQueueConsumer(ClientSessionFactory factory, String destination, String id, DestinationServiceManager serviceManager, String selector) throws ActiveMQException
ActiveMQException
public Acknowledgement getAck()
@Path(value="acknowledge-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)
poll
in class QueueConsumer
public void shutdown()
shutdown
in class QueueConsumer
@Path(value="acknowledgement/{ackToken}") @POST public javax.ws.rs.core.Response acknowledge(@PathParam(value="ackToken") String ackToken, @FormParam(value="acknowledge") boolean doAcknowledge, @Context javax.ws.rs.core.UriInfo uriInfo)
protected ClientMessage receive(long timeoutSecs) throws Exception
receive
in class QueueConsumer
Exception
protected ClientMessage receiveFromConsumer(long timeoutSecs) throws Exception
receiveFromConsumer
in class QueueConsumer
Exception
protected String getAckToken()
protected void unacknowledge()
protected void setAcknowledgeLinks(javax.ws.rs.core.UriInfo uriInfo, String basePath, javax.ws.rs.core.Response.ResponseBuilder builder, String index)
protected void setMessageResponseLinks(javax.ws.rs.core.UriInfo info, String basePath, javax.ws.rs.core.Response.ResponseBuilder builder, String index)
setMessageResponseLinks
in class QueueConsumer
protected void setPollTimeoutLinks(javax.ws.rs.core.UriInfo info, String basePath, javax.ws.rs.core.Response.ResponseBuilder builder, String index)
setPollTimeoutLinks
in class QueueConsumer
public void setAcknowledgementLink(javax.ws.rs.core.Response.ResponseBuilder response, javax.ws.rs.core.UriInfo info, String basePath)
public static void setAcknowledgeNextLink(LinkStrategy linkStrategy, javax.ws.rs.core.Response.ResponseBuilder response, javax.ws.rs.core.UriInfo info, String basePath, String index)
Copyright © 2016 The Apache Software Foundation. All rights reserved.