Class POSendMessage
java.lang.Object
com.swiftmq.tools.pipeline.POObject
com.swiftmq.impl.mqtt.po.POSendMessage
public class POSendMessage
extends com.swiftmq.tools.pipeline.POObject
-
Constructor Summary
ConstructorsConstructorDescriptionPOSendMessage(String topicName, com.swiftmq.jms.MessageImpl jmsMessage, MqttQoS qos, com.swiftmq.swiftlet.queue.QueueTransaction transaction, Subscription subscription) -
Method Summary
Methods inherited from class com.swiftmq.tools.pipeline.POObject
getCallback, getException, getSemaphore, isSuccess, setException, setSuccess
-
Constructor Details
-
POSendMessage
public POSendMessage(String topicName, com.swiftmq.jms.MessageImpl jmsMessage, MqttQoS qos, com.swiftmq.swiftlet.queue.QueueTransaction transaction, Subscription subscription)
-
-
Method Details
-
getTopicName
-
getJmsMessage
public com.swiftmq.jms.MessageImpl getJmsMessage() -
getQos
-
getTransaction
public com.swiftmq.swiftlet.queue.QueueTransaction getTransaction() -
getSubscription
-
accept
public void accept(com.swiftmq.tools.pipeline.POVisitor visitor) - Specified by:
acceptin classcom.swiftmq.tools.pipeline.POObject
-
toString
-