org.zodiac.server.proxy.impl

类 ConnectionFlowStep

java.lang.Object

org.zodiac.server.proxy.impl.ConnectionFlowStep

abstract class ConnectionFlowStep
extends Object

Represents a phase in a ConnectionFlow.

字段概要

字段

限定符和类型	字段和说明
private ProxyConnection	connection
private ProxyConnectionLogger	LOG
private ConnectionState	state

构造器概要

构造器

构造器和说明
ConnectionFlowStep(ProxyConnection connection, ConnectionState state) Construct a new step in a connection flow.

方法概要

限定符和类型	方法和说明
protected abstract io.netty.util.concurrent.Future	execute() Implement this method to actually do the work involved in this step of the flow.
(专用程序包) ProxyConnection	getConnection()
(专用程序包) ConnectionState	getState()
(专用程序包) void	onSuccess(ConnectionFlow flow) When the flow determines that this step was successful, it calls into this method.
(专用程序包) void	read(ConnectionFlow flow, Object msg) Any messages that are read from the underlying connection while we're at this step of the connection flow are passed to this method.
(专用程序包) boolean	shouldExecuteOnEventLoop() Indicates whether or not this step should be executed on the channel's event loop.
(专用程序包) boolean	shouldSuppressInitialRequest() Indicates whether or not to suppress the initial request.
String	toString()

从类继承的方法 java.lang.Object

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

字段详细资料

LOG

private final ProxyConnectionLogger LOG

connection

private final ProxyConnection connection

state

private final ConnectionState state

构造器详细资料

ConnectionFlowStep

ConnectionFlowStep(ProxyConnection connection,
                   ConnectionState state)

Construct a new step in a connection flow.

参数:

connection - the connection that we're working on

state - the state that the connection will show while we're processing this step

方法详细资料

getConnection

ProxyConnection getConnection()

getState

ConnectionState getState()

shouldSuppressInitialRequest

boolean shouldSuppressInitialRequest()

Indicates whether or not to suppress the initial request. Defaults to false, can be overridden.

返回:

should suppress request

shouldExecuteOnEventLoop

boolean shouldExecuteOnEventLoop()

Indicates whether or not this step should be executed on the channel's event loop. Defaults to true, can be overridden.

If this step modifies the pipeline, for example by adding/removing handlers, it's best to make it execute on the event loop.

返回:

should executed on event loop ot not

execute

protected abstract io.netty.util.concurrent.Future execute()

Implement this method to actually do the work involved in this step of the flow.

返回:

Future

onSuccess

void onSuccess(ConnectionFlow flow)

When the flow determines that this step was successful, it calls into this method. The default implementation simply continues with the flow. Other implementations may choose to not continue and instead wait for a message or something like that.

参数:

flow - connection flow

read

void read(ConnectionFlow flow,
          Object msg)

Any messages that are read from the underlying connection while we're at this step of the connection flow are passed to this method.

The default implementation ignores the message and logs this, since we weren't really expecting a message here.

Some ConnectionFlowSteps do need to read the messages, so they override this method as appropriate.

参数:

flow - our ConnectionFlow

msg - the message read from the underlying connection

toString

public String toString()

覆盖:

toString 在类中 Object