org.apache.activemq.junit

Class AbstractActiveMQProducerResource

java.lang.Object

org.junit.rules.ExternalResource

org.apache.activemq.junit.AbstractActiveMQClientResource

org.apache.activemq.junit.AbstractActiveMQProducerResource

All Implemented Interfaces:

org.junit.rules.TestRule

Direct Known Subclasses:

ActiveMQDynamicQueueSenderResource, ActiveMQDynamicTopicPublisherResource, ActiveMQQueueSenderResource, ActiveMQTopicPublisherResource

public abstract class AbstractActiveMQProducerResource
extends AbstractActiveMQClientResource

Constructor Summary

Constructors

Constructor and Description
AbstractActiveMQProducerResource(ActiveMQConnectionFactory connectionFactory)
AbstractActiveMQProducerResource(EmbeddedActiveMQBroker embeddedActiveMQBroker)
AbstractActiveMQProducerResource(String destinationName, ActiveMQConnectionFactory connectionFactory)
AbstractActiveMQProducerResource(String destinationName, EmbeddedActiveMQBroker embeddedActiveMQBroker)
AbstractActiveMQProducerResource(String destinationName, URI brokerURI)
AbstractActiveMQProducerResource(String destinationName, URI brokerURI, String userName, String password)
AbstractActiveMQProducerResource(URI brokerURI)
AbstractActiveMQProducerResource(URI brokerURI, String userName, String password)

Method Summary

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

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

after, before, createBytesMessage, createClient, createDestination, createMapMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createObjectMessage, createStreamMessage, createTextMessage, getBrokerURL, getClientId, getDestinationType, 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

AbstractActiveMQProducerResource

public AbstractActiveMQProducerResource(ActiveMQConnectionFactory connectionFactory)

AbstractActiveMQProducerResource

public AbstractActiveMQProducerResource(URI brokerURI)

AbstractActiveMQProducerResource

public AbstractActiveMQProducerResource(EmbeddedActiveMQBroker embeddedActiveMQBroker)

AbstractActiveMQProducerResource

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

AbstractActiveMQProducerResource

public AbstractActiveMQProducerResource(String destinationName,
                                        ActiveMQConnectionFactory connectionFactory)

AbstractActiveMQProducerResource

public AbstractActiveMQProducerResource(String destinationName,
                                        URI brokerURI)

AbstractActiveMQProducerResource

public AbstractActiveMQProducerResource(String destinationName,
                                        EmbeddedActiveMQBroker embeddedActiveMQBroker)

AbstractActiveMQProducerResource

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

Method Detail

getDestinationName

public String getDestinationName()

Overrides:

getDestinationName in class AbstractActiveMQClientResource

sendMessage

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

Throws:

javax.jms.JMSException

sendMessage

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

Throws:

javax.jms.JMSException

sendMessage

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

Throws:

javax.jms.JMSException

sendMessage

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

Throws:

javax.jms.JMSException

sendMessage

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

Throws:

javax.jms.JMSException

sendMessageWithProperties

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

Throws:

javax.jms.JMSException

sendMessageWithProperties

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

Throws:

javax.jms.JMSException

sendMessageWithProperties

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

Throws:

javax.jms.JMSException

sendMessageWithProperties

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

Throws:

javax.jms.JMSException