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

Class ConnectionConfiguration.IbmMqJmsConnectionFactory

java.lang.Object

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

All Implemented Interfaces:

Serializable, BeamGenericJmsConnectionFactory

Enclosing class:

ConnectionConfiguration

public static class ConnectionConfiguration.IbmMqJmsConnectionFactory
extends Object
implements BeamGenericJmsConnectionFactory

A BeamGenericJmsConnectionFactory implementation for IBM MQ.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
IbmMqJmsConnectionFactory()

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

IbmMqJmsConnectionFactory

public IbmMqJmsConnectionFactory()

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