public class PushConsumer extends Object
Modifier and Type | Field and Description |
---|---|
protected List<ClientConsumer> |
consumers |
protected String |
destination |
protected ClientSessionFactory |
factory |
protected String |
id |
protected PushRegistration |
registration |
protected List<ClientSession> |
sessions |
protected PushStore |
store |
protected PushStrategy |
strategy |
Constructor and Description |
---|
PushConsumer(ClientSessionFactory factory,
String destination,
String id,
PushRegistration registration,
PushStore store,
ConnectionFactoryOptions jmsOptions) |
Modifier and Type | Method and Description |
---|---|
void |
disableFromFailure() |
String |
getDestination() |
PushRegistration |
getRegistration() |
PushStrategy |
getStrategy() |
void |
start() |
void |
stop() |
protected PushRegistration registration
protected ClientSessionFactory factory
protected List<ClientSession> sessions
protected List<ClientConsumer> consumers
protected String destination
protected String id
protected PushStrategy strategy
protected PushStore store
public PushConsumer(ClientSessionFactory factory, String destination, String id, PushRegistration registration, PushStore store, ConnectionFactoryOptions jmsOptions)
public PushStrategy getStrategy()
public PushRegistration getRegistration()
public String getDestination()
public void stop()
public void disableFromFailure()
Copyright © 2016 The Apache Software Foundation. All rights reserved.