Package org.apache.storm.jms

Interface JmsMessageProducer

All Superinterfaces:

Serializable

public interface JmsMessageProducer
extends Serializable

JmsMessageProducer implementations are responsible for translating a org.apache.storm.tuple.Values instance into a jakarta.jms.Message object.

Method Summary

Modifier and Type	Method	Description
jakarta.jms.Message	toMessage(jakarta.jms.Session session, ITuple input)	Translate a org.apache.storm.tuple.Tuple object to a jakarta.jms.Message object.

Method Details

toMessage

jakarta.jms.Message toMessage(jakarta.jms.Session session,
 ITuple input)
                       throws jakarta.jms.JMSException

Translate a org.apache.storm.tuple.Tuple object to a jakarta.jms.Message object.

Throws:

jakarta.jms.JMSException