com.alipay.sofa.jraft.rpc.impl

Class BoltRpcServer

java.lang.Object

com.alipay.sofa.jraft.rpc.impl.BoltRpcServer

All Implemented Interfaces:

Lifecycle<Void>, RpcServer

public class BoltRpcServer
extends Object
implements RpcServer

Bolt RPC server impl.

Author:

jiachun.fjc

Constructor Summary

Constructors

Constructor and Description
BoltRpcServer(com.alipay.remoting.rpc.RpcServer rpcServer)

Method Summary

Modifier and Type	Method and Description
int	boundPort()
com.alipay.remoting.rpc.RpcServer	getServer()
boolean	init(Void opts) Initialize the service.
void	registerConnectionClosedEventListener(ConnectionClosedEventListener listener) Register a conn closed event listener.
void	registerProcessor(RpcProcessor processor) Register user processor.
void	shutdown() Dispose the resources for service.

Methods inherited from class java.lang.Object

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

Constructor Detail

BoltRpcServer

public BoltRpcServer(com.alipay.remoting.rpc.RpcServer rpcServer)

Method Detail

init

public boolean init(Void opts)

Description copied from interface: Lifecycle

Initialize the service.

Specified by:

init in interface Lifecycle<Void>

Returns:

true when successes.

shutdown

public void shutdown()

Description copied from interface: Lifecycle

Dispose the resources for service.

Specified by:

shutdown in interface Lifecycle<Void>

registerConnectionClosedEventListener

public void registerConnectionClosedEventListener(ConnectionClosedEventListener listener)

Description copied from interface: RpcServer

Register a conn closed event listener.

Specified by:

registerConnectionClosedEventListener in interface RpcServer

Parameters:

listener - the event listener.

boundPort

public int boundPort()

Specified by:

boundPort in interface RpcServer

Returns:

bound port

registerProcessor

public void registerProcessor(RpcProcessor processor)

Description copied from interface: RpcServer

Register user processor.

Specified by:

registerProcessor in interface RpcServer

Parameters:

processor - the user processor which has a interest

getServer

public com.alipay.remoting.rpc.RpcServer getServer()