org.apache.activemq.junit

Class ActiveMQDynamicQueueSenderResource

java.lang.Object

org.junit.rules.ExternalResource

org.apache.activemq.junit.AbstractActiveMQClientResource

org.apache.activemq.junit.AbstractActiveMQProducerResource

org.apache.activemq.junit.ActiveMQDynamicQueueSenderResource

All Implemented Interfaces:

org.junit.rules.TestRule

public class ActiveMQDynamicQueueSenderResource
extends AbstractActiveMQProducerResource

Constructor Summary

Constructors

Constructor and Description
ActiveMQDynamicQueueSenderResource(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
ActiveMQDynamicQueueSenderResource(EmbeddedActiveMQBroker embeddedActiveMQBroker)
ActiveMQDynamicQueueSenderResource(String defaultDestinationName, org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
ActiveMQDynamicQueueSenderResource(String destinationName, EmbeddedActiveMQBroker embeddedActiveMQBroker)
ActiveMQDynamicQueueSenderResource(String defaultDestinationName, URI brokerURI)
ActiveMQDynamicQueueSenderResource(String defaultDestinationName, URI brokerURI, String userName, String password)
ActiveMQDynamicQueueSenderResource(URI brokerURI)
ActiveMQDynamicQueueSenderResource(URI brokerURI, String userName, String password)

Method Summary

Modifier and Type	Method and Description
protected void	createClient()
byte	getDestinationType()
void	sendMessage(javax.jms.Message message)
javax.jms.BytesMessage	sendMessage(String destinationName, byte[] body)
javax.jms.MapMessage	sendMessage(String destinationName, Map<String,Object> body)
void	sendMessage(String destinationName, javax.jms.Message message)
javax.jms.ObjectMessage	sendMessage(String destinationName, Serializable body)
javax.jms.TextMessage	sendMessage(String destinationName, String body)
javax.jms.BytesMessage	sendMessageWithProperties(String destinationName, byte[] body, Map<String,Object> properties)
javax.jms.MapMessage	sendMessageWithProperties(String destinationName, Map<String,Object> body, Map<String,Object> properties)
javax.jms.ObjectMessage	sendMessageWithProperties(String destinationName, Serializable body, Map<String,Object> properties)
javax.jms.TextMessage	sendMessageWithProperties(String destinationName, String body, Map<String,Object> properties)

Methods inherited from class org.apache.activemq.junit.AbstractActiveMQProducerResource

getDestinationName, sendMessage, sendMessage, sendMessage, sendMessage, sendMessageWithProperties, sendMessageWithProperties, sendMessageWithProperties, sendMessageWithProperties

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, getClientId, 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

ActiveMQDynamicQueueSenderResource

public ActiveMQDynamicQueueSenderResource(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)

ActiveMQDynamicQueueSenderResource

public ActiveMQDynamicQueueSenderResource(URI brokerURI)

ActiveMQDynamicQueueSenderResource

public ActiveMQDynamicQueueSenderResource(EmbeddedActiveMQBroker embeddedActiveMQBroker)

ActiveMQDynamicQueueSenderResource

public ActiveMQDynamicQueueSenderResource(URI brokerURI,
                                          String userName,
                                          String password)

ActiveMQDynamicQueueSenderResource

public ActiveMQDynamicQueueSenderResource(String defaultDestinationName,
                                          org.apache.activemq.ActiveMQConnectionFactory connectionFactory)

ActiveMQDynamicQueueSenderResource

public ActiveMQDynamicQueueSenderResource(String defaultDestinationName,
                                          URI brokerURI)

ActiveMQDynamicQueueSenderResource

public ActiveMQDynamicQueueSenderResource(String destinationName,
                                          EmbeddedActiveMQBroker embeddedActiveMQBroker)

ActiveMQDynamicQueueSenderResource

public ActiveMQDynamicQueueSenderResource(String defaultDestinationName,
                                          URI brokerURI,
                                          String userName,
                                          String password)

Method Detail

createClient

protected void createClient()
                     throws javax.jms.JMSException

Specified by:

createClient in class AbstractActiveMQClientResource

Throws:

javax.jms.JMSException

getDestinationType

public byte getDestinationType()

Specified by:

getDestinationType in class AbstractActiveMQClientResource

sendMessage

public void sendMessage(javax.jms.Message message)
                 throws javax.jms.JMSException

Overrides:

sendMessage in class AbstractActiveMQProducerResource

Throws:

javax.jms.JMSException

sendMessage

public void sendMessage(String destinationName,
                        javax.jms.Message message)
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

sendMessage

public javax.jms.BytesMessage sendMessage(String destinationName,
                                          byte[] body)
                                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

sendMessage

public javax.jms.TextMessage sendMessage(String destinationName,
                                         String body)
                                  throws javax.jms.JMSException

Throws:

javax.jms.JMSException

sendMessage

public javax.jms.MapMessage sendMessage(String destinationName,
                                        Map<String,Object> body)
                                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

sendMessage

public javax.jms.ObjectMessage sendMessage(String destinationName,
                                           Serializable body)
                                    throws javax.jms.JMSException

Throws:

javax.jms.JMSException

sendMessageWithProperties

public javax.jms.BytesMessage sendMessageWithProperties(String destinationName,
                                                        byte[] body,
                                                        Map<String,Object> properties)
                                                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

sendMessageWithProperties

public javax.jms.TextMessage sendMessageWithProperties(String destinationName,
                                                       String body,
                                                       Map<String,Object> properties)
                                                throws javax.jms.JMSException

Throws:

javax.jms.JMSException

sendMessageWithProperties

public javax.jms.MapMessage sendMessageWithProperties(String destinationName,
                                                      Map<String,Object> body,
                                                      Map<String,Object> properties)
                                               throws javax.jms.JMSException

Throws:

javax.jms.JMSException

sendMessageWithProperties

public javax.jms.ObjectMessage sendMessageWithProperties(String destinationName,
                                                         Serializable body,
                                                         Map<String,Object> properties)
                                                  throws javax.jms.JMSException

Throws:

javax.jms.JMSException