Package org.apache.beam.sdk.io.jms

Interface BeamGenericJmsConnectionFactory

All Superinterfaces:

Serializable

All Known Implementing Classes:

ConnectionConfiguration.IbmMqJmsConnectionFactory, ConnectionConfiguration.StandardJmsConnectionFactory

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface BeamGenericJmsConnectionFactory
extends Serializable

An interface for creating custom JMS ConnectionFactory instances.

Expansion service users connecting to JMS brokers other than the built-in supported ones (ActiveMQ, Qpid, IBM MQ) can implement this interface and specify their implementation class name in ConnectionConfiguration.

The implementation must have a public default constructor.

Method Summary

Modifier and Type	Method	Description
javax.jms.ConnectionFactory	createConnectionFactory(ConnectionConfiguration config)	Creates a ConnectionFactory using the given ConnectionConfiguration.

Method Details

createConnectionFactory

javax.jms.ConnectionFactory createConnectionFactory(ConnectionConfiguration config)
                                             throws Exception

Creates a ConnectionFactory using the given ConnectionConfiguration.

Parameters:

config - the JMS connection configuration

Returns:

configured JMS ConnectionFactory

Throws:

Exception