org.apache.pulsar.common.api

Class PulsarDecoder

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

org.apache.pulsar.common.api.PulsarDecoder

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

Direct Known Subclasses:

PulsarHandler

public abstract class PulsarDecoder
extends io.netty.channel.ChannelInboundHandlerAdapter

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
static int	MaxFrameSize
static int	MaxMessageSize

Constructor Summary

Constructors

Constructor and Description
PulsarDecoder()

Method Summary

Modifier and Type	Method and Description
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)
protected void	handleAck(PulsarApi.CommandAck ack)
protected void	handleActiveConsumerChange(PulsarApi.CommandActiveConsumerChange change)
protected void	handleCloseConsumer(PulsarApi.CommandCloseConsumer closeConsumer)
protected void	handleCloseProducer(PulsarApi.CommandCloseProducer closeProducer)
protected void	handleConnect(PulsarApi.CommandConnect connect)
protected void	handleConnected(PulsarApi.CommandConnected connected)
protected void	handleConsumerStats(PulsarApi.CommandConsumerStats commandConsumerStats)
protected void	handleConsumerStatsResponse(PulsarApi.CommandConsumerStatsResponse commandConsumerStatsResponse)
protected void	handleError(PulsarApi.CommandError error)
protected void	handleFlow(PulsarApi.CommandFlow flow)
protected void	handleGetLastMessageId(PulsarApi.CommandGetLastMessageId getLastMessageId)
protected void	handleGetLastMessageIdSuccess(PulsarApi.CommandGetLastMessageIdResponse success)
protected void	handleGetSchema(PulsarApi.CommandGetSchema commandGetSchema)
protected void	handleGetSchemaResponse(PulsarApi.CommandGetSchemaResponse commandGetSchemaResponse)
protected void	handleGetTopicsOfNamespace(PulsarApi.CommandGetTopicsOfNamespace commandGetTopicsOfNamespace)
protected void	handleGetTopicsOfNamespaceSuccess(PulsarApi.CommandGetTopicsOfNamespaceResponse response)
protected void	handleLookup(PulsarApi.CommandLookupTopic lookup)
protected void	handleLookupResponse(PulsarApi.CommandLookupTopicResponse connection)
protected void	handleMessage(PulsarApi.CommandMessage cmdMessage, io.netty.buffer.ByteBuf headersAndPayload)
protected void	handlePartitionMetadataRequest(PulsarApi.CommandPartitionedTopicMetadata response)
protected void	handlePartitionResponse(PulsarApi.CommandPartitionedTopicMetadataResponse response)
protected void	handlePing(PulsarApi.CommandPing ping)
protected void	handlePong(PulsarApi.CommandPong pong)
protected void	handleProducer(PulsarApi.CommandProducer producer)
protected void	handleProducerSuccess(PulsarApi.CommandProducerSuccess success)
protected void	handleReachedEndOfTopic(PulsarApi.CommandReachedEndOfTopic commandReachedEndOfTopic)
protected void	handleRedeliverUnacknowledged(PulsarApi.CommandRedeliverUnacknowledgedMessages redeliver)
protected void	handleSeek(PulsarApi.CommandSeek seek)
protected void	handleSend(PulsarApi.CommandSend send, io.netty.buffer.ByteBuf headersAndPayload)
protected void	handleSendError(PulsarApi.CommandSendError sendError)
protected void	handleSendReceipt(PulsarApi.CommandSendReceipt sendReceipt)
protected void	handleSubscribe(PulsarApi.CommandSubscribe subscribe)
protected void	handleSuccess(PulsarApi.CommandSuccess success)
protected void	handleUnsubscribe(PulsarApi.CommandUnsubscribe unsubscribe)
protected abstract void	messageReceived()

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Field Detail

MaxMessageSize

public static final int MaxMessageSize

See Also:

Constant Field Values

MaxFrameSize

public static final int MaxFrameSize

See Also:

Constant Field Values

Constructor Detail

PulsarDecoder

public PulsarDecoder()

