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

Class ConnectionConfiguration.StandardJmsConnectionFactory

java.lang.Object

org.apache.beam.sdk.io.jms.ConnectionConfiguration.StandardJmsConnectionFactory

All Implemented Interfaces:

Serializable, BeamGenericJmsConnectionFactory

Enclosing class:

ConnectionConfiguration

public static class ConnectionConfiguration.StandardJmsConnectionFactory
extends Object
implements BeamGenericJmsConnectionFactory

A BeamGenericJmsConnectionFactory implementation for standard JMS connection factories.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
StandardJmsConnectionFactory()

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

StandardJmsConnectionFactory

public StandardJmsConnectionFactory()

Method Details

createConnectionFactory

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

Description copied from interface: BeamGenericJmsConnectionFactory

Creates a ConnectionFactory using the given ConnectionConfiguration.

Specified by:

createConnectionFactory in interface BeamGenericJmsConnectionFactory

Parameters:

config - the JMS connection configuration

Returns:

configured JMS ConnectionFactory

Throws:

Exception