Uses of Class
org.infinispan.server.resp.SubscriberHandler

Packages that use SubscriberHandler

Package	Description
org.infinispan.server.resp.commands
org.infinispan.server.resp.commands.connection
org.infinispan.server.resp.commands.pubsub

Uses of SubscriberHandler in org.infinispan.server.resp.commands

Methods in org.infinispan.server.resp.commands with parameters of type SubscriberHandler

Modifier and Type	Method	Description
CompletionStage<RespRequestHandler>	PubSubResp3Command.perform(SubscriberHandler handler, io.netty.channel.ChannelHandlerContext ctx, List<byte[]> arguments)

Uses of SubscriberHandler in org.infinispan.server.resp.commands.connection

Methods in org.infinispan.server.resp.commands.connection with parameters of type SubscriberHandler

Modifier and Type	Method	Description
CompletionStage<RespRequestHandler>	PING.perform(SubscriberHandler handler, io.netty.channel.ChannelHandlerContext ctx, List<byte[]> arguments)
CompletionStage<RespRequestHandler>	QUIT.perform(SubscriberHandler handler, io.netty.channel.ChannelHandlerContext ctx, List<byte[]> arguments)
CompletionStage<RespRequestHandler>	RESET.perform(SubscriberHandler handler, io.netty.channel.ChannelHandlerContext ctx, List<byte[]> arguments)

Uses of SubscriberHandler in org.infinispan.server.resp.commands.pubsub

Methods in org.infinispan.server.resp.commands.pubsub with parameters of type SubscriberHandler

Modifier and Type	Method	Description
CompletionStage<RespRequestHandler>	PSUBSCRIBE.perform(SubscriberHandler handler, io.netty.channel.ChannelHandlerContext ctx, List<byte[]> arguments)
CompletionStage<RespRequestHandler>	PUNSUBSCRIBE.perform(SubscriberHandler handler, io.netty.channel.ChannelHandlerContext ctx, List<byte[]> arguments)
CompletionStage<RespRequestHandler>	SUBSCRIBE.perform(SubscriberHandler handler, io.netty.channel.ChannelHandlerContext ctx, List<byte[]> arguments)
CompletionStage<RespRequestHandler>	UNSUBSCRIBE.perform(SubscriberHandler handler, io.netty.channel.ChannelHandlerContext ctx, List<byte[]> arguments)