org.apache.activemq.artemis.rest.topic

Class PushSubscription

java.lang.Object

org.apache.activemq.artemis.rest.queue.push.PushConsumer

org.apache.activemq.artemis.rest.topic.PushSubscription

public class PushSubscription
extends PushConsumer

Field Summary

Fields inherited from class org.apache.activemq.artemis.rest.queue.push.PushConsumer

consumers, destination, factory, id, registration, sessions, store, strategy

Constructor Summary

Constructors

Constructor and Description
PushSubscription(org.apache.activemq.artemis.api.core.client.ClientSessionFactory factory, String destination, String id, PushRegistration registration, PushStore store, org.apache.activemq.artemis.jms.client.ConnectionFactoryOptions jmsOptions)

Method Summary

Modifier and Type	Method and Description
protected void	deleteSubscriberQueue()
void	disableFromFailure()

Methods inherited from class org.apache.activemq.artemis.rest.queue.push.PushConsumer

getDestination, getRegistration, getStrategy, 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.apache.activemq.artemis.api.core.client.ClientSessionFactory factory,
                        String destination,
                        String id,
                        PushRegistration registration,
                        PushStore store,
                        org.apache.activemq.artemis.jms.client.ConnectionFactoryOptions jmsOptions)

Method Detail

disableFromFailure

public void disableFromFailure()

Overrides:

disableFromFailure in class PushConsumer

deleteSubscriberQueue

protected void deleteSubscriberQueue()