@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
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
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).