Index (jms 2.74.0 API)

A C D E F G H J M O P R S T W
All Classes All Packages

A

apply(String, Session) - Method in class org.apache.beam.sdk.io.jms.TextMessageMapper
AutoScaler - Interface in org.apache.beam.sdk.io.jms: Enables users to specify their own `JMS` backlog reporters enabling JmsIO to report UnboundedSource.UnboundedReader.getTotalBacklogBytes().

C

create() - Static method in class org.apache.beam.sdk.io.jms.RetryConfiguration
create(int) - Static method in class org.apache.beam.sdk.io.jms.RetryConfiguration
create(int, Duration, Duration) - Static method in class org.apache.beam.sdk.io.jms.RetryConfiguration

D

DefaultAutoscaler - Class in org.apache.beam.sdk.io.jms: Default implementation of AutoScaler.
DefaultAutoscaler() - Constructor for class org.apache.beam.sdk.io.jms.DefaultAutoscaler

E

equals(Object) - Method in class org.apache.beam.sdk.io.jms.JmsRecord
expand() - Method in class org.apache.beam.sdk.io.jms.WriteJmsResult
expand(PBegin) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Read
expand(PCollection<EventT>) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Write

F

finishSpecifyingOutput(String, PInput, PTransform<?, ?>) - Method in class org.apache.beam.sdk.io.jms.WriteJmsResult

G

getFailedMessages() - Method in class org.apache.beam.sdk.io.jms.WriteJmsResult
getJmsCorrelationID() - Method in class org.apache.beam.sdk.io.jms.JmsRecord
getJmsDeliveryMode() - Method in class org.apache.beam.sdk.io.jms.JmsRecord
getJmsDestination() - Method in class org.apache.beam.sdk.io.jms.JmsRecord
getJmsExpiration() - Method in class org.apache.beam.sdk.io.jms.JmsRecord
getJmsMessageID() - Method in class org.apache.beam.sdk.io.jms.JmsRecord
getJmsPriority() - Method in class org.apache.beam.sdk.io.jms.JmsRecord
getJmsRedelivered() - Method in class org.apache.beam.sdk.io.jms.JmsRecord
getJmsReplyTo() - Method in class org.apache.beam.sdk.io.jms.JmsRecord
getJmsTimestamp() - Method in class org.apache.beam.sdk.io.jms.JmsRecord
getJmsType() - Method in class org.apache.beam.sdk.io.jms.JmsRecord
getPayload() - Method in class org.apache.beam.sdk.io.jms.JmsRecord
getPipeline() - Method in class org.apache.beam.sdk.io.jms.WriteJmsResult
getProperties() - Method in class org.apache.beam.sdk.io.jms.JmsRecord
getTotalBacklogBytes() - Method in interface org.apache.beam.sdk.io.jms.AutoScaler: Returns the size of the backlog of unread data in the underlying data source represented by all splits of this source.
getTotalBacklogBytes() - Method in class org.apache.beam.sdk.io.jms.DefaultAutoscaler

H

hashCode() - Method in class org.apache.beam.sdk.io.jms.JmsRecord

J

JmsIO - Class in org.apache.beam.sdk.io.jms: An unbounded source for JMS destinations (queues or topics).
JmsIO.ConnectionFactoryContainer<T extends JmsIO.ConnectionFactoryContainer<T>> - Interface in org.apache.beam.sdk.io.jms
JmsIO.MessageMapper<T> - Interface in org.apache.beam.sdk.io.jms: An interface used by JmsIO.Read for converting each jms Message into an element of the resulting PCollection.
JmsIO.Read<T> - Class in org.apache.beam.sdk.io.jms: A PTransform to read from a JMS destination.
JmsIO.Write<EventT> - Class in org.apache.beam.sdk.io.jms: A PTransform to write to a JMS queue.
JmsIOException - Exception in org.apache.beam.sdk.io.jms
JmsIOException(String) - Constructor for exception org.apache.beam.sdk.io.jms.JmsIOException
JmsIOException(String, Throwable) - Constructor for exception org.apache.beam.sdk.io.jms.JmsIOException
JmsRecord - Class in org.apache.beam.sdk.io.jms: JmsRecord contains message payload of the record as well as metadata (JMS headers and properties).
JmsRecord(String, long, String, Destination, Destination, int, boolean, String, long, int, Map<String, Object>, String) - Constructor for class org.apache.beam.sdk.io.jms.JmsRecord

M

mapMessage(Message) - Method in interface org.apache.beam.sdk.io.jms.JmsIO.MessageMapper

O

