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

Class PushConsumer

java.lang.Object

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

Direct Known Subclasses:

PushSubscription

public class PushConsumer
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected List<org.apache.activemq.artemis.api.core.client.ClientConsumer>	consumers
protected String	destination
protected org.apache.activemq.artemis.api.core.client.ClientSessionFactory	factory
protected String	id
protected PushRegistration	registration
protected List<org.apache.activemq.artemis.api.core.client.ClientSession>	sessions
protected PushStore	store
protected PushStrategy	strategy

Constructor Summary

Constructors

Constructor and Description
PushConsumer(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
void	disableFromFailure()
String	getDestination()
PushRegistration	getRegistration()
PushStrategy	getStrategy()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

registration

protected PushRegistration registration

factory

protected org.apache.activemq.artemis.api.core.client.ClientSessionFactory factory

sessions

protected List<org.apache.activemq.artemis.api.core.client.ClientSession> sessions

consumers

protected List<org.apache.activemq.artemis.api.core.client.ClientConsumer> consumers

destination

protected String destination

id

protected String id

strategy

protected PushStrategy strategy

store

protected PushStore store

Constructor Detail

PushConsumer

public PushConsumer(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

getStrategy

public PushStrategy getStrategy()

getRegistration

public PushRegistration getRegistration()

getDestination

public String getDestination()

start

public void start()
           throws Exception

Throws:

Exception

stop

public void stop()

disableFromFailure

public void disableFromFailure()