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

package org.apache.beam.sdk.io.jms

Transforms for reading and writing from JMS (Java Messaging Service).

Related Packages

Package	Description
org.apache.beam.sdk.io	Defines transforms for reading and writing common storage formats, including invalid reference org.apache.beam.sdk.io.AvroIO , and TextIO.

Class	Description
AutoScaler	Enables users to specify their own `JMS` backlog reporters enabling JmsIO to report UnboundedSource.UnboundedReader.getTotalBacklogBytes().
DefaultAutoscaler	Default implementation of AutoScaler.
JmsIO	An unbounded source for JMS destinations (queues or topics).
JmsIO.ConnectionFactoryContainer<T extends JmsIO.ConnectionFactoryContainer<T>>
JmsIO.MessageMapper<T>	An interface used by JmsIO.Read for converting each jms Message into an element of the resulting PCollection.
JmsIO.Read<T>	A PTransform to read from a JMS destination.
JmsIO.Write<EventT>	A PTransform to write to a JMS queue.
JmsIOException
JmsRecord	JmsRecord contains message payload of the record as well as metadata (JMS headers and properties).
RetryConfiguration
TextMessageMapper	The TextMessageMapper takes a String value, a Session and returns a TextMessage.
WriteJmsResult<EventT>	Return type of JmsIO.Write transform.