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 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)

Method Summary

Modifier and Type	Method and 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

Methods inherited from class org.junit.rules.ExternalResource

apply

Methods inherited from class java.lang.Object

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

Constructor Detail

ActiveMQTopicDurableSubscriberResource

public ActiveMQTopicDurableSubscriberResource(String destinationName,
                                              ActiveMQConnectionFactory connectionFactory)

ActiveMQTopicDurableSubscriberResource

public ActiveMQTopicDurableSubscriberResource(String destinationName,
                                              URI brokerURI)

ActiveMQTopicDurableSubscriberResource

public ActiveMQTopicDurableSubscriberResource(String destinationName,
                                              EmbeddedActiveMQBroker embeddedActiveMQBroker)

ActiveMQTopicDurableSubscriberResource

public ActiveMQTopicDurableSubscriberResource(String destinationName,
                                              URI brokerURI,
                                              String userName,
                                              String password)

Method Detail

getDestinationType

public byte getDestinationType()

Specified by:

getDestinationType in class AbstractActiveMQClientResource

createClient

protected void createClient()
                     throws javax.jms.JMSException

Overrides:

createClient in class AbstractActiveMQConsumerResource

Throws:

javax.jms.JMSException

getClientId

public String getClientId()

Overrides:

getClientId in class AbstractActiveMQClientResource

setClientId

public void setClientId(String clientId)

getSubscriberName

public String getSubscriberName()

setSubscriberName

public void setSubscriberName(String subscriberName)