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

      All Methods Instance Methods Abstract Methods 
      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 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 object.
        Throws:
        javax.jms.JMSException