org.hornetq.rest.queue

Class AcknowledgedQueueConsumer

java.lang.Object

org.hornetq.rest.queue.QueueConsumer

org.hornetq.rest.queue.AcknowledgedQueueConsumer

Direct Known Subclasses:

AcknowledgedSubscriptionResource

public class AcknowledgedQueueConsumer
extends QueueConsumer

Version:

$Revision: 1 $

Author:

Bill Burke

Field Summary

Fields

Modifier and Type	Field and Description
protected Acknowledgement	ack
protected long	counter
protected String	startup

Fields inherited from class org.hornetq.rest.queue.QueueConsumer

autoAck, closed, consumer, destination, factory, id, lastConsumed, lastPing, previousIndex, selector, serviceManager, session

Constructor Summary

Constructors

Constructor and Description
AcknowledgedQueueConsumer(ClientSessionFactory factory, String destination, String id, DestinationServiceManager serviceManager, String selector)

Method Summary

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

Methods inherited from class org.hornetq.rest.queue.QueueConsumer

checkIndexAndPoll, createSession, getConsumeIndex, getId, getLastPingTime, getMessageResponse, getServiceManager, isClosed, ping, pollWithIndex, setConsumeNextLink, setServiceManager, setSessionLink

Methods inherited from class java.lang.Object

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

Field Detail

counter

protected long counter

startup

protected String startup

ack

protected volatile Acknowledgement ack

Constructor Detail

AcknowledgedQueueConsumer

public AcknowledgedQueueConsumer(ClientSessionFactory factory,
                                 String destination,
                                 String id,
                                 DestinationServiceManager serviceManager,
                                 String selector)
                          throws HornetQException

Throws:

HornetQException

Method Detail

getAck

public Acknowledgement getAck()

poll

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

Overrides:

poll in class QueueConsumer

shutdown

public void shutdown()

Overrides:

shutdown in class QueueConsumer

acknowledge

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

receive

protected ClientMessage receive(long timeoutSecs)
                         throws Exception

Overrides:

receive in class QueueConsumer

Throws:

Exception

receiveFromConsumer

protected ClientMessage receiveFromConsumer(long timeoutSecs)
                                     throws Exception

Overrides:

receiveFromConsumer in class QueueConsumer

Throws:

Exception

getAckToken

protected String getAckToken()

unacknowledge

protected void unacknowledge()

setAcknowledgeLinks

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

setMessageResponseLinks

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

Overrides:

setMessageResponseLinks in class QueueConsumer

setPollTimeoutLinks

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

Overrides:

setPollTimeoutLinks in class QueueConsumer

setAcknowledgementLink

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

setAcknowledgeNextLink

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