public class SubscriptionResource extends QueueConsumer implements Subscription
Modifier and Type | Field and Description |
---|---|
protected boolean |
durable |
protected long |
timeout |
autoAck, closed, consumer, destination, factory, id, lastConsumed, lastPing, previousIndex, selector, serviceManager, session
Constructor and Description |
---|
SubscriptionResource(ClientSessionFactory factory,
String destination,
String id,
DestinationServiceManager serviceManager,
String selector,
boolean durable,
long timeout) |
Modifier and Type | Method and Description |
---|---|
long |
getTimeout() |
boolean |
isDeleteWhenIdle() |
boolean |
isDurable() |
void |
setDeleteWhenIdle(boolean deleteWhenIdle) |
void |
setDurable(boolean durable) |
void |
setTimeout(long timeout) |
checkIndexAndPoll, createSession, getConsumeIndex, getId, getJmsOptions, getLastPingTime, getMessageResponse, getServiceManager, isClosed, ping, poll, pollWithIndex, receive, receiveFromConsumer, setConsumeNextLink, setMessageResponseLinks, setPollTimeoutLinks, setServiceManager, setSessionLink, shutdown
public SubscriptionResource(ClientSessionFactory factory, String destination, String id, DestinationServiceManager serviceManager, String selector, boolean durable, long timeout) throws ActiveMQException
ActiveMQException
public boolean isDurable()
isDurable
in interface Subscription
public void setDurable(boolean durable)
setDurable
in interface Subscription
public long getTimeout()
getTimeout
in interface Subscription
public void setTimeout(long timeout)
setTimeout
in interface Subscription
public boolean isDeleteWhenIdle()
isDeleteWhenIdle
in interface Subscription
public void setDeleteWhenIdle(boolean deleteWhenIdle)
setDeleteWhenIdle
in interface Subscription
Copyright © 2016 The Apache Software Foundation. All rights reserved.