org.hornetq.rest.topic
Class AcknowledgedSubscriptionResource

java.lang.Object
  org.hornetq.rest.queue.QueueConsumer
      org.hornetq.rest.queue.AcknowledgedQueueConsumer
          org.hornetq.rest.topic.AcknowledgedSubscriptionResource

All Implemented Interfaces:

Subscription

public class AcknowledgedSubscriptionResource
extends AcknowledgedQueueConsumer
implements Subscription

Version:

$Revision: 1 $

Author:

Bill Burke

Field Summary

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

ack, counter, startup

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

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

Constructor Summary

AcknowledgedSubscriptionResource(org.hornetq.api.core.client.ClientSessionFactory factory, java.lang.String destination, java.lang.String id, DestinationServiceManager serviceManager, java.lang.String selector, boolean durable, java.lang.Long timeout)

Method Summary

long	getTimeout()
boolean	isDeleteWhenIdle()
boolean	isDurable()
void	setDeleteWhenIdle(boolean deleteWhenIdle)
void	setDurable(boolean durable)
void	setTimeout(long timeout)

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

acknowledge, getAck, getAckToken, poll, receive, receiveFromConsumer, setAcknowledgeLinks, setAcknowledgementLink, setAcknowledgeNextLink, setMessageResponseLinks, setPollTimeoutLinks, shutdown, 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

Constructor Detail

AcknowledgedSubscriptionResource

public AcknowledgedSubscriptionResource(org.hornetq.api.core.client.ClientSessionFactory factory,
                                        java.lang.String destination,
                                        java.lang.String id,
                                        DestinationServiceManager serviceManager,
                                        java.lang.String selector,
                                        boolean durable,
                                        java.lang.Long timeout)
                                 throws org.hornetq.api.core.HornetQException

Throws:

org.hornetq.api.core.HornetQException

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