com.hazelcast.enterprise.wan

Class WanThrottlingAcknowledger

java.lang.Object

com.hazelcast.enterprise.wan.WanThrottlingAcknowledger

All Implemented Interfaces:

WanAcknowledger

public class WanThrottlingAcknowledger
extends Object
implements WanAcknowledger

WanAcknowledger implementation that is meant to be used for throttling the WAN event stream on the consumer side. Throttling is done by testing the health condition of the given WAN consumer member to prevent it getting overloaded by the WAN publisher. The health condition check is performed by comparing the number of the pending invocations on the consumer node against a configurable threshold. If the threshold is exceeded the acknowledgement is delayed and the condition will be evaluated later again. Since the publisher waits with sending the next batch to the same WAN target endpoint until the previously sent one is acknowledged, this implementation slows down the publisher to the desired level.

Constructor Summary

Constructors

Constructor and Description
WanThrottlingAcknowledger(com.hazelcast.instance.Node node, int invocationThreshold)

Method Summary

Modifier and Type	Method and Description
void	acknowledgeFailure(com.hazelcast.spi.Operation operation) Acknowledges the WAN operation as failed operation.
void	acknowledgeSuccess(com.hazelcast.spi.Operation operation) Acknowledges the WAN operation as successful operation.

Methods inherited from class java.lang.Object

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

Constructor Detail

WanThrottlingAcknowledger

public WanThrottlingAcknowledger(com.hazelcast.instance.Node node,
                                 int invocationThreshold)

Method Detail

acknowledgeSuccess

public void acknowledgeSuccess(com.hazelcast.spi.Operation operation)

Description copied from interface: WanAcknowledger

Acknowledges the WAN operation as successful operation.

Specified by:

acknowledgeSuccess in interface WanAcknowledger

Parameters:

operation - the WAN operation to acknowledge

acknowledgeFailure

public void acknowledgeFailure(com.hazelcast.spi.Operation operation)

Description copied from interface: WanAcknowledger

Acknowledges the WAN operation as failed operation.

Specified by:

acknowledgeFailure in interface WanAcknowledger

Parameters:

operation - the WAN operation to acknowledge