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

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

Interface Summary

Interface	Description
AutoScaler	Enables users to specify their own `JMS` backlog reporters enabling JmsIO to report UnboundedSource.UnboundedReader.getTotalBacklogBytes().
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.

Class Summary

Class	Description
DefaultAutoscaler	Default implementation of AutoScaler.
JmsIO	An unbounded source for JMS destinations (queues or topics).
JmsIO.Read<T>	A PTransform to read from a JMS destination.
JmsIO.Write<EventT>	A PTransform to write to a JMS queue.
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.

Exception Summary

Exception	Description
JmsIOException