Package org.apache.storm.jms

Interface JmsProvider

All Superinterfaces:
Serializable
All Known Implementing Classes:
SpringJmsProvider
public interface JmsProvider extends Serializable
A JmsProvider object encapsulates the ConnectionFactory and Destination JMS objects the JmsSpout needs to manage a topic/queue connection over the course of it's lifecycle.

  • Method Summary

    Modifier and Type
    Method
    Description
    javax.jms.ConnectionFactory
    connectionFactory()
    Provides the JMS ConnectionFactory.
    javax.jms.Destination
    destination()
    Provides the Destination (topic or queue) from which the JmsSpout will receive messages.

  • Method Details

    • connectionFactory

      javax.jms.ConnectionFactory connectionFactory() throws Exception
      Provides the JMS ConnectionFactory.
      Returns:
      the connection factory
      Throws:
      Exception

    • destination

      javax.jms.Destination destination() throws Exception
      Provides the Destination (topic or queue) from which the JmsSpout will receive messages.
      Throws:
      Exception