org.apache.activemq.artemis.rest.topic

Class SubscriptionResource

java.lang.Object

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

org.apache.activemq.artemis.rest.topic.SubscriptionResource

All Implemented Interfaces:

Subscription

public class SubscriptionResource
extends QueueConsumer
implements Subscription

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	durable
protected long	timeout

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
SubscriptionResource(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.QueueConsumer

checkIndexAndPoll, createSession, getConsumeIndex, getId, getJmsOptions, getLastPingTime, getMessageResponse, getServiceManager, isClosed, ping, poll, pollWithIndex, receive, receiveFromConsumer, setConsumeNextLink, setMessageResponseLinks, setPollTimeoutLinks, setServiceManager, setSessionLink, shutdown

Methods inherited from class java.lang.Object

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

Field Detail

durable

protected boolean durable

timeout

protected long timeout

Constructor Detail

SubscriptionResource

public SubscriptionResource(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