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 Details

    • withConnectionFactory

      T withConnectionFactory(javax.jms.ConnectionFactory connectionFactory)

    • withConnectionFactoryProviderFn

      T withConnectionFactoryProviderFn(SerializableFunction<Void,? extends javax.jms.ConnectionFactory> connectionFactoryProviderFn)