public class ActiveMQTopicPublisherResource extends AbstractActiveMQProducerResource
Constructor and Description |
---|
ActiveMQTopicPublisherResource(String destinationName,
ActiveMQConnectionFactory connectionFactory) |
ActiveMQTopicPublisherResource(String destinationName,
EmbeddedActiveMQBroker embeddedActiveMQBroker) |
ActiveMQTopicPublisherResource(String destinationName,
URI brokerURI) |
ActiveMQTopicPublisherResource(String destinationName,
URI brokerURI,
String userName,
String password) |
Modifier and Type | Method and Description |
---|---|
protected void |
createClient() |
String |
getDestinationName() |
byte |
getDestinationType() |
sendMessage, 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 ActiveMQTopicPublisherResource(String destinationName, ActiveMQConnectionFactory connectionFactory)
public ActiveMQTopicPublisherResource(String destinationName, URI brokerURI)
public ActiveMQTopicPublisherResource(String destinationName, EmbeddedActiveMQBroker embeddedActiveMQBroker)
public ActiveMQTopicPublisherResource(String destinationName, URI brokerURI, String userName, String password)
public String getDestinationName()
getDestinationName
in class AbstractActiveMQProducerResource
public byte getDestinationType()
getDestinationType
in class AbstractActiveMQClientResource
protected void createClient() throws javax.jms.JMSException
createClient
in class AbstractActiveMQClientResource
javax.jms.JMSException
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.