redis.clients.jedis

Interface PushConsumerChain

All Known Implementing Classes:

PushConsumerChainImpl

@Experimental
public interface PushConsumerChain

Process push messages and decide weather to propagate them to the caller or consume them.

The PushConsumerChain is used by the Protocol.read(RedisInputStream, PushConsumerChain) method to process out of band push messages while reading the regular command replies.

See Also:

Protocol.read(RedisInputStream, PushConsumerChain)

Method Summary

Modifier and Type	Method and Description
java.util.List<PushConsumer>	getConsumers() Return a list of consumers in the chain.
PushMessage	process(PushMessage message) Process the push message Returning null means the message was consumed.

Method Detail

process

PushMessage process(PushMessage message)

Process the push message

Returning null means the message was consumed.

Parameters:

message - message to process

Returns:

message, or null if the message was consumed

getConsumers

java.util.List<PushConsumer> getConsumers()

Return a list of consumers in the chain.

Returns:

list of consumers in the chain