org.apache.beam.sdk.io.jms - package org.apache.beam.sdk.io.jms: Transforms for reading and writing from JMS (Java Messaging Service).

P

populateDisplayData(DisplayData.Builder) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Read

R

read() - Static method in class org.apache.beam.sdk.io.jms.JmsIO
Read() - Constructor for class org.apache.beam.sdk.io.jms.JmsIO.Read
readMessage() - Static method in class org.apache.beam.sdk.io.jms.JmsIO
RetryConfiguration - Class in org.apache.beam.sdk.io.jms
RetryConfiguration() - Constructor for class org.apache.beam.sdk.io.jms.RetryConfiguration

S

start() - Method in interface org.apache.beam.sdk.io.jms.AutoScaler: The AutoScaler is started when the JmsIO.UnboundedJmsReader is started.
start() - Method in class org.apache.beam.sdk.io.jms.DefaultAutoscaler
stop() - Method in interface org.apache.beam.sdk.io.jms.AutoScaler: The AutoScaler is stopped when the JmsIO.UnboundedJmsReader is closed.
stop() - Method in class org.apache.beam.sdk.io.jms.DefaultAutoscaler

T

TextMessageMapper - Class in org.apache.beam.sdk.io.jms: The TextMessageMapper takes a String value, a Session and returns a TextMessage.
TextMessageMapper() - Constructor for class org.apache.beam.sdk.io.jms.TextMessageMapper

W

withAutoScaler(AutoScaler) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Read: Sets the AutoScaler to use for reporting backlog during the execution of this source.
withCloseTimeout(Duration) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Read: Sets the amount of time to wait for callbacks from the runner stating that the output has been durably persisted before closing the connection to the JMS broker.
withCoder(Coder<T>) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Read
withConnectionFactory(ConnectionFactory) - Method in interface org.apache.beam.sdk.io.jms.JmsIO.ConnectionFactoryContainer
withConnectionFactory(ConnectionFactory) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Read: Specify the JMS connection factory to connect to the JMS broker.
withConnectionFactory(ConnectionFactory) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Write: Specify the JMS connection factory to connect to the JMS broker.
withConnectionFactoryProviderFn(SerializableFunction<Void, ? extends ConnectionFactory>) - Method in interface org.apache.beam.sdk.io.jms.JmsIO.ConnectionFactoryContainer
withConnectionFactoryProviderFn(SerializableFunction<Void, ? extends ConnectionFactory>) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Read: Specify a JMS connection factory provider function to connect to the JMS broker.
withConnectionFactoryProviderFn(SerializableFunction<Void, ? extends ConnectionFactory>) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Write: Specify a JMS connection factory provider function to connect to the JMS broker.
withMaxNumRecords(long) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Read: Define the max number of records that the source will read.
withMaxReadTime(Duration) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Read: Define the max read time that the source will read.
withMessageMapper(JmsIO.MessageMapper<T>) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Read
withPassword(String) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Read: Define the password to connect to the JMS broker (authenticated).
withPassword(String) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Write: Define the password to connect to the JMS broker (authenticated).
withQueue(String) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Read: Specify the JMS queue destination name where to read messages from.
withQueue(String) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Write: Specify the JMS queue destination name where to send messages to.
withReceiveTimeout(Duration) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Read: If set, block for the Duration of timeout for each poll to new JMS record if the previous poll returns no new record.
withRequiresDeduping() - Method in class org.apache.beam.sdk.io.jms.JmsIO.Read: If set, requires runner deduplication for the messages.
withRetryConfiguration(RetryConfiguration) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Write: Specify the JMS retry configuration.
withTopic(String) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Read: Specify the JMS topic destination name where to receive messages from.
withTopic(String) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Write: Specify the JMS topic destination name where to send messages to.
withTopicNameMapper(SerializableFunction<EventT, String>) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Write: Specify the JMS topic destination name where to send messages to dynamically.
withUsername(String) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Read: Define the username to connect to the JMS broker (authenticated).
withUsername(String) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Write: Define the username to connect to the JMS broker (authenticated).
withValueMapper(SerializableBiFunction<EventT, Session, Message>) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Write: Map the EventT object to a Message.
write() - Static method in class org.apache.beam.sdk.io.jms.JmsIO
Write() - Constructor for class org.apache.beam.sdk.io.jms.JmsIO.Write
WriteJmsResult<EventT> - Class in org.apache.beam.sdk.io.jms: Return type of JmsIO.Write transform.
WriteJmsResult(Pipeline, TupleTag<EventT>, PCollection<EventT>) - Constructor for class org.apache.beam.sdk.io.jms.WriteJmsResult

A C D E F G H J M O P R S T W
All Classes All Packages