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

Class ConnectionConfiguration

java.lang.Object

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

All Implemented Interfaces:

Serializable

@DefaultSchema(AutoValueSchema.class)
public abstract class ConnectionConfiguration
extends Object
implements Serializable

A POJO describing a JMS connection, used by SchemaTransformProvider.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConnectionConfiguration.Builder
static class	ConnectionConfiguration.IbmMqJmsConnectionFactory	A BeamGenericJmsConnectionFactory implementation for IBM MQ.
static class	ConnectionConfiguration.StandardJmsConnectionFactory	A BeamGenericJmsConnectionFactory implementation for standard JMS connection factories.

Constructor Summary

Constructors

Constructor	Description
ConnectionConfiguration()

Method Summary

Modifier and Type	Method	Description
static ConnectionConfiguration.Builder	builder()
static ConnectionConfiguration	create(String serverUri)
static ConnectionConfiguration	create(String serverUri, @Nullable String connectionFactoryClassName)
javax.jms.ConnectionFactory	createConnectionFactory()
abstract @Nullable String	getConnectionFactoryClassName()
abstract @Nullable String	getPassword()
abstract String	getServerUri()
abstract @Nullable String	getUsername()
ConnectionConfiguration	withConnectionFactoryClassName(String connectionFactoryClassName)
ConnectionConfiguration	withPassword(String password)
ConnectionConfiguration	withUsername(String username)

Methods inherited from class java.lang.Object

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

Constructor Details

ConnectionConfiguration

public ConnectionConfiguration()

Method Details

builder

public static ConnectionConfiguration.Builder builder()

create

public static ConnectionConfiguration create(String serverUri,
 @Nullable String connectionFactoryClassName)

create

public static ConnectionConfiguration create(String serverUri)

getServerUri

@SchemaFieldDescription("The JMS broker URI.")
public abstract String getServerUri()

getConnectionFactoryClassName

@SchemaFieldDescription("The JMS ConnectionFactory class name.")
public abstract @Nullable String getConnectionFactoryClassName()

getUsername

@SchemaFieldDescription("The username to connect to the JMS broker.")
public abstract @Nullable String getUsername()

getPassword

@SchemaFieldDescription("The password to connect to the JMS broker.")
public abstract @Nullable String getPassword()

withUsername

public ConnectionConfiguration withUsername(String username)

withPassword

public ConnectionConfiguration withPassword(String password)

withConnectionFactoryClassName

public ConnectionConfiguration withConnectionFactoryClassName(String connectionFactoryClassName)

createConnectionFactory

public javax.jms.ConnectionFactory createConnectionFactory()