public class ActiveMQTopicDurableSubscriberResource extends AbstractActiveMQConsumerResource
Constructor and Description |
---|
ActiveMQTopicDurableSubscriberResource(String destinationName,
ActiveMQConnectionFactory connectionFactory) |
ActiveMQTopicDurableSubscriberResource(String destinationName,
EmbeddedActiveMQBroker embeddedActiveMQBroker) |
ActiveMQTopicDurableSubscriberResource(String destinationName,
URI brokerURI) |
ActiveMQTopicDurableSubscriberResource(String destinationName,
URI brokerURI,
String userName,
String password) |
Modifier and Type | Method and Description |
---|---|
protected void |
createClient() |
String |
getClientId() |
byte |
getDestinationType() |
String |
getSubscriberName() |
void |
setClientId(String clientId) |
void |
setSubscriberName(String subscriberName) |
getDefaultReceiveTimout, receiveBytesMessage, receiveBytesMessage, receiveMapMessage, receiveMapMessage, receiveMessage, receiveMessage, receiveObjectMessage, receiveObjectMessage, receiveTextMessage, receiveTextMessage, setDefaultReceiveTimout
after, before, createBytesMessage, createDestination, createMapMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createObjectMessage, createStreamMessage, createTextMessage, getBrokerURL, getDestinationName, setMessageProperties, start, stop
apply
public ActiveMQTopicDurableSubscriberResource(String destinationName, ActiveMQConnectionFactory connectionFactory)
public ActiveMQTopicDurableSubscriberResource(String destinationName, URI brokerURI)
public ActiveMQTopicDurableSubscriberResource(String destinationName, EmbeddedActiveMQBroker embeddedActiveMQBroker)
public ActiveMQTopicDurableSubscriberResource(String destinationName, URI brokerURI, String userName, String password)
public byte getDestinationType()
getDestinationType
in class AbstractActiveMQClientResource
protected void createClient() throws javax.jms.JMSException
createClient
in class AbstractActiveMQConsumerResource
javax.jms.JMSException
public String getClientId()
getClientId
in class AbstractActiveMQClientResource
public void setClientId(String clientId)
public String getSubscriberName()
public void setSubscriberName(String subscriberName)
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.