public abstract class AbstractActiveMQClientResource extends org.junit.rules.ExternalResource
Constructor and Description |
---|
AbstractActiveMQClientResource(ActiveMQConnectionFactory connectionFactory) |
AbstractActiveMQClientResource(EmbeddedActiveMQBroker embeddedActiveMQBroker) |
AbstractActiveMQClientResource(String destinationName,
ActiveMQConnectionFactory connectionFactory) |
AbstractActiveMQClientResource(String destinationName,
EmbeddedActiveMQBroker embeddedActiveMQBroker) |
AbstractActiveMQClientResource(String destinationName,
URI brokerURI) |
AbstractActiveMQClientResource(String destinationName,
URI brokerURI,
String userName,
String password) |
AbstractActiveMQClientResource(URI brokerURI) |
AbstractActiveMQClientResource(URI brokerURI,
String userName,
String password) |
Modifier and Type | Method and Description |
---|---|
protected void |
after()
Stop the Client
Invoked by JUnit to tear down the resource
|
protected void |
before()
Start the Client
Invoked by JUnit to setup the resource
|
javax.jms.BytesMessage |
createBytesMessage() |
protected abstract void |
createClient() |
protected ActiveMQDestination |
createDestination(String destinationName) |
javax.jms.MapMessage |
createMapMessage() |
javax.jms.BytesMessage |
createMessage(byte[] body) |
javax.jms.BytesMessage |
createMessage(byte[] body,
Map<String,Object> properties) |
javax.jms.MapMessage |
createMessage(Map<String,Object> body) |
javax.jms.MapMessage |
createMessage(Map<String,Object> body,
Map<String,Object> properties) |
javax.jms.ObjectMessage |
createMessage(Serializable body) |
javax.jms.ObjectMessage |
createMessage(Serializable body,
Map<String,Object> properties) |
javax.jms.TextMessage |
createMessage(String body) |
javax.jms.TextMessage |
createMessage(String body,
Map<String,Object> properties) |
javax.jms.ObjectMessage |
createObjectMessage() |
javax.jms.StreamMessage |
createStreamMessage() |
javax.jms.TextMessage |
createTextMessage() |
String |
getBrokerURL() |
String |
getClientId() |
String |
getDestinationName() |
abstract byte |
getDestinationType() |
static void |
setMessageProperties(javax.jms.Message message,
Map<String,Object> properties) |
void |
start() |
void |
stop() |
apply
public AbstractActiveMQClientResource(ActiveMQConnectionFactory connectionFactory)
public AbstractActiveMQClientResource(URI brokerURI)
public AbstractActiveMQClientResource(EmbeddedActiveMQBroker embeddedActiveMQBroker)
public AbstractActiveMQClientResource(URI brokerURI, String userName, String password)
public AbstractActiveMQClientResource(String destinationName, ActiveMQConnectionFactory connectionFactory)
public AbstractActiveMQClientResource(String destinationName, URI brokerURI)
public AbstractActiveMQClientResource(String destinationName, EmbeddedActiveMQBroker embeddedActiveMQBroker)
public AbstractActiveMQClientResource(String destinationName, URI brokerURI, String userName, String password)
public static void setMessageProperties(javax.jms.Message message, Map<String,Object> properties) throws javax.jms.JMSException
javax.jms.JMSException
public String getClientId()
public String getDestinationName()
public abstract byte getDestinationType()
protected abstract void createClient() throws javax.jms.JMSException
javax.jms.JMSException
protected void before() throws Throwable
before
in class org.junit.rules.ExternalResource
Throwable
protected void after()
after
in class org.junit.rules.ExternalResource
public void start()
public void stop()
public String getBrokerURL()
protected ActiveMQDestination createDestination(String destinationName)
public javax.jms.BytesMessage createBytesMessage() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.TextMessage createTextMessage() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.MapMessage createMapMessage() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.ObjectMessage createObjectMessage() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.StreamMessage createStreamMessage() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.BytesMessage createMessage(byte[] body) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.TextMessage createMessage(String body) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.MapMessage createMessage(Map<String,Object> body) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.ObjectMessage createMessage(Serializable body) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.BytesMessage createMessage(byte[] body, Map<String,Object> properties) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.TextMessage createMessage(String body, Map<String,Object> properties) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.MapMessage createMessage(Map<String,Object> body, Map<String,Object> properties) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.ObjectMessage createMessage(Serializable body, Map<String,Object> properties) throws javax.jms.JMSException
javax.jms.JMSException
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.