Package org.infinispan.server.resp

Class SubscriberHandler

java.lang.Object

org.infinispan.server.resp.RespRequestHandler

org.infinispan.server.resp.CacheRespRequestHandler

org.infinispan.server.resp.SubscriberHandler

public class SubscriberHandler
extends CacheRespRequestHandler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SubscriberHandler.PubSubListener

Field Summary

Fields inherited from class org.infinispan.server.resp.CacheRespRequestHandler

cache

Fields inherited from class org.infinispan.server.resp.RespRequestHandler

BYTE_BUF_POOL_ATTRIBUTE_KEY, myStage, respServer, writer

Constructor Summary

Constructors

Constructor	Description
SubscriberHandler(RespServer respServer, Resp3Handler prevHandler)

Method Summary

Modifier and Type	Method	Description
protected CompletionStage<RespRequestHandler>	actualHandleRequest(io.netty.channel.ChannelHandlerContext ctx, RespCommand command, List<byte[]> arguments)	Handles the RESP request returning a stage that when complete notifies the command has completed as well as providing the request handler for subsequent commands.
void	handleChannelDisconnect(io.netty.channel.ChannelHandlerContext ctx)
CompletionStage<Void>	handleStageListenerError(CompletionStage<Void> stage, byte[] keyChannel, boolean subscribeOrUnsubscribe)
static RespCacheListener	newKeyListener(io.netty.channel.Channel channel, byte[] key)
static RespCacheListener	newPatternListener(io.netty.channel.Channel channel, byte[] pattern)
void	removeAllListeners()
Resp3Handler	resp3Handler()
CompletionStage<RespRequestHandler>	sendSubscriptions(io.netty.channel.ChannelHandlerContext ctx, CompletionStage<Void> stageToWaitFor, Collection<byte[]> keyChannels, boolean isSubscribe)
Map<WrappedByteArray,RespCacheListener>	specificChannelSubscribers()
CompletionStage<RespRequestHandler>	unsubscribeAll(io.netty.channel.ChannelHandlerContext ctx)

Methods inherited from class org.infinispan.server.resp.CacheRespRequestHandler

cache, setCache, typedCache

Methods inherited from class org.infinispan.server.resp.RespRequestHandler

commandNotFound, handleRequest, initializeIfNecessary, myStage, respServer, stageToReturn, stageToReturn, stageToReturn, writer

Methods inherited from class java.lang.Object

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

Constructor Details

SubscriberHandler

public SubscriberHandler(RespServer respServer,
 Resp3Handler prevHandler)

Method Details

newKeyListener

public static RespCacheListener newKeyListener(io.netty.channel.Channel channel,
 byte[] key)

newPatternListener

public static RespCacheListener newPatternListener(io.netty.channel.Channel channel,
 byte[] pattern)

specificChannelSubscribers

public Map<WrappedByteArray,RespCacheListener> specificChannelSubscribers()

resp3Handler

public Resp3Handler resp3Handler()

handleChannelDisconnect

public void handleChannelDisconnect(io.netty.channel.ChannelHandlerContext ctx)

Overrides:

handleChannelDisconnect in class RespRequestHandler

actualHandleRequest

protected CompletionStage<RespRequestHandler> actualHandleRequest(io.netty.channel.ChannelHandlerContext ctx,
 RespCommand command,
 List<byte[]> arguments)

Description copied from class: RespRequestHandler

Handles the RESP request returning a stage that when complete notifies the command has completed as well as providing the request handler for subsequent commands.

Implementations should never use the ByteBufAllocator in the context. Instead, they should use RespRequestHandler.writer to retrieve a ResponseWriter This ByteBuffer should only have bytes written to it adding up to the size requested. The ByteBuffer itself should never be written to the context or channel and flush should also never be invoked. Failure to do so may cause mis-ordering or responses as requests support pipelining and a ByteBuf may not be sent down stream until later in the pipeline.

Overrides:

actualHandleRequest in class RespRequestHandler

Parameters:

ctx - Netty context pipeline for this request

command - The command type

arguments - The remaining arguments to the command

Returns:

stage that when complete returns the new handler to instate. This stage must be completed on the event loop

handleStageListenerError

public CompletionStage<Void> handleStageListenerError(CompletionStage<Void> stage,
 byte[] keyChannel,
 boolean subscribeOrUnsubscribe)

removeAllListeners

public void removeAllListeners()

unsubscribeAll

public CompletionStage<RespRequestHandler> unsubscribeAll(io.netty.channel.ChannelHandlerContext ctx)

sendSubscriptions

public CompletionStage<RespRequestHandler> sendSubscriptions(io.netty.channel.ChannelHandlerContext ctx,
 CompletionStage<Void> stageToWaitFor,
 Collection<byte[]> keyChannels,
 boolean isSubscribe)