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

Interface JmsIO.ConnectionFactoryContainer<T extends JmsIO.ConnectionFactoryContainer<T>>

  • All Known Implementing Classes:
    JmsIO.Read, JmsIO.Write
    Enclosing class:
    JmsIO
    public static interface JmsIO.ConnectionFactoryContainer<T extends JmsIO.ConnectionFactoryContainer<T>>

    • Method Detail

      • withConnectionFactory

        T withConnectionFactory​(javax.jms.ConnectionFactory connectionFactory)

      • withConnectionFactoryProviderFn

        T withConnectionFactoryProviderFn​(org.apache.beam.sdk.transforms.SerializableFunction<java.lang.Void,​? extends javax.jms.ConnectionFactory> connectionFactoryProviderFn)