com.fr.workspace.engine.server.rpc.netty

类 MessageReceiveExecutor

java.lang.Object

com.fr.workspace.engine.server.rpc.netty.MessageReceiveExecutor

public class MessageReceiveExecutor
extends java.lang.Object

方法概要

方法

限定符和类型	方法和说明
java.lang.String	getHost()
static MessageReceiveExecutor	getInstance()
int	getPort()
SerializeProtocol	getSerializeProtocol()
java.lang.String	getServerAddress()
MessageReceiveExecutor	host(java.lang.String host)
MessageReceiveExecutor	port(int port)
MessageReceiveExecutor	serializeProtocol(SerializeProtocol serializeProtocol)
void	setHost(java.lang.String host)
void	setPort(int port)
void	setSerializeProtocol(SerializeProtocol serializeProtocol)
void	start()
void	stop()
static void	submit(java.util.concurrent.Callable<java.lang.Boolean> task, io.netty.channel.ChannelHandlerContext ctx, MessageRequest request, MessageResponse response)

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

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

方法详细资料

getInstance

public static MessageReceiveExecutor getInstance()

submit

public static void submit(java.util.concurrent.Callable<java.lang.Boolean> task,
          io.netty.channel.ChannelHandlerContext ctx,
          MessageRequest request,
          MessageResponse response)

start

public void start()

stop

public void stop()

getPort

public int getPort()

setPort

public void setPort(int port)

port

public MessageReceiveExecutor port(int port)

getHost

public java.lang.String getHost()

setHost

public void setHost(java.lang.String host)

host

public MessageReceiveExecutor host(java.lang.String host)

getServerAddress

public java.lang.String getServerAddress()

getSerializeProtocol

public SerializeProtocol getSerializeProtocol()

setSerializeProtocol

public void setSerializeProtocol(SerializeProtocol serializeProtocol)

serializeProtocol

public MessageReceiveExecutor serializeProtocol(SerializeProtocol serializeProtocol)