Method Detail

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext ctx,
                        Object msg)
                 throws Exception

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

messageReceived

protected abstract void messageReceived()

handlePartitionMetadataRequest

protected void handlePartitionMetadataRequest(PulsarApi.CommandPartitionedTopicMetadata response)

handlePartitionResponse

protected void handlePartitionResponse(PulsarApi.CommandPartitionedTopicMetadataResponse response)

handleLookup

protected void handleLookup(PulsarApi.CommandLookupTopic lookup)

handleLookupResponse

protected void handleLookupResponse(PulsarApi.CommandLookupTopicResponse connection)

handleConnect

protected void handleConnect(PulsarApi.CommandConnect connect)

handleConnected

protected void handleConnected(PulsarApi.CommandConnected connected)

handleSubscribe

protected void handleSubscribe(PulsarApi.CommandSubscribe subscribe)

handleProducer

protected void handleProducer(PulsarApi.CommandProducer producer)

handleSend

protected void handleSend(PulsarApi.CommandSend send,
                          io.netty.buffer.ByteBuf headersAndPayload)

handleSendReceipt

protected void handleSendReceipt(PulsarApi.CommandSendReceipt sendReceipt)

handleSendError

protected void handleSendError(PulsarApi.CommandSendError sendError)

handleMessage

protected void handleMessage(PulsarApi.CommandMessage cmdMessage,
                             io.netty.buffer.ByteBuf headersAndPayload)

handleAck

protected void handleAck(PulsarApi.CommandAck ack)

handleFlow

protected void handleFlow(PulsarApi.CommandFlow flow)

handleRedeliverUnacknowledged

protected void handleRedeliverUnacknowledged(PulsarApi.CommandRedeliverUnacknowledgedMessages redeliver)

handleUnsubscribe

protected void handleUnsubscribe(PulsarApi.CommandUnsubscribe unsubscribe)

handleSeek

protected void handleSeek(PulsarApi.CommandSeek seek)

handleActiveConsumerChange

protected void handleActiveConsumerChange(PulsarApi.CommandActiveConsumerChange change)

handleSuccess

protected void handleSuccess(PulsarApi.CommandSuccess success)

handleProducerSuccess

protected void handleProducerSuccess(PulsarApi.CommandProducerSuccess success)

handleError

protected void handleError(PulsarApi.CommandError error)

handleCloseProducer

protected void handleCloseProducer(PulsarApi.CommandCloseProducer closeProducer)

handleCloseConsumer

protected void handleCloseConsumer(PulsarApi.CommandCloseConsumer closeConsumer)

handlePing

protected void handlePing(PulsarApi.CommandPing ping)

handlePong

protected void handlePong(PulsarApi.CommandPong pong)

handleConsumerStats

protected void handleConsumerStats(PulsarApi.CommandConsumerStats commandConsumerStats)

handleConsumerStatsResponse

protected void handleConsumerStatsResponse(PulsarApi.CommandConsumerStatsResponse commandConsumerStatsResponse)

handleReachedEndOfTopic

protected void handleReachedEndOfTopic(PulsarApi.CommandReachedEndOfTopic commandReachedEndOfTopic)

handleGetLastMessageId

protected void handleGetLastMessageId(PulsarApi.CommandGetLastMessageId getLastMessageId)

handleGetLastMessageIdSuccess

protected void handleGetLastMessageIdSuccess(PulsarApi.CommandGetLastMessageIdResponse success)

handleGetTopicsOfNamespace

protected void handleGetTopicsOfNamespace(PulsarApi.CommandGetTopicsOfNamespace commandGetTopicsOfNamespace)

handleGetTopicsOfNamespaceSuccess

protected void handleGetTopicsOfNamespaceSuccess(PulsarApi.CommandGetTopicsOfNamespaceResponse response)

handleGetSchema

protected void handleGetSchema(PulsarApi.CommandGetSchema commandGetSchema)

handleGetSchemaResponse

protected void handleGetSchemaResponse(PulsarApi.CommandGetSchemaResponse commandGetSchemaResponse)