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

Class JmsReadSchemaTransformProvider.ReadConfiguration

java.lang.Object
org.apache.beam.sdk.io.jms.JmsReadSchemaTransformProvider.ReadConfiguration
All Implemented Interfaces:
Serializable
Enclosing class:
JmsReadSchemaTransformProvider
@DefaultSchema(AutoValueSchema.class) public abstract static class JmsReadSchemaTransformProvider.ReadConfiguration extends Object implements Serializable
See Also:

  • Constructor Details

    • ReadConfiguration

      public ReadConfiguration()

  • Method Details

    • builder

      public static JmsReadSchemaTransformProvider.ReadConfiguration.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 read from. Exclusively one of queue or topic must be specified.") @Nullable public abstract String getQueue()

    • getTopic

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

    • getMaxNumRecords

      @SchemaFieldDescription("The max number of records to receive. Setting this will result in a bounded PCollection.") @Nullable public abstract Long getMaxNumRecords()

    • getMaxReadTimeSeconds

      @SchemaFieldDescription("The maximum time for this source to read messages. Setting this will result in a bounded PCollection.") @Nullable public abstract Long getMaxReadTimeSeconds()

    • getCloseTimeoutSeconds

      @SchemaFieldDescription("Close timeout for the JMS connection in seconds.") @Nullable public abstract Long getCloseTimeoutSeconds()

    • getAcknowledgeMode

      @SchemaFieldDescription("The JMS acknowledge mode: CLIENT_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE_UNSAFE, or INDIVIDUAL_ACKNOWLEDGE.") @Nullable public abstract String getAcknowledgeMode()

    • getIndividualAcknowledgeModeCode

      @SchemaFieldDescription("The proprietary integer code for individual message acknowledgment when using INDIVIDUAL_ACKNOWLEDGE.") @Nullable public abstract Integer getIndividualAcknowledgeModeCode()