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

Class PublishResultHandler

java.lang.Object

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

All Implemented Interfaces:

JCSMPStreamingPublishCorrelatingEventHandler, JCSMPStreamingPublishEventHandler

public final class PublishResultHandler
extends java.lang.Object
implements JCSMPStreamingPublishCorrelatingEventHandler

This class is required to handle callbacks from Solace, to find out if messages were actually published or there were any kind of error.

This class is also used to calculate the latency of the publication. The correlation key contains the original timestamp of when the message was sent from the pipeline to Solace. The comparison of that value with the clock now, using a monotonic clock, is understood as the latency of the publication

Constructor Summary

Constructors

Constructor and Description
PublishResultHandler(java.util.Queue<Solace.PublishResult> publishResultsQueue)

Method Summary

Modifier and Type	Method and Description
void	handleErrorEx(java.lang.Object key, JCSMPException cause, long timestamp)
void	responseReceivedEx(java.lang.Object key)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.solacesystems.jcsmp.JCSMPStreamingPublishCorrelatingEventHandler

handleError, responseReceived

Constructor Detail

PublishResultHandler

public PublishResultHandler(java.util.Queue<Solace.PublishResult> publishResultsQueue)

Method Detail

handleErrorEx

public void handleErrorEx(java.lang.Object key,
                          JCSMPException cause,
                          long timestamp)

Specified by:

handleErrorEx in interface JCSMPStreamingPublishCorrelatingEventHandler

responseReceivedEx

public void responseReceivedEx(java.lang.Object key)

Specified by:

responseReceivedEx in interface JCSMPStreamingPublishCorrelatingEventHandler