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 and 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 Detail

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