@Experimental(value=SOURCE_SINK)

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

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

See: Description

Interface Summary

Interface	Description
AutoScaler	Enables users to specify their own `JMS` backlog reporters enabling JmsIO to report UnboundedSource.UnboundedReader#getTotalBacklogBytes().
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	A PTransform to write to a JMS queue.
JmsRecord	JmsRecord contains message payload of the record as well as metadata (JMS headers and properties).

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

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