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

  • Method Summary

    Modifier and Type
    Method
    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.

  • Method Details

    • 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 object.
      Throws:
      javax.jms.JMSException