Serialized Form

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

Class org.apache.beam.sdk.io.jms.DefaultAutoscaler extends java.lang.Object implements Serializable

Class org.apache.beam.sdk.io.jms.JmsIO.Read extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<T>> implements Serializable

Class org.apache.beam.sdk.io.jms.JmsIO.Write extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<EventT>,WriteJmsResult<EventT>> implements Serializable

Class org.apache.beam.sdk.io.jms.JmsIOException extends java.lang.RuntimeException implements Serializable

Class org.apache.beam.sdk.io.jms.JmsRecord extends java.lang.Object implements Serializable

Serialized Fields

jmsCorrelationID

java.lang.String jmsCorrelationID

jmsDeliveryMode

int jmsDeliveryMode

jmsDestination

javax.jms.Destination jmsDestination

jmsExpiration

long jmsExpiration

jmsMessageID

@Nullable java.lang.String jmsMessageID

jmsPriority

int jmsPriority

jmsRedelivered

boolean jmsRedelivered

jmsReplyTo

@Nullable javax.jms.Destination jmsReplyTo

jmsTimestamp

long jmsTimestamp

jmsType

java.lang.String jmsType

properties

java.util.Map<java.lang.String,java.lang.Object> properties

text

java.lang.String text

Class org.apache.beam.sdk.io.jms.RetryConfiguration extends java.lang.Object implements Serializable

Class org.apache.beam.sdk.io.jms.TextMessageMapper extends java.lang.Object implements Serializable