redis.clients.jedis.csc

Class PushInvalidateConsumer

java.lang.Object

redis.clients.jedis.csc.PushInvalidateConsumer

All Implemented Interfaces:

PushConsumer

@Internal
public class PushInvalidateConsumer
extends java.lang.Object
implements PushConsumer

PushConsumer that drops RESP3 invalidate push messages after evicting the referenced Redis keys from the supplied Cache.

Internal API: exposed only so tests and benchmarks outside this package can construct it directly. Not part of the public surface and subject to change.

Constructor Summary

Constructors

Constructor and Description
PushInvalidateConsumer(Cache cache)

Method Summary

Modifier and Type	Method and Description
PushConsumerContext	handle(PushConsumerContext context) Process a push message.

Methods inherited from class java.lang.Object

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

Constructor Detail

PushInvalidateConsumer

public PushInvalidateConsumer(Cache cache)

Method Detail

handle

public PushConsumerContext handle(PushConsumerContext context)

Description copied from interface: PushConsumer

Process a push message. Each PushConsumer can decide to:

• Allow the message to be returned to the caller by calling PushConsumerContext.propagate()
• Process the message and prevent it from being processed further by calling PushConsumerContext.drop()

Specified by:

handle in interface PushConsumer

Parameters:

context - The context of the push message

See Also:

PushConsumerChain, PushConsumerContext