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 javax.jms.Message object.

Method Summary

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</code object.

Method Detail

toMessage

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</code object.

Parameters:

session -

input -

Returns:

Throws:

javax.jms.JMSException