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

Class JmsWriteSchemaTransformProvider.WriteConfiguration

java.lang.Object

org.apache.beam.sdk.io.jms.JmsWriteSchemaTransformProvider.WriteConfiguration

All Implemented Interfaces:

Serializable

Enclosing class:

JmsWriteSchemaTransformProvider

@DefaultSchema(AutoValueSchema.class)
public abstract static class JmsWriteSchemaTransformProvider.WriteConfiguration
extends Object
implements Serializable

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JmsWriteSchemaTransformProvider.WriteConfiguration.Builder

Constructor Summary

Constructors

Constructor	Description
WriteConfiguration()

Method Summary

Modifier and Type	Method	Description
static JmsWriteSchemaTransformProvider.WriteConfiguration.Builder	builder()
abstract ConnectionConfiguration	getConnectionConfiguration()
abstract String	getQueue()
abstract String	getTopic()

Methods inherited from class java.lang.Object

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

Constructor Details

WriteConfiguration

public WriteConfiguration()

Method Details

builder

public static JmsWriteSchemaTransformProvider.WriteConfiguration.Builder builder()

getConnectionConfiguration

@SchemaFieldDescription("Configuration options to set up the JMS connection.\nNote: if connection factory class name is set, spin up a persistent expansion service with the provider client JAR on the classpath:\njava -cp <expansion-service-jar>:<provider-client-jar>\norg.apache.beam.sdk.expansion.service.ExpansionService <port>\nand pass expansion_service=\'localhost:<port>\' to the transform. Currently, only ActiveMQ (org.apache.activemq.ActiveMQConnectionFactory) is embedded into the expansion service")
public abstract ConnectionConfiguration getConnectionConfiguration()

getQueue

@SchemaFieldDescription("The JMS queue to write to. Exclusively one of queue or topic must be specified.")
@Nullable
public abstract String getQueue()

getTopic

@SchemaFieldDescription("The JMS topic to write to. Exclusively one of queue or topic must be specified.")
@Nullable
public abstract String getTopic()