com.alipay.sofa.jraft.rpc.impl

Class BoltRpcClient

java.lang.Object

com.alipay.sofa.jraft.rpc.impl.BoltRpcClient

All Implemented Interfaces:

Lifecycle<RpcOptions>, RpcClient

public class BoltRpcClient
extends Object
implements RpcClient

Bolt rpc client impl.

Author:

jiachun.fjc

Field Summary

Fields

Modifier and Type	Field and Description
static String	BOLT_CTX
static String	BOLT_REJECTED_EXECUTION_POLICY

Constructor Summary

Constructors

Constructor and Description
BoltRpcClient(com.alipay.remoting.rpc.RpcClient rpcClient)

Method Summary

Modifier and Type	Method and Description
boolean	checkConnection(Endpoint endpoint) Check connection for given address.
boolean	checkConnection(Endpoint endpoint, boolean createIfAbsent) Check connection for given address and async to create a new one if there is no connection.
void	closeConnection(Endpoint endpoint) Close all connections of a address.
com.alipay.remoting.rpc.RpcClient	getRpcClient()
boolean	init(RpcOptions opts) Initialize the service.
void	invokeAsync(Endpoint endpoint, Object request, InvokeContext ctx, InvokeCallback callback, long timeoutMs) Asynchronous invocation with a callback.
Object	invokeSync(Endpoint endpoint, Object request, InvokeContext ctx, long timeoutMs) Synchronous invocation using a invoke context.
void	registerConnectEventListener(ReplicatorGroup replicatorGroup) Register a connect event listener for the replicator group.
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

Methods inherited from interface com.alipay.sofa.jraft.rpc.RpcClient

invokeAsync, invokeSync

Field Detail

BOLT_CTX

public static final String BOLT_CTX

See Also:

Constant Field Values

BOLT_REJECTED_EXECUTION_POLICY

public static final String BOLT_REJECTED_EXECUTION_POLICY

See Also:

Constant Field Values

Constructor Detail

BoltRpcClient

public BoltRpcClient(com.alipay.remoting.rpc.RpcClient rpcClient)

Method Detail

init

public boolean init(RpcOptions opts)

Description copied from interface: Lifecycle

Initialize the service.

Specified by:

init in interface Lifecycle<RpcOptions>

Returns:

true when successes.

shutdown

public void shutdown()

Description copied from interface: Lifecycle

Dispose the resources for service.

Specified by:

shutdown in interface Lifecycle<RpcOptions>

checkConnection

public boolean checkConnection(Endpoint endpoint)

Description copied from interface: RpcClient

Check connection for given address.

Specified by:

checkConnection in interface RpcClient

Parameters:

endpoint - target address

Returns:

true if there is a connection and the connection is active and writable.

checkConnection

public boolean checkConnection(Endpoint endpoint,
                               boolean createIfAbsent)

Description copied from interface: RpcClient

Check connection for given address and async to create a new one if there is no connection.

Specified by:

checkConnection in interface RpcClient

Parameters:

endpoint - target address

createIfAbsent - create a new one if there is no connection

Returns:

true if there is a connection and the connection is active and writable.

closeConnection

public void closeConnection(Endpoint endpoint)

Description copied from interface: RpcClient

Close all connections of a address.

Specified by:

closeConnection in interface RpcClient

Parameters:

endpoint - target address

registerConnectEventListener

public void registerConnectEventListener(ReplicatorGroup replicatorGroup)

Description copied from interface: RpcClient

Register a connect event listener for the replicator group.

Specified by:

registerConnectEventListener in interface RpcClient

Parameters:

replicatorGroup - replicator group

invokeSync

public Object invokeSync(Endpoint endpoint,
                         Object request,
                         InvokeContext ctx,
                         long timeoutMs)
                  throws InterruptedException,
                         RemotingException

Description copied from interface: RpcClient

Synchronous invocation using a invoke context.

Specified by:

invokeSync in interface RpcClient

Parameters:

endpoint - target address

request - request object

ctx - invoke context

timeoutMs - timeout millisecond

Returns:

invoke result

Throws:

InterruptedException

RemotingException

invokeAsync

public void invokeAsync(Endpoint endpoint,
                        Object request,
                        InvokeContext ctx,
                        InvokeCallback callback,
                        long timeoutMs)
                 throws InterruptedException,
                        RemotingException

Description copied from interface: RpcClient

Asynchronous invocation with a callback.

Specified by:

invokeAsync in interface RpcClient

Parameters:

endpoint - target address

request - request object

ctx - invoke context

callback - invoke callback

timeoutMs - timeout millisecond

Throws:

InterruptedException

RemotingException

getRpcClient

public com.alipay.remoting.rpc.RpcClient getRpcClient()