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

Class SolaceMessageProducer

java.lang.Object

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

All Implemented Interfaces:

MessageProducer

@Internal
public class SolaceMessageProducer
extends java.lang.Object
implements MessageProducer

Constructor Summary

Constructors

Constructor and Description
SolaceMessageProducer(XMLMessageProducer producer)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the message producer.
boolean	isClosed() Returns true if the message producer is closed, false otherwise.
int	publishBatch(java.util.List<Solace.Record> records, boolean useCorrelationKeyLatency, SerializableFunction<Solace.Record,Destination> destinationFn, DeliveryMode deliveryMode) Publishes a batch of messages to the broker.
void	publishSingleMessage(Solace.Record record, Destination topicOrQueue, boolean useCorrelationKeyLatency, DeliveryMode deliveryMode) Publishes a message to the broker.

Methods inherited from class java.lang.Object

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

Constructor Detail

SolaceMessageProducer

public SolaceMessageProducer(XMLMessageProducer producer)

Method Detail

publishSingleMessage

public void publishSingleMessage(Solace.Record record,
                                 Destination topicOrQueue,
                                 boolean useCorrelationKeyLatency,
                                 DeliveryMode deliveryMode)

Description copied from interface: MessageProducer

Publishes a message to the broker.

Specified by:

publishSingleMessage in interface MessageProducer

publishBatch

public int publishBatch(java.util.List<Solace.Record> records,
                        boolean useCorrelationKeyLatency,
                        SerializableFunction<Solace.Record,Destination> destinationFn,
                        DeliveryMode deliveryMode)

Description copied from interface: MessageProducer

Publishes a batch of messages to the broker.

The size of the batch cannot exceed 50 messages, this is a limitation of the Solace API.

It returns the number of messages written.

Specified by:

publishBatch in interface MessageProducer

isClosed

public boolean isClosed()

Description copied from interface: MessageProducer

Returns true if the message producer is closed, false otherwise.

Specified by:

isClosed in interface MessageProducer

close

public void close()

Description copied from interface: MessageProducer

Closes the message producer.

Specified by:

close in interface MessageProducer