org.apache.dubbo.rpc.protocol.tri.command

Class QueuedCommand

java.lang.Object

org.apache.dubbo.rpc.protocol.tri.command.QueuedCommand

Direct Known Subclasses:

CancelQueueCommand, DataQueueCommand, EndStreamQueueCommand, HeaderQueueCommand, TextDataQueueCommand

public abstract class QueuedCommand
extends Object

Constructor Summary

Constructors

Constructor and Description
QueuedCommand()

Method Summary

Modifier and Type	Method and Description
void	cancel()
abstract void	doSend(io.netty.channel.ChannelHandlerContext ctx, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelPromise	promise()
void	promise(io.netty.channel.ChannelPromise promise)
void	run(io.netty.channel.Channel channel)
void	send(io.netty.channel.ChannelHandlerContext ctx, io.netty.channel.ChannelPromise promise)

Methods inherited from class java.lang.Object

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

Constructor Detail

QueuedCommand

public QueuedCommand()

Method Detail

promise

public io.netty.channel.ChannelPromise promise()

promise

public void promise(io.netty.channel.ChannelPromise promise)

cancel

public void cancel()

run

public void run(io.netty.channel.Channel channel)

send

public final void send(io.netty.channel.ChannelHandlerContext ctx,
                       io.netty.channel.ChannelPromise promise)

doSend

public abstract void doSend(io.netty.channel.ChannelHandlerContext ctx,
                            io.netty.channel.ChannelPromise promise)