Package org.apache.activemq.junit
Class ActiveMQTopicDurableSubscriberResource
- java.lang.Object
-
- org.junit.rules.ExternalResource
-
- org.apache.activemq.junit.AbstractActiveMQClientResource
-
- org.apache.activemq.junit.AbstractActiveMQConsumerResource
-
- org.apache.activemq.junit.ActiveMQTopicDurableSubscriberResource
-
- All Implemented Interfaces:
org.junit.rules.TestRule
public class ActiveMQTopicDurableSubscriberResource extends AbstractActiveMQConsumerResource
-
-
Constructor Summary
Constructors Constructor Description ActiveMQTopicDurableSubscriberResource(String destinationName, URI brokerURI)
ActiveMQTopicDurableSubscriberResource(String destinationName, URI brokerURI, String userName, String password)
ActiveMQTopicDurableSubscriberResource(String destinationName, ActiveMQConnectionFactory connectionFactory)
ActiveMQTopicDurableSubscriberResource(String destinationName, EmbeddedActiveMQBroker embeddedActiveMQBroker)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
createClient()
String
getClientId()
byte
getDestinationType()
String
getSubscriberName()
void
setClientId(String clientId)
void
setSubscriberName(String subscriberName)
-
Methods inherited from class org.apache.activemq.junit.AbstractActiveMQConsumerResource
getDefaultReceiveTimout, receiveBytesMessage, receiveBytesMessage, receiveMapMessage, receiveMapMessage, receiveMessage, receiveMessage, receiveObjectMessage, receiveObjectMessage, receiveTextMessage, receiveTextMessage, setDefaultReceiveTimout
-
Methods inherited from class org.apache.activemq.junit.AbstractActiveMQClientResource
after, before, createBytesMessage, createDestination, createMapMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createObjectMessage, createStreamMessage, createTextMessage, getBrokerURL, getDestinationName, setMessageProperties, start, stop
-
-
-
-
Constructor Detail
-
ActiveMQTopicDurableSubscriberResource
public ActiveMQTopicDurableSubscriberResource(String destinationName, ActiveMQConnectionFactory connectionFactory)
-
ActiveMQTopicDurableSubscriberResource
public ActiveMQTopicDurableSubscriberResource(String destinationName, URI brokerURI)
-
ActiveMQTopicDurableSubscriberResource
public ActiveMQTopicDurableSubscriberResource(String destinationName, EmbeddedActiveMQBroker embeddedActiveMQBroker)
-
-
Method Detail
-
getDestinationType
public byte getDestinationType()
- Specified by:
getDestinationType
in classAbstractActiveMQClientResource
-
createClient
protected void createClient() throws JMSException
- Overrides:
createClient
in classAbstractActiveMQConsumerResource
- Throws:
JMSException
-
getClientId
public String getClientId()
- Overrides:
getClientId
in classAbstractActiveMQClientResource
-
setClientId
public void setClientId(String clientId)
-
getSubscriberName
public String getSubscriberName()
-
setSubscriberName
public void setSubscriberName(String subscriberName)
-
-