public interface JmsMessageProducer extends Serializable
JmsMessageProducer implementations are responsible for translating a org.apache.storm.tuple.Values instance into a javax.jms.Message object.
| Modifier and Type | Method and Description |
|---|---|
javax.jms.Message |
toMessage(javax.jms.Session session,
ITuple input)
Translate a
org.apache.storm.tuple.Tuple object to a javax.jms.Message object. |
javax.jms.Message toMessage(javax.jms.Session session,
ITuple input)
throws javax.jms.JMSException
Translate a org.apache.storm.tuple.Tuple object to a javax.jms.Message object.
javax.jms.JMSExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.