Package org.apache.beam.sdk.io.solace.broker

Class SolaceMessageReceiver

java.lang.Object

org.apache.beam.sdk.io.solace.broker.SolaceMessageReceiver

All Implemented Interfaces:

MessageReceiver

public class SolaceMessageReceiver
extends Object
implements MessageReceiver

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_ADVANCE_TIMEOUT_IN_MILLIS

Constructor Summary

Constructors

Constructor	Description
SolaceMessageReceiver(FlowReceiver flowReceiver)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the message receiver.
BytesXMLMessage	receive()	Receives a message from the broker.
void	start()	Starts the message receiver.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.beam.sdk.io.solace.broker.MessageReceiver

isEOF

Field Details

DEFAULT_ADVANCE_TIMEOUT_IN_MILLIS

public static final int DEFAULT_ADVANCE_TIMEOUT_IN_MILLIS

See Also:

• Constant Field Values

Constructor Details

SolaceMessageReceiver

public SolaceMessageReceiver(FlowReceiver flowReceiver)

Method Details

start

public void start()

Description copied from interface: MessageReceiver

Starts the message receiver.

This method is called in the UnboundedSource.UnboundedReader.start() method.

Specified by:

start in interface MessageReceiver

receive

public BytesXMLMessage receive()
                        throws IOException

Description copied from interface: MessageReceiver

Receives a message from the broker.

This method will block until a message is received.

Specified by:

receive in interface MessageReceiver

Throws:

IOException

close

public void close()

Description copied from interface: MessageReceiver

Closes the message receiver.

Specified by:

close in interface MessageReceiver