public class AcknowledgedSubscriptionResource extends AcknowledgedQueueConsumer implements Subscription
ack, counter, startup
autoAck, closed, consumer, destination, factory, id, lastConsumed, lastPing, previousIndex, selector, serviceManager, session
Constructor and Description |
---|
AcknowledgedSubscriptionResource(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) |
acknowledge, getAck, getAckToken, poll, receive, receiveFromConsumer, setAcknowledgeLinks, setAcknowledgementLink, setAcknowledgeNextLink, setMessageResponseLinks, setPollTimeoutLinks, shutdown, unacknowledge
checkIndexAndPoll, createSession, getConsumeIndex, getId, getJmsOptions, getLastPingTime, getMessageResponse, getServiceManager, isClosed, ping, pollWithIndex, setConsumeNextLink, setServiceManager, setSessionLink
public AcknowledgedSubscriptionResource(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.