public class ActiveMQDynamicTopicPublisherResource extends AbstractActiveMQProducerResource
Constructor and Description |
---|
ActiveMQDynamicTopicPublisherResource(ActiveMQConnectionFactory connectionFactory) |
ActiveMQDynamicTopicPublisherResource(EmbeddedActiveMQBroker embeddedActiveMQBroker) |
ActiveMQDynamicTopicPublisherResource(String defaultDestinationName,
ActiveMQConnectionFactory connectionFactory) |
ActiveMQDynamicTopicPublisherResource(String destinationName,
EmbeddedActiveMQBroker embeddedActiveMQBroker) |
ActiveMQDynamicTopicPublisherResource(String defaultDestinationName,
URI brokerURI) |
ActiveMQDynamicTopicPublisherResource(String defaultDestinationName,
URI brokerURI,
String userName,
String password) |
ActiveMQDynamicTopicPublisherResource(URI brokerURI) |
ActiveMQDynamicTopicPublisherResource(URI brokerURI,
String userName,
String password) |
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) |
getDestinationName, sendMessage, sendMessage, sendMessage, sendMessage, sendMessageWithProperties, sendMessageWithProperties, sendMessageWithProperties, sendMessageWithProperties
after, before, createBytesMessage, createDestination, createMapMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createObjectMessage, createStreamMessage, createTextMessage, getBrokerURL, getClientId, setMessageProperties, start, stop
apply
public ActiveMQDynamicTopicPublisherResource(ActiveMQConnectionFactory connectionFactory)
public ActiveMQDynamicTopicPublisherResource(URI brokerURI)
public ActiveMQDynamicTopicPublisherResource(EmbeddedActiveMQBroker embeddedActiveMQBroker)
public ActiveMQDynamicTopicPublisherResource(URI brokerURI, String userName, String password)
public ActiveMQDynamicTopicPublisherResource(String defaultDestinationName, ActiveMQConnectionFactory connectionFactory)
public ActiveMQDynamicTopicPublisherResource(String defaultDestinationName, URI brokerURI)
public ActiveMQDynamicTopicPublisherResource(String destinationName, EmbeddedActiveMQBroker embeddedActiveMQBroker)
public ActiveMQDynamicTopicPublisherResource(String defaultDestinationName, URI brokerURI, String userName, String password)
protected void createClient() throws javax.jms.JMSException
createClient
in class AbstractActiveMQClientResource
javax.jms.JMSException
public byte getDestinationType()
getDestinationType
in class AbstractActiveMQClientResource
public void sendMessage(javax.jms.Message message) throws javax.jms.JMSException
sendMessage
in class AbstractActiveMQProducerResource
javax.jms.JMSException
public void sendMessage(String destinationName, javax.jms.Message message) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.BytesMessage sendMessage(String destinationName, byte[] body) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.TextMessage sendMessage(String destinationName, String body) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.MapMessage sendMessage(String destinationName, Map<String,Object> body) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.ObjectMessage sendMessage(String destinationName, Serializable body) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.BytesMessage sendMessageWithProperties(String destinationName, byte[] body, Map<String,Object> properties) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.TextMessage sendMessageWithProperties(String destinationName, String body, Map<String,Object> properties) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.MapMessage sendMessageWithProperties(String destinationName, Map<String,Object> body, Map<String,Object> properties) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.ObjectMessage sendMessageWithProperties(String destinationName, Serializable body, Map<String,Object> properties) throws javax.jms.JMSException
javax.jms.JMSException
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.