org.apache.activemq.artemis.rest.topic

Class AcknowledgedSubscriptionResource

java.lang.Object

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

org.apache.activemq.artemis.rest.queue.AcknowledgedQueueConsumer

org.apache.activemq.artemis.rest.topic.AcknowledgedSubscriptionResource

All Implemented Interfaces:

Subscription

public class AcknowledgedSubscriptionResource
extends AcknowledgedQueueConsumer
implements Subscription

Field Summary

Fields inherited from class org.apache.activemq.artemis.rest.queue.AcknowledgedQueueConsumer

ack, counter, startup

Fields inherited from class org.apache.activemq.artemis.rest.queue.QueueConsumer

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

Constructor Summary

Constructors

Constructor and Description
AcknowledgedSubscriptionResource(ClientSessionFactory factory, String destination, String id, DestinationServiceManager serviceManager, String selector, boolean durable, Long timeout)

Method Summary

Modifier and Type	Method and Description
long	getTimeout()
boolean	isDeleteWhenIdle()
boolean	isDurable()
void	setDeleteWhenIdle(boolean deleteWhenIdle)
void	setDurable(boolean durable)
void	setTimeout(long timeout)

Methods inherited from class org.apache.activemq.artemis.rest.queue.AcknowledgedQueueConsumer

acknowledge, getAck, getAckToken, poll, receive, receiveFromConsumer, setAcknowledgeLinks, setAcknowledgementLink, setAcknowledgeNextLink, setMessageResponseLinks, setPollTimeoutLinks, shutdown, unacknowledge

Methods inherited from class org.apache.activemq.artemis.rest.queue.QueueConsumer

checkIndexAndPoll, createSession, getConsumeIndex, getId, getJmsOptions, 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

Constructor Detail

AcknowledgedSubscriptionResource

public AcknowledgedSubscriptionResource(ClientSessionFactory factory,
                                        String destination,
                                        String id,
                                        DestinationServiceManager serviceManager,
                                        String selector,
                                        boolean durable,
                                        Long timeout)
                                 throws ActiveMQException

Throws:

ActiveMQException

Method Detail

isDurable

public boolean isDurable()

Specified by:

isDurable in interface Subscription

setDurable

public void setDurable(boolean durable)

Specified by:

setDurable in interface Subscription

getTimeout

public long getTimeout()

Specified by:

getTimeout in interface Subscription

setTimeout

public void setTimeout(long timeout)

Specified by:

setTimeout in interface Subscription

isDeleteWhenIdle

public boolean isDeleteWhenIdle()

Specified by:

isDeleteWhenIdle in interface Subscription

setDeleteWhenIdle

public void setDeleteWhenIdle(boolean deleteWhenIdle)

Specified by:

setDeleteWhenIdle in interface Subscription