org.hornetq.rest.topic
Class PushSubscription

java.lang.Object
  org.hornetq.rest.queue.push.PushConsumer
      org.hornetq.rest.topic.PushSubscription

All Implemented Interfaces:

org.hornetq.api.core.client.MessageHandler

public class PushSubscription
extends PushConsumer

Version:

$Revision: 1 $

Author:

Bill Burke

Field Summary

Fields inherited from class org.hornetq.rest.queue.push.PushConsumer

consumer, destination, factory, id, registration, session, store, strategy

Constructor Summary

PushSubscription(org.hornetq.api.core.client.ClientSessionFactory factory, java.lang.String destination, java.lang.String id, PushRegistration registration, PushStore store)

Method Summary

protected void	deleteSubscriberQueue()
void	disableFromFailure()

Methods inherited from class org.hornetq.rest.queue.push.PushConsumer

getDestination, getRegistration, onMessage, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

PushSubscription

public PushSubscription(org.hornetq.api.core.client.ClientSessionFactory factory,
                        java.lang.String destination,
                        java.lang.String id,
                        PushRegistration registration,
                        PushStore store)

Method Detail

disableFromFailure

public void disableFromFailure()

Overrides:

disableFromFailure in class PushConsumer

deleteSubscriberQueue

protected void deleteSubscriberQueue()