- backChannelHandlers() - Method in interface com.alipay.remoting.ExtendedNettyChannelHandler
-
Netty ChannelHandlers to be added after Bolt's built-in Handler.
- BaseRemoting - Class in com.alipay.remoting
-
Base remoting capability.
- BaseRemoting(CommandFactory) - Constructor for class com.alipay.remoting.BaseRemoting
-
- BizContext - Interface in com.alipay.remoting
-
basic info for biz
- BOLT_CRC_SWITCH - Static variable in class com.alipay.remoting.InvokeContext
-
- BOLT_CUSTOM_SERIALIZER - Static variable in class com.alipay.remoting.InvokeContext
-
- BOLT_INVOKE_REQUEST_ID - Static variable in class com.alipay.remoting.InvokeContext
-
- BOLT_LOG_SPACE_PROPERTY - Static variable in class com.alipay.remoting.log.BoltLoggerFactory
-
- BOLT_PROCESS_ARRIVE_BODY_IN_NANO - Static variable in class com.alipay.remoting.InvokeContext
-
- BOLT_PROCESS_ARRIVE_HEADER_IN_NANO - Static variable in class com.alipay.remoting.InvokeContext
-
time request arrived in nano seconds , collected by System.nanoTime()
- BOLT_PROCESS_BEFORE_DISPATCH_IN_NANO - Static variable in class com.alipay.remoting.InvokeContext
-
time before send request to user thread in nano seconds , collected by System.nanoTime()
- BOLT_PROCESS_CLIENT_AFTER_SEND - Static variable in class com.alipay.remoting.InvokeContext
-
time after send request to net in nano seconds , collected by System.nanoTime()
- BOLT_PROCESS_CLIENT_BEFORE_SEND - Static variable in class com.alipay.remoting.InvokeContext
-
time before send request to net in nano seconds , collected by System.nanoTime()
- BOLT_PROCESS_CLIENT_RECEIVED - Static variable in class com.alipay.remoting.InvokeContext
-
time after receive response from server in nano seconds , collected by System.nanoTime()
- BOLT_PROCESS_START_PROCESS_IN_NANO - Static variable in class com.alipay.remoting.InvokeContext
-
time before send request to user thread in nano seconds , collected by System.nanoTime()
- BOLT_PROCESS_WAIT_TIME - Static variable in class com.alipay.remoting.InvokeContext
-
time consumed start from the time when request arrive, to the time when request be processed, this is a timespan
- BoltClient - Interface in com.alipay.remoting
-
Bolt client interface.
- BoltClientOption<T> - Class in com.alipay.remoting.config
-
Supported options in client side.
- BoltGenericOption<T> - Class in com.alipay.remoting.config
-
Supported options both in client and server side.
- BoltGenericOption(String, T) - Constructor for class com.alipay.remoting.config.BoltGenericOption
-
- BoltLoggerFactory - Class in com.alipay.remoting.log
-
Customized logger factory
This can use middleware-log in sofa-common-tools to detect specific log implementation and initialize with the given log template.
- BoltLoggerFactory() - Constructor for class com.alipay.remoting.log.BoltLoggerFactory
-
- BoltOption<T> - Class in com.alipay.remoting.config
-
The base implementation class of the configuration item.
- BoltOption(String, T) - Constructor for class com.alipay.remoting.config.BoltOption
-
- BoltOptions - Class in com.alipay.remoting.config
-
Option carrier.
- BoltOptions() - Constructor for class com.alipay.remoting.config.BoltOptions
-
- BoltServerOption<T> - Class in com.alipay.remoting.config
-
Supported options in server side.
- bootstrap - Variable in class com.alipay.remoting.connection.AbstractConnectionFactory
-
- callDecode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class com.alipay.remoting.codec.AbstractBatchDecoder
-
Called once data should be decoded from the given ByteBuf.
- cancelTimeout() - Method in interface com.alipay.remoting.InvokeFuture
-
Cancel the timeout.
- cancelTimeout() - Method in class com.alipay.remoting.rpc.DefaultInvokeFuture
-
- channelActive(ChannelHandlerContext) - Method in class com.alipay.remoting.ConnectionEventHandler
-
- channelInactive(ChannelHandlerContext) - Method in class com.alipay.remoting.codec.AbstractBatchDecoder
-
- channelInactive(ChannelHandlerContext) - Method in class com.alipay.remoting.ConnectionEventHandler
-
- channelInactive(ChannelHandlerContext) - Method in class com.alipay.remoting.rpc.RpcConnectionEventHandler
-
- channelRead(ChannelHandlerContext, Object) - Method in class com.alipay.remoting.codec.AbstractBatchDecoder
-
This method has been modified to check the size of decoded msgs, which is represented by the
local variable RecyclableArrayList out.
- channelRead(ChannelHandlerContext, Object) - Method in class com.alipay.remoting.rpc.RpcHandler
-
- channelReadComplete(ChannelHandlerContext) - Method in class com.alipay.remoting.codec.AbstractBatchDecoder
-
- channelRegistered(ChannelHandlerContext) - Method in class com.alipay.remoting.ConnectionEventHandler
-
- channelUnregistered(ChannelHandlerContext) - Method in class com.alipay.remoting.ConnectionEventHandler
-
- check(Connection) - Method in interface com.alipay.remoting.ConnectionManager
-
check a connection whether available, if not, throw RemotingException
- check(Connection) - Method in class com.alipay.remoting.DefaultConnectionManager
-
- checkConnection(String) - Method in interface com.alipay.remoting.BoltClient
-
check connection, the address format example - 127.0.0.1:12200?
- checkConnection(String, boolean) - Method in interface com.alipay.remoting.BoltClient
-
check connection, the address format example - 127.0.0.1:12200?
- checkConnection(String, boolean, boolean) - Method in interface com.alipay.remoting.BoltClient
-
check connection, the address format example - 127.0.0.1:12200?
- checkConnection(String) - Method in class com.alipay.remoting.rpc.RpcClient
-
- checkConnection(String, boolean) - Method in class com.alipay.remoting.rpc.RpcClient
-
- checkConnection(String, boolean, boolean) - Method in class com.alipay.remoting.rpc.RpcClient
-
- clear() - Static method in class com.alipay.remoting.CustomSerializerManager
-
clear the custom serializers.
- clear() - Method in class com.alipay.remoting.InvokeContext
-
clear all mappings.
- clear() - Method in class com.alipay.remoting.util.ConcurrentHashSet
-
clear the set
- clearAttributes() - Method in class com.alipay.remoting.Connection
-
Clear attribute.
- CLI_SSL_ENABLE - Static variable in class com.alipay.remoting.config.BoltClientOption
-
- CLI_SSL_ENABLE - Static variable in class com.alipay.remoting.rpc.RpcConfigs
-
Whether to enable client SSL support, default is false(disabled).
- CLI_SSL_KEYSTORE - Static variable in class com.alipay.remoting.config.BoltClientOption
-
- CLI_SSL_KEYSTORE - Static variable in class com.alipay.remoting.rpc.RpcConfigs
-
Client SSL keystore file path
- CLI_SSL_KEYSTORE_PASS - Static variable in class com.alipay.remoting.config.BoltClientOption
-
- CLI_SSL_KEYSTORE_PASS - Static variable in class com.alipay.remoting.rpc.RpcConfigs
-
Client SSL keystore password
- CLI_SSL_KEYSTORE_TYPE - Static variable in class com.alipay.remoting.config.BoltClientOption
-
- CLI_SSL_KEYTSTORE_YPE - Static variable in class com.alipay.remoting.rpc.RpcConfigs
-
Client SSL keystore type, JKS pkcs12 for example.
- CLI_SSL_TMF_ALGO - Static variable in class com.alipay.remoting.config.BoltClientOption
-
- CLI_SSL_TMF_ALGO - Static variable in class com.alipay.remoting.rpc.RpcConfigs
-
Client SSL TrustManagerFactory algorithm.
- CLIENT_CONN_CREATE_END_IN_NANO - Static variable in class com.alipay.remoting.InvokeContext
-
- CLIENT_CONN_CREATE_START_IN_NANO - Static variable in class com.alipay.remoting.InvokeContext
-
- CLIENT_CONN_CREATETIME - Static variable in class com.alipay.remoting.InvokeContext
-
time consumed during connection creating, this is a timespan
- CLIENT_LOCAL_IP - Static variable in class com.alipay.remoting.InvokeContext
-
- CLIENT_LOCAL_PORT - Static variable in class com.alipay.remoting.InvokeContext
-
- CLIENT_REMOTE_IP - Static variable in class com.alipay.remoting.InvokeContext
-
- CLIENT_REMOTE_PORT - Static variable in class com.alipay.remoting.InvokeContext
-
- client_ssl_enable() - Static method in class com.alipay.remoting.rpc.RpcConfigManager
-
Deprecated.
- client_ssl_keystore() - Static method in class com.alipay.remoting.rpc.RpcConfigManager
-
Deprecated.
- client_ssl_keystore_pass() - Static method in class com.alipay.remoting.rpc.RpcConfigManager
-
Deprecated.
- client_ssl_keystore_type() - Static method in class com.alipay.remoting.rpc.RpcConfigManager
-
Deprecated.
- client_ssl_tmf_algorithm() - Static method in class com.alipay.remoting.rpc.RpcConfigManager
-
Deprecated.
- ClientConnectionManager - Interface in com.alipay.remoting
-
Connection manager in client side.
- close() - Method in class com.alipay.remoting.Connection
-
Close the connection.
- close(ChannelHandlerContext, ChannelPromise) - Method in class com.alipay.remoting.ConnectionEventHandler
-
- closeConnection(String) - Method in interface com.alipay.remoting.BoltClient
-
Close all connections of a address
- closeConnection(Url) - Method in interface com.alipay.remoting.BoltClient
-
Close all connections of a
Url
- closeConnection(String) - Method in class com.alipay.remoting.rpc.RpcClient
-
Close all connections of a address
- closeConnection(Url) - Method in class com.alipay.remoting.rpc.RpcClient
-
- closeQuietly(Closeable) - Static method in class com.alipay.remoting.util.IoUtils
-
- closeStandaloneConnection(Connection) - Method in interface com.alipay.remoting.BoltClient
-
Close a standalone connection
- closeStandaloneConnection(Connection) - Method in class com.alipay.remoting.rpc.RpcClient
-
- Codec - Interface in com.alipay.remoting.codec
-
Codec interface.
- CodecException - Exception in com.alipay.remoting.exception
-
Exception when codec problems occur
- CodecException() - Constructor for exception com.alipay.remoting.exception.CodecException
-
Constructor.
- CodecException(String) - Constructor for exception com.alipay.remoting.exception.CodecException
-
Constructor.
- CodecException(String, Throwable) - Constructor for exception com.alipay.remoting.exception.CodecException
-
Constructor.
- COLON - Static variable in interface com.alipay.remoting.RemotingAddressParser
-
symbol :
- com.alipay.remoting - package com.alipay.remoting
-
- com.alipay.remoting.codec - package com.alipay.remoting.codec
-
- com.alipay.remoting.config - package com.alipay.remoting.config
-
- com.alipay.remoting.config.configs - package com.alipay.remoting.config.configs
-
- com.alipay.remoting.config.switches - package com.alipay.remoting.config.switches
-
- com.alipay.remoting.connection - package com.alipay.remoting.connection
-
- com.alipay.remoting.constant - package com.alipay.remoting.constant
-
- com.alipay.remoting.exception - package com.alipay.remoting.exception
-
- com.alipay.remoting.log - package com.alipay.remoting.log
-
- com.alipay.remoting.rpc - package com.alipay.remoting.rpc
-
- com.alipay.remoting.rpc.exception - package com.alipay.remoting.rpc.exception
-
- com.alipay.remoting.rpc.protocol - package com.alipay.remoting.rpc.protocol
-
- com.alipay.remoting.serialization - package com.alipay.remoting.serialization
-
- com.alipay.remoting.util - package com.alipay.remoting.util
-
- CommandCode - Interface in com.alipay.remoting
-
Remoting command code stands for a specific remoting command, and every kind of command has its own code.
- CommandDecoder - Interface in com.alipay.remoting
-
Decode command.
- CommandEncoder - Interface in com.alipay.remoting
-
Encode command.
- CommandFactory - Interface in com.alipay.remoting
-
Command factory
- CommandHandler - Interface in com.alipay.remoting
-
Command handler.
- CommonCommandCode - Enum in com.alipay.remoting
-
The common command code, especially for heart beat command.
- COMPOSITE_CUMULATOR - Static variable in class com.alipay.remoting.codec.AbstractBatchDecoder
-
Cumulate ByteBufs by add them to a CompositeByteBuf and so do no memory copy whenever possible.
- ConcurrentHashSet<E> - Class in com.alipay.remoting.util
-
Concurrent hash set.
- ConcurrentHashSet() - Constructor for class com.alipay.remoting.util.ConcurrentHashSet
-
constructor
- conf() - Method in class com.alipay.remoting.AbstractBoltClient
-
Deprecated.
- conf() - Method in class com.alipay.remoting.AbstractRemotingServer
-
Deprecated.
- conf() - Method in interface com.alipay.remoting.config.ConfigurableInstance
-
Deprecated.
- ConfigContainer - Interface in com.alipay.remoting.config.configs
-
Deprecated.
- ConfigItem - Enum in com.alipay.remoting.config.configs
-
Deprecated.
- ConfigManager - Class in com.alipay.remoting.config
-
get configs through system properties prior to default value
- ConfigManager() - Constructor for class com.alipay.remoting.config.ConfigManager
-
- Configs - Class in com.alipay.remoting.config
-
Define the key for a certain config item using system property,
and provide the default value for that config item.
- Configs() - Constructor for class com.alipay.remoting.config.Configs
-
- ConfigType - Enum in com.alipay.remoting.config.configs
-
Deprecated.
- ConfigurableInstance - Interface in com.alipay.remoting.config
-
define an interface which can be used to implement configurable apis.
- Configuration - Interface in com.alipay.remoting.config
-
Config interface.
- conn_create_tp_keepalive() - Static method in class com.alipay.remoting.config.ConfigManager
-
- CONN_CREATE_TP_KEEPALIVE_TIME - Static variable in class com.alipay.remoting.config.BoltClientOption
-
- CONN_CREATE_TP_KEEPALIVE_TIME - Static variable in class com.alipay.remoting.config.Configs
-
Thread pool keep alive time for the connection manager executor
- CONN_CREATE_TP_KEEPALIVE_TIME_DEFAULT - Static variable in class com.alipay.remoting.config.Configs
-
- CONN_CREATE_TP_MAX_SIZE - Static variable in class com.alipay.remoting.config.BoltClientOption
-
- conn_create_tp_max_size() - Static method in class com.alipay.remoting.config.ConfigManager
-
- CONN_CREATE_TP_MAX_SIZE - Static variable in class com.alipay.remoting.config.Configs
-
Thread pool max size for the connection manager executor
- CONN_CREATE_TP_MAX_SIZE_DEFAULT - Static variable in class com.alipay.remoting.config.Configs
-
- CONN_CREATE_TP_MIN_SIZE - Static variable in class com.alipay.remoting.config.BoltClientOption
-
- conn_create_tp_min_size() - Static method in class com.alipay.remoting.config.ConfigManager
-
- CONN_CREATE_TP_MIN_SIZE - Static variable in class com.alipay.remoting.config.Configs
-
Thread pool min size for the connection manager executor
- CONN_CREATE_TP_MIN_SIZE_DEFAULT - Static variable in class com.alipay.remoting.config.Configs
-
- CONN_CREATE_TP_QUEUE_SIZE - Static variable in class com.alipay.remoting.config.BoltClientOption
-
- conn_create_tp_queue_size() - Static method in class com.alipay.remoting.config.ConfigManager
-
- CONN_CREATE_TP_QUEUE_SIZE - Static variable in class com.alipay.remoting.config.Configs
-
Thread pool queue size for the connection manager executor
- CONN_CREATE_TP_QUEUE_SIZE_DEFAULT - Static variable in class com.alipay.remoting.config.Configs
-
- conn_monitor_initial_delay() - Static method in class com.alipay.remoting.config.ConfigManager
-
- CONN_MONITOR_INITIAL_DELAY - Static variable in class com.alipay.remoting.config.Configs
-
Initial delay to execute schedule task for connection monitor
- CONN_MONITOR_INITIAL_DELAY_DEFAULT - Static variable in class com.alipay.remoting.config.Configs
-
- conn_monitor_period() - Static method in class com.alipay.remoting.config.ConfigManager
-
- CONN_MONITOR_PERIOD - Static variable in class com.alipay.remoting.config.Configs
-
Period of schedule task for connection monitor
- CONN_MONITOR_PERIOD_DEFAULT - Static variable in class com.alipay.remoting.config.Configs
-
- CONN_MONITOR_SWITCH - Static variable in class com.alipay.remoting.config.BoltClientOption
-
- conn_monitor_switch() - Static method in class com.alipay.remoting.config.ConfigManager
-
- CONN_MONITOR_SWITCH - Static variable in class com.alipay.remoting.config.Configs
-
- CONN_MONITOR_SWITCH_DEFAULT - Static variable in class com.alipay.remoting.config.Configs
-
- CONN_RECONNECT_SWITCH - Static variable in class com.alipay.remoting.config.BoltClientOption
-
- conn_reconnect_switch() - Static method in class com.alipay.remoting.config.ConfigManager
-
- CONN_RECONNECT_SWITCH - Static variable in class com.alipay.remoting.config.Configs
-
Reconnection switch
- CONN_RECONNECT_SWITCH_DEFAULT - Static variable in class com.alipay.remoting.config.Configs
-
- CONN_SERVICE_STATUS - Static variable in class com.alipay.remoting.config.Configs
-
Connection status
- CONN_SERVICE_STATUS_OFF - Static variable in class com.alipay.remoting.config.Configs
-
- CONN_SERVICE_STATUS_ON - Static variable in class com.alipay.remoting.config.Configs
-
- conn_threshold() - Static method in class com.alipay.remoting.config.ConfigManager
-
- CONN_THRESHOLD - Static variable in class com.alipay.remoting.config.Configs
-
Connection threshold
- CONN_THRESHOLD_DEFAULT - Static variable in class com.alipay.remoting.config.Configs
-
- connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise) - Method in class com.alipay.remoting.ConnectionEventHandler
-
- CONNECT_TIMEOUT_KEY - Static variable in class com.alipay.remoting.rpc.RpcConfigs
-
Connection timeout key in url.
- Connection - Class in com.alipay.remoting
-
An abstraction of socket channel.
- Connection(Channel) - Constructor for class com.alipay.remoting.Connection
-
Constructor
- Connection(Channel, Url) - Constructor for class com.alipay.remoting.Connection
-
Constructor
- Connection(Channel, ProtocolCode, Url) - Constructor for class com.alipay.remoting.Connection
-
Constructor
- Connection(Channel, ProtocolCode, byte, Url) - Constructor for class com.alipay.remoting.Connection
-
- CONNECTION - Static variable in class com.alipay.remoting.Connection
-
Attribute key for connection
- CONNECTION_NUM_KEY - Static variable in class com.alipay.remoting.rpc.RpcConfigs
-
Connection number key of each address
- CONNECTION_SELECT_STRATEGY - Static variable in class com.alipay.remoting.config.BoltGenericOption
-
- CONNECTION_WARMUP_KEY - Static variable in class com.alipay.remoting.rpc.RpcConfigs
-
whether need to warm up connections
- ConnectionClosedException - Exception in com.alipay.remoting.exception
-
Exception when connection is closed.
- ConnectionClosedException() - Constructor for exception com.alipay.remoting.exception.ConnectionClosedException
-
Default constructor.
- ConnectionClosedException(String) - Constructor for exception com.alipay.remoting.exception.ConnectionClosedException
-
- ConnectionClosedException(String, Throwable) - Constructor for exception com.alipay.remoting.exception.ConnectionClosedException
-
- ConnectionEventExecutor() - Constructor for class com.alipay.remoting.ConnectionEventHandler.ConnectionEventExecutor
-
- ConnectionEventHandler - Class in com.alipay.remoting
-
Log the channel status event.
- ConnectionEventHandler() - Constructor for class com.alipay.remoting.ConnectionEventHandler
-
- ConnectionEventHandler(Configuration) - Constructor for class com.alipay.remoting.ConnectionEventHandler
-
- connectionEventHandler - Variable in class com.alipay.remoting.DefaultConnectionManager
-
connection event handler
- ConnectionEventHandler.ConnectionEventExecutor - Class in com.alipay.remoting
-
Dispatch connection event.
- ConnectionEventListener - Class in com.alipay.remoting
-
Listen and dispatch connection events.
- ConnectionEventListener() - Constructor for class com.alipay.remoting.ConnectionEventListener
-
- connectionEventListener - Variable in class com.alipay.remoting.DefaultConnectionManager
-
connection event listener
- ConnectionEventProcessor - Interface in com.alipay.remoting
-
Process connection events.
- ConnectionEventType - Enum in com.alipay.remoting
-
Event triggered by connection state.
- ConnectionFactory - Interface in com.alipay.remoting.connection
-
Factory that creates connections.
- connectionFactory - Variable in class com.alipay.remoting.DefaultConnectionManager
-
connection factory
- ConnectionHeartbeatManager - Interface in com.alipay.remoting
-
Connection heart beat manager, operate heart beat whether enabled for a certain connection at runtime
- ConnectionManager - Interface in com.alipay.remoting
-
Connection manager of connection pool
- connectionManager - Variable in class com.alipay.remoting.rpc.RpcRemoting
-
connection manager
- ConnectionMonitorStrategy - Interface in com.alipay.remoting
-
The strategy of connection monitor
- ConnectionPool - Class in com.alipay.remoting
-
Connection pool
- ConnectionPool(ConnectionSelectStrategy) - Constructor for class com.alipay.remoting.ConnectionPool
-
Constructor
- ConnectionSelectStrategy - Interface in com.alipay.remoting
-
Select strategy from connection pool
- connectionSelectStrategy - Variable in class com.alipay.remoting.DefaultConnectionManager
-
connection pool select strategy
- ConnectionUtil - Class in com.alipay.remoting.util
-
connection util
- ConnectionUtil() - Constructor for class com.alipay.remoting.util.ConnectionUtil
-
- connTasks - Variable in class com.alipay.remoting.DefaultConnectionManager
-
connection pool initialize tasks
- Constants - Class in com.alipay.remoting.constant
-
Bolt Constants.
- Constants() - Constructor for class com.alipay.remoting.constant.Constants
-
- contains(ConfigType, ConfigItem) - Method in interface com.alipay.remoting.config.configs.ConfigContainer
-
Deprecated.
check whether a config item of a certain config type exist.
- contains(ConfigType, ConfigItem) - Method in class com.alipay.remoting.config.configs.DefaultConfigContainer
-
Deprecated.
- contains(Connection) - Method in class com.alipay.remoting.ConnectionPool
-
check weather a connection already added
- contains(Object) - Method in class com.alipay.remoting.util.ConcurrentHashSet
-
- count(String) - Method in interface com.alipay.remoting.ConnectionManager
-
- count(String) - Method in class com.alipay.remoting.DefaultConnectionManager
-
- crc32(byte[]) - Static method in class com.alipay.remoting.util.CrcUtil
-
Compute CRC32 code for byte[].
- crc32(byte[], int, int) - Static method in class com.alipay.remoting.util.CrcUtil
-
Compute CRC32 code for byte[].
- CRC_SWITCH_DEFAULT_VALUE - Static variable in class com.alipay.remoting.config.switches.ProtocolSwitch
-
- CRC_SWITCH_INDEX - Static variable in class com.alipay.remoting.config.switches.ProtocolSwitch
-
- CrcUtil - Class in com.alipay.remoting.util
-
CRC32 utility.
- CrcUtil() - Constructor for class com.alipay.remoting.util.CrcUtil
-
- create(int) - Static method in class com.alipay.remoting.config.switches.ProtocolSwitch
-
- create(int[]) - Static method in class com.alipay.remoting.config.switches.ProtocolSwitch
-
- create(Url) - Method in interface com.alipay.remoting.ConnectionManager
-
Create a connection using specified
Url.
- create(String, int) - Method in interface com.alipay.remoting.ConnectionManager
-
Create a connection using specified
String address.
- create(String, int, int) - Method in interface com.alipay.remoting.ConnectionManager
-
Create a connection using specified ip and port.
- create(Url) - Method in class com.alipay.remoting.DefaultConnectionManager
-
- create(String, int, int) - Method in class com.alipay.remoting.DefaultConnectionManager
-
- create(String, int) - Method in class com.alipay.remoting.DefaultConnectionManager
-
- createConnection(Url) - Method in class com.alipay.remoting.connection.AbstractConnectionFactory
-
- createConnection(String, int, int) - Method in class com.alipay.remoting.connection.AbstractConnectionFactory
-
- createConnection(String, int, byte, int) - Method in class com.alipay.remoting.connection.AbstractConnectionFactory
-
- createConnection(Url) - Method in interface com.alipay.remoting.connection.ConnectionFactory
-
Create a connection use #BoltUrl
- createConnection(String, int, int) - Method in interface com.alipay.remoting.connection.ConnectionFactory
-
Create a connection according to the IP and port.
- createConnection(String, int, byte, int) - Method in interface com.alipay.remoting.connection.ConnectionFactory
-
Create a connection according to the IP and port.
- createConnectionAndHealIfNeed(Url) - Method in interface com.alipay.remoting.ConnectionManager
-
This method can create connection pool with connections initialized and check the number of connections.
- createConnectionAndHealIfNeed(Url) - Method in class com.alipay.remoting.DefaultConnectionManager
-
If no task cached, create one and initialize the connections.
- createConnectionClosedResponse(InetSocketAddress, String) - Method in interface com.alipay.remoting.CommandFactory
-
- createConnectionClosedResponse(InetSocketAddress) - Method in interface com.alipay.remoting.InvokeFuture
-
Create a remoting command response when connection closed
- createConnectionClosedResponse(InetSocketAddress) - Method in class com.alipay.remoting.rpc.DefaultInvokeFuture
-
- createConnectionClosedResponse(InetSocketAddress, String) - Method in class com.alipay.remoting.rpc.RpcCommandFactory
-
- createConnectionInManagement(Url) - Method in interface com.alipay.remoting.ConnectionManager
-
- createConnectionInManagement(Url) - Method in class com.alipay.remoting.DefaultConnectionManager
-
Always create connection in asynchronous way.
- createExceptionResponse(int, String) - Method in interface com.alipay.remoting.CommandFactory
-
- createExceptionResponse(int, Throwable, String) - Method in interface com.alipay.remoting.CommandFactory
-
- createExceptionResponse(int, ResponseStatus) - Method in interface com.alipay.remoting.CommandFactory
-
- createExceptionResponse(int, ResponseStatus, Throwable) - Method in interface com.alipay.remoting.CommandFactory
-
- createExceptionResponse(int, String) - Method in class com.alipay.remoting.rpc.RpcCommandFactory
-
- createExceptionResponse(int, Throwable, String) - Method in class com.alipay.remoting.rpc.RpcCommandFactory
-
- createExceptionResponse(int, ResponseStatus) - Method in class com.alipay.remoting.rpc.RpcCommandFactory
-
- createExceptionResponse(int, ResponseStatus, Throwable) - Method in class com.alipay.remoting.rpc.RpcCommandFactory
-
- createInvokeFuture(RemotingCommand, InvokeContext) - Method in class com.alipay.remoting.BaseRemoting
-
- createInvokeFuture(Connection, RemotingCommand, InvokeContext, InvokeCallback) - Method in class com.alipay.remoting.BaseRemoting
-
- createInvokeFuture(RemotingCommand, InvokeContext) - Method in class com.alipay.remoting.rpc.RpcRemoting
-
- createInvokeFuture(Connection, RemotingCommand, InvokeContext, InvokeCallback) - Method in class com.alipay.remoting.rpc.RpcRemoting
-
- createRequestCommand(Object) - Method in interface com.alipay.remoting.CommandFactory
-
create a request command with request object
- createRequestCommand(Object) - Method in class com.alipay.remoting.rpc.RpcCommandFactory
-
- createResponse(Object, RemotingCommand) - Method in interface com.alipay.remoting.CommandFactory
-
create a normal response with response object
- createResponse(Object, RemotingCommand) - Method in class com.alipay.remoting.rpc.RpcCommandFactory
-
- createSendFailedResponse(InetSocketAddress, Throwable) - Method in interface com.alipay.remoting.CommandFactory
-
- createSendFailedResponse(InetSocketAddress, Throwable) - Method in class com.alipay.remoting.rpc.RpcCommandFactory
-
- createStandaloneConnection(String, int, int) - Method in interface com.alipay.remoting.BoltClient
-
Create a stand alone connection using ip and port.
- createStandaloneConnection(String, int) - Method in interface com.alipay.remoting.BoltClient
-
Create a stand alone connection using address, address format example - 127.0.0.1:12200
Notice:
Each time you can this method, will create a new connection.
- createStandaloneConnection(String, int, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- createStandaloneConnection(String, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- createTimeoutResponse(InetSocketAddress) - Method in interface com.alipay.remoting.CommandFactory
-
- createTimeoutResponse(InetSocketAddress) - Method in class com.alipay.remoting.rpc.RpcCommandFactory
-
- cumulate(ByteBufAllocator, ByteBuf, ByteBuf) - Method in interface com.alipay.remoting.codec.AbstractBatchDecoder.Cumulator
-
Cumulate the given ByteBufs and return the ByteBuf that holds the cumulated bytes.
- CustomSerializer - Interface in com.alipay.remoting
-
Define custom serializers for command header and content.
- CustomSerializerManager - Class in com.alipay.remoting
-
Manage the custom serializer according to the class name.
- CustomSerializerManager() - Constructor for class com.alipay.remoting.CustomSerializerManager
-
- decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class com.alipay.remoting.codec.AbstractBatchDecoder
-
Decode the from one ByteBuf to an other.
- decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class com.alipay.remoting.codec.ProtocolCodeBasedDecoder
-
- decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in interface com.alipay.remoting.CommandDecoder
-
Decode bytes into object.
- decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class com.alipay.remoting.rpc.protocol.RpcCommandDecoder
-
- decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class com.alipay.remoting.rpc.protocol.RpcCommandDecoderV2
-
- decodeLast(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class com.alipay.remoting.codec.AbstractBatchDecoder
-
Is called one last time when the ChannelHandlerContext goes in-active.
- decodeProtocolCode(ByteBuf) - Method in class com.alipay.remoting.codec.ProtocolCodeBasedDecoder
-
decode the protocol code
- decodeProtocolVersion(ByteBuf) - Method in class com.alipay.remoting.codec.ProtocolCodeBasedDecoder
-
decode the protocol version
- decodeProtocolVersion(ByteBuf) - Method in class com.alipay.remoting.rpc.protocol.RpcProtocolDecoder
-
- decreaseRef() - Method in class com.alipay.remoting.Connection
-
decrease the reference count
- DEFAULT_CHARSET - Static variable in class com.alipay.remoting.config.Configs
-
Charset
- DEFAULT_CONN_NUM_PER_URL - Static variable in class com.alipay.remoting.config.Configs
-
default connection number per url
- DEFAULT_CONNECT_TIMEOUT - Static variable in class com.alipay.remoting.config.Configs
-
Default connect timeout value, time unit: ms
- DEFAULT_EXPIRE_TIME - Static variable in class com.alipay.remoting.constant.Constants
-
default expire time to remove connection pool, time unit: milliseconds
- DEFAULT_ILLEGAL_PROTOCOL_VERSION_LENGTH - Static variable in class com.alipay.remoting.codec.ProtocolCodeBasedDecoder
-
protocol version should be a positive number, we use -1 to represent illegal
- DEFAULT_PROTOCOL_CODE_LENGTH - Static variable in class com.alipay.remoting.rpc.protocol.RpcProtocolManager
-
- DEFAULT_PROTOCOL_VERSION_LENGTH - Static variable in class com.alipay.remoting.codec.ProtocolCodeBasedDecoder
-
by default, suggest design a single byte for protocol version.
- DEFAULT_RETRY_TIMES - Static variable in class com.alipay.remoting.constant.Constants
-
default retry times when failed to get result of FutureTask
- default_tp_keepalive_time() - Static method in class com.alipay.remoting.config.ConfigManager
-
- default_tp_max_size() - Static method in class com.alipay.remoting.config.ConfigManager
-
- default_tp_min_size() - Static method in class com.alipay.remoting.config.ConfigManager
-
- default_tp_queue_size() - Static method in class com.alipay.remoting.config.ConfigManager
-
- DefaultBizContext - Class in com.alipay.remoting
-
default biz context
- DefaultBizContext(RemotingContext) - Constructor for class com.alipay.remoting.DefaultBizContext
-
Constructor with RemotingContext
- DefaultClientConnectionManager - Class in com.alipay.remoting
-
Do some preparatory work in order to refactor the ConnectionManager in the next version.
- DefaultClientConnectionManager(ConnectionSelectStrategy, ConnectionFactory, ConnectionEventHandler, ConnectionEventListener) - Constructor for class com.alipay.remoting.DefaultClientConnectionManager
-
- DefaultConfigContainer - Class in com.alipay.remoting.config.configs
-
Deprecated.
- DefaultConfigContainer() - Constructor for class com.alipay.remoting.config.configs.DefaultConfigContainer
-
Deprecated.
- DefaultConnectionFactory - Class in com.alipay.remoting.connection
-
Default connection factory.
- DefaultConnectionFactory(Codec, ChannelHandler, ChannelHandler, Configuration) - Constructor for class com.alipay.remoting.connection.DefaultConnectionFactory
-
- DefaultConnectionManager - Class in com.alipay.remoting
-
Abstract implementation of connection manager
- DefaultConnectionManager(ConnectionSelectStrategy) - Constructor for class com.alipay.remoting.DefaultConnectionManager
-
Construct with parameters.
- DefaultConnectionManager(ConnectionSelectStrategy, ConnectionFactory) - Constructor for class com.alipay.remoting.DefaultConnectionManager
-
Construct with parameters.
- DefaultConnectionManager(ConnectionFactory, RemotingAddressParser, ConnectionEventHandler) - Constructor for class com.alipay.remoting.DefaultConnectionManager
-
Construct with parameters.
- DefaultConnectionManager(ConnectionSelectStrategy, ConnectionFactory, ConnectionEventHandler, ConnectionEventListener) - Constructor for class com.alipay.remoting.DefaultConnectionManager
-
Construct with parameters.
- DefaultConnectionMonitor - Class in com.alipay.remoting
-
A default connection monitor that handle connections with strategies
- DefaultConnectionMonitor(ConnectionMonitorStrategy, ConnectionManager) - Constructor for class com.alipay.remoting.DefaultConnectionMonitor
-
- DefaultCustomSerializer - Class in com.alipay.remoting
-
The default custom serializer, which does nothing.
- DefaultCustomSerializer() - Constructor for class com.alipay.remoting.DefaultCustomSerializer
-
- DefaultInvokeFuture - Class in com.alipay.remoting.rpc
-
The default implementation of InvokeFuture.
- DefaultInvokeFuture(int, InvokeCallbackListener, InvokeCallback, byte, CommandFactory) - Constructor for class com.alipay.remoting.rpc.DefaultInvokeFuture
-
Constructor.
- DefaultInvokeFuture(int, InvokeCallbackListener, InvokeCallback, byte, CommandFactory, InvokeContext) - Constructor for class com.alipay.remoting.rpc.DefaultInvokeFuture
-
Constructor.
- defaultProtocolCode - Variable in class com.alipay.remoting.codec.ProtocolCodeBasedEncoder
-
default protocol code
- DefaultServerConnectionManager - Class in com.alipay.remoting
-
Do some preparatory work in order to refactor the ConnectionManager in the next version.
- DefaultServerConnectionManager(ConnectionSelectStrategy) - Constructor for class com.alipay.remoting.DefaultServerConnectionManager
-
- defaultValue() - Method in class com.alipay.remoting.config.BoltOption
-
- DeserializationException - Exception in com.alipay.remoting.exception
-
Exception when deserialize failed
- DeserializationException() - Constructor for exception com.alipay.remoting.exception.DeserializationException
-
Constructor.
- DeserializationException(String) - Constructor for exception com.alipay.remoting.exception.DeserializationException
-
Constructor.
- DeserializationException(String, boolean) - Constructor for exception com.alipay.remoting.exception.DeserializationException
-
Constructor.
- DeserializationException(String, Throwable) - Constructor for exception com.alipay.remoting.exception.DeserializationException
-
Constructor.
- DeserializationException(String, Throwable, boolean) - Constructor for exception com.alipay.remoting.exception.DeserializationException
-
Constructor.
- deserialize() - Method in interface com.alipay.remoting.RemotingCommand
-
Deserialize all parts of remoting command
- deserialize() - Method in class com.alipay.remoting.rpc.RpcCommand
-
Deserialize the class header and content.
- deserialize(long) - Method in class com.alipay.remoting.rpc.RpcCommand
-
Deserialize according to mask.
- deserialize(byte[], String) - Method in class com.alipay.remoting.serialization.HessianSerializer
-
- deserialize(byte[], String) - Method in interface com.alipay.remoting.serialization.Serializer
-
Decode bytes into Object.
- DESERIALIZE_ALL - Static variable in class com.alipay.remoting.rpc.protocol.RpcDeserializeLevel
-
deserialize clazz, header, contents all three parts of rpc command
- DESERIALIZE_CLAZZ - Static variable in class com.alipay.remoting.rpc.protocol.RpcDeserializeLevel
-
deserialize only the clazz part of rpc command
- DESERIALIZE_HEADER - Static variable in class com.alipay.remoting.rpc.protocol.RpcDeserializeLevel
-
deserialize both header and clazz parts of rpc command
- deserializeClazz() - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
- deserializeClazz() - Method in class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
- deserializeClazz() - Method in class com.alipay.remoting.rpc.RpcCommand
-
Deserialize the content class.
- deserializeContent(T) - Method in interface com.alipay.remoting.CustomSerializer
-
Deserialize the content of RequestCommand.
- deserializeContent(T, InvokeContext) - Method in interface com.alipay.remoting.CustomSerializer
-
Deserialize the content of ResponseCommand.
- deserializeContent(T) - Method in class com.alipay.remoting.DefaultCustomSerializer
-
- deserializeContent(T, InvokeContext) - Method in class com.alipay.remoting.DefaultCustomSerializer
-
- deserializeContent(InvokeContext) - Method in interface com.alipay.remoting.RemotingCommand
-
Deserialize content of remoting command
- deserializeContent(InvokeContext) - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
- deserializeContent(InvokeContext) - Method in class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
- deserializeContent(InvokeContext) - Method in class com.alipay.remoting.rpc.RpcCommand
-
Deserialize the content.
- deserializeHeader(T) - Method in interface com.alipay.remoting.CustomSerializer
-
Deserialize the header of RequestCommand.
- deserializeHeader(T, InvokeContext) - Method in interface com.alipay.remoting.CustomSerializer
-
Deserialize the header of ResponseCommand.
- deserializeHeader(T) - Method in class com.alipay.remoting.DefaultCustomSerializer
-
- deserializeHeader(T, InvokeContext) - Method in class com.alipay.remoting.DefaultCustomSerializer
-
- deserializeHeader(InvokeContext) - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
- deserializeHeader(InvokeContext) - Method in class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
- deserializeHeader(InvokeContext) - Method in class com.alipay.remoting.rpc.RpcCommand
-
Deserialize the header.
- destroy() - Method in class com.alipay.remoting.DefaultConnectionMonitor
-
Deprecated.
- disableConnectionMonitorSwitch() - Method in interface com.alipay.remoting.BoltClient
-
disable connection monitor switch off
Notice: This api should be called before
RpcClient.init()
- disableConnectionMonitorSwitch() - Method in class com.alipay.remoting.rpc.RpcClient
-
Deprecated.
- disableConnHeartbeat(String) - Method in interface com.alipay.remoting.BoltClient
-
Disable heart beat for a certain connection.
- disableConnHeartbeat(Url) - Method in interface com.alipay.remoting.BoltClient
-
Disable heart beat for a certain connection.
- disableConnHeartbeat(String) - Method in class com.alipay.remoting.rpc.RpcClient
-
- disableConnHeartbeat(Url) - Method in class com.alipay.remoting.rpc.RpcClient
-
- disableHeartbeat(Connection) - Method in interface com.alipay.remoting.ConnectionHeartbeatManager
-
disable heart beat for a certain connection
- disableHeartbeat(Connection) - Method in class com.alipay.remoting.DefaultConnectionManager
-
- disableReconnect(Url) - Method in class com.alipay.remoting.ReconnectManager
-
- disableReconnect(Url) - Method in interface com.alipay.remoting.Reconnector
-
Disable reconnect to the target url.
- disableReconnectSwith() - Method in interface com.alipay.remoting.BoltClient
-
disable connection reconnect switch off
Notice: This api should be called before
RpcClient.init()
- disableReconnectSwith() - Method in class com.alipay.remoting.rpc.RpcClient
-
Deprecated.
- discardSomeReadBytes() - Method in class com.alipay.remoting.codec.AbstractBatchDecoder
-
- disconnect(ChannelHandlerContext, ChannelPromise) - Method in class com.alipay.remoting.ConnectionEventHandler
-
- dispatch_msg_list_in_default_executor() - Static method in class com.alipay.remoting.rpc.RpcConfigManager
-
- DISPATCH_MSG_LIST_IN_DEFAULT_EXECUTOR - Static variable in class com.alipay.remoting.rpc.RpcConfigs
-
Whether to dispatch message list in default executor.
- DISPATCH_MSG_LIST_IN_DEFAULT_EXECUTOR_DEFAULT - Static variable in class com.alipay.remoting.rpc.RpcConfigs
-
- doCreateConnection(String, int, int) - Method in class com.alipay.remoting.connection.AbstractConnectionFactory
-
- doInit() - Method in class com.alipay.remoting.AbstractRemotingServer
-
- doInit() - Method in class com.alipay.remoting.rpc.RpcServer
-
- doProcess(RemotingContext, T) - Method in class com.alipay.remoting.AbstractRemotingProcessor
-
Do the process.
- doProcess(RemotingContext, RemotingCommand) - Method in class com.alipay.remoting.rpc.protocol.RpcHeartBeatProcessor
-
- doProcess(RemotingContext, RpcRequestCommand) - Method in class com.alipay.remoting.rpc.protocol.RpcRequestProcessor
-
- doProcess(RemotingContext, RemotingCommand) - Method in class com.alipay.remoting.rpc.protocol.RpcResponseProcessor
-
- doStart() - Method in class com.alipay.remoting.AbstractRemotingServer
-
- doStart() - Method in class com.alipay.remoting.rpc.RpcServer
-
- doStop() - Method in class com.alipay.remoting.AbstractRemotingServer
-
- doStop() - Method in class com.alipay.remoting.rpc.RpcServer
-
Notice: only RpcServer#option(BoltServerOption.SERVER_MANAGE_CONNECTION_SWITCH, true) switch on, will close all connections.
- get(String) - Method in interface com.alipay.remoting.BizContext
-
get value
- get(ConfigType, ConfigItem) - Method in interface com.alipay.remoting.config.configs.ConfigContainer
-
Deprecated.
try to get config value using config type and config item.
- get(ConfigType, ConfigItem) - Method in class com.alipay.remoting.config.configs.DefaultConfigContainer
-
Deprecated.
- get(String) - Method in interface com.alipay.remoting.ConnectionManager
-
- get() - Method in class com.alipay.remoting.ConnectionPool
-
get a connection
- get(String) - Method in class com.alipay.remoting.DefaultBizContext
-
- get(String) - Method in class com.alipay.remoting.DefaultConnectionManager
-
- get(String) - Method in class com.alipay.remoting.InvokeContext
-
get
- get(String, T) - Method in class com.alipay.remoting.InvokeContext
-
get and use default if not found
- get(int) - Method in class com.alipay.remoting.rpc.RpcResponseFuture
-
get result with timeout specified
if request done, resolve normal responseObject
if request not done, throws InvokeTimeoutException
- get() - Method in class com.alipay.remoting.rpc.RpcResponseFuture
-
- getAddressParser() - Method in interface com.alipay.remoting.BoltClient
-
Getter method for property addressParser.
- getAddressParser() - Method in class com.alipay.remoting.DefaultConnectionManager
-
Getter method for property addressParser.
- getAddressParser() - Method in class com.alipay.remoting.rpc.RpcClient
-
- getAddressParser() - Method in class com.alipay.remoting.rpc.RpcServer
-
Getter method for property addressParser.
- getAfterRun() - Method in class com.alipay.remoting.util.RunStateRecordedFutureTask
-
- getAll(String) - Method in interface com.alipay.remoting.ConnectionManager
-
- getAll() - Method in interface com.alipay.remoting.ConnectionManager
-
Get all connections of all poolKey.
- getAll() - Method in class com.alipay.remoting.ConnectionPool
-
get all connections
- getAll(String) - Method in class com.alipay.remoting.DefaultConnectionManager
-
- getAll() - Method in class com.alipay.remoting.DefaultConnectionManager
-
Get all connections of all poolKey.
- getAllManagedConnections() - Method in interface com.alipay.remoting.BoltClient
-
get all connections managed by rpc client
- getAllManagedConnections() - Method in class com.alipay.remoting.rpc.RpcClient
-
- getAndClear(Channel, Integer) - Static method in class com.alipay.remoting.util.ThreadLocalArriveTimeHolder
-
- getAndCreateIfAbsent(Url) - Method in interface com.alipay.remoting.ConnectionManager
-
- getAndCreateIfAbsent(Url) - Method in class com.alipay.remoting.DefaultConnectionManager
-
If no task cached, create one and initialize the connections.
- getAppClassLoader() - Method in interface com.alipay.remoting.InvokeFuture
-
Get application classloader.
- getAppClassLoader() - Method in class com.alipay.remoting.rpc.DefaultInvokeFuture
-
- getArriveBodyTimeInNano() - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
- getArriveHeaderTimeInNano() - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
- getArriveTime() - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
Getter method for property arriveTime.
- getArriveTimestamp() - Method in interface com.alipay.remoting.BizContext
-
get the arrive time stamp
- getArriveTimestamp() - Method in class com.alipay.remoting.DefaultBizContext
-
get the arrive time stamp
- getArriveTimestamp() - Method in class com.alipay.remoting.RemotingContext
-
Getter method for property arriveTimestamp.
- getAttribute(String) - Method in class com.alipay.remoting.Connection
-
Get attribute.
- getBeforeEnterQueueTime() - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
- getBizClassLoader() - Method in class com.alipay.remoting.rpc.protocol.AbstractUserProcessor
-
- getBizClassLoader() - Method in interface com.alipay.remoting.rpc.protocol.UserProcessor
-
Get business class loader
- getBool(String, String) - Static method in class com.alipay.remoting.config.ConfigManager
-
- getByte(String, String) - Static method in class com.alipay.remoting.config.ConfigManager
-
- getCause() - Method in interface com.alipay.remoting.InvokeFuture
-
Get the cause of exception of the future.
- getCause() - Method in class com.alipay.remoting.rpc.DefaultInvokeFuture
-
- getCause() - Method in class com.alipay.remoting.rpc.ResponseCommand
-
Getter method for property cause.
- getChannel() - Method in class com.alipay.remoting.Connection
-
Get the netty channel of the connection.
- getChannelContext() - Method in class com.alipay.remoting.RemotingContext
-
Get the channel handler context.
- getClazz() - Method in class com.alipay.remoting.rpc.RpcCommand
-
- getClazzLength() - Method in class com.alipay.remoting.rpc.RpcCommand
-
- getClientSocketChannelClass() - Static method in class com.alipay.remoting.util.NettyEventLoopUtil
-
- getClientTimeout() - Method in interface com.alipay.remoting.BizContext
-
get the timeout value from rpc client.
- getClientTimeout() - Method in class com.alipay.remoting.DefaultBizContext
-
get the timeout value from rpc client.
- getCmdCode() - Method in interface com.alipay.remoting.RemotingCommand
-
Get the command code for this command
- getCmdCode() - Method in class com.alipay.remoting.rpc.RpcCommand
-
- getCommandFactory() - Method in class com.alipay.remoting.AbstractRemotingProcessor
-
- getCommandFactory() - Method in class com.alipay.remoting.BaseRemoting
-
Deprecated.
- getCommandFactory(Connection) - Method in class com.alipay.remoting.BaseRemoting
-
- getCommandFactory(ProtocolCode) - Method in class com.alipay.remoting.BaseRemoting
-
- getCommandFactory() - Method in interface com.alipay.remoting.Protocol
-
Get the command factory for the protocol.
- getCommandFactory() - Method in class com.alipay.remoting.rpc.protocol.RpcProtocol
-
- getCommandFactory() - Method in class com.alipay.remoting.rpc.protocol.RpcProtocolV2
-
- getCommandHandler() - Method in interface com.alipay.remoting.Protocol
-
Get the command handler for the protocol.
- getCommandHandler() - Method in class com.alipay.remoting.rpc.protocol.RpcProtocol
-
- getCommandHandler() - Method in class com.alipay.remoting.rpc.protocol.RpcProtocolV2
-
- getConnection() - Method in interface com.alipay.remoting.BizContext
-
get the connection of this request
- getConnection(String, int) - Method in interface com.alipay.remoting.BoltClient
-
Get a connection using address, address format example - 127.0.0.1:12200?
- getConnection(Url, int) - Method in interface com.alipay.remoting.BoltClient
-
Get a connection using a
Url.
- getConnection() - Method in class com.alipay.remoting.DefaultBizContext
-
- getConnection() - Method in class com.alipay.remoting.RemotingContext
-
Get connection from channel
- getConnection(String, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- getConnection(Url, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- getConnectionAndInitInvokeContext(Url, InvokeContext) - Method in class com.alipay.remoting.rpc.RpcClientRemoting
-
Get connection and set init invokeContext if invokeContext not null
- getConnectionEventHandler() - Method in class com.alipay.remoting.DefaultConnectionManager
-
Getter method for property connectionEventHandler.
- getConnectionEventListener() - Method in class com.alipay.remoting.ConnectionEventHandler
-
- getConnectionEventListener() - Method in class com.alipay.remoting.DefaultConnectionManager
-
Getter method for property connectionEventListener.
- getConnectionFactory() - Method in class com.alipay.remoting.DefaultConnectionManager
-
Getter method for property connctionFactory.
- getConnectionFromChannel(Channel) - Static method in class com.alipay.remoting.util.ConnectionUtil
-
- getConnectionManager() - Method in interface com.alipay.remoting.BoltClient
-
Getter method for property connectionManager.
- getConnectionManager() - Method in class com.alipay.remoting.ConnectionEventHandler
-
- getConnectionManager() - Method in class com.alipay.remoting.rpc.RpcClient
-
- getConnectionManager() - Method in class com.alipay.remoting.rpc.RpcServer
-
Getter method for property connectionManager.
- getConnectionSelectStrategy() - Method in class com.alipay.remoting.DefaultConnectionManager
-
Getter method for property connectionSelectStrategy.
- getConnectTimeout() - Method in class com.alipay.remoting.Url
-
- getConnNum() - Method in class com.alipay.remoting.Url
-
- getConnPools() - Method in class com.alipay.remoting.DefaultConnectionManager
-
Getter method for property connPools.
- getContent() - Method in class com.alipay.remoting.rpc.RpcCommand
-
- getContentLength() - Method in class com.alipay.remoting.rpc.RpcCommand
-
- getCustomSerializer(String) - Static method in class com.alipay.remoting.CustomSerializerManager
-
Get the custom serializer for class name.
- getCustomSerializer(CommandCode) - Static method in class com.alipay.remoting.CustomSerializerManager
-
Get the custom serializer for command code.
- getCustomSerializer() - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
Getter method for property customSerializer.
- getCustomSerializer() - Method in class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
Getter method for property customSerializer.
- getDecoder() - Method in interface com.alipay.remoting.Protocol
-
Get the decoder for the protocol.
- getDecoder() - Method in class com.alipay.remoting.rpc.protocol.RpcProtocol
-
- getDecoder() - Method in class com.alipay.remoting.rpc.protocol.RpcProtocolV2
-
- getDefaultExecutor() - Method in interface com.alipay.remoting.CommandHandler
-
Get default executor for the handler.
- getDefaultExecutor() - Method in class com.alipay.remoting.ProcessorManager
-
Getter method for property defaultExecutor.
- getDefaultExecutor() - Method in class com.alipay.remoting.rpc.protocol.RpcCommandHandler
-
- getEncoder() - Method in interface com.alipay.remoting.Protocol
-
Get the newEncoder for the protocol.
- getEncoder() - Method in class com.alipay.remoting.rpc.protocol.RpcProtocol
-
- getEncoder() - Method in class com.alipay.remoting.rpc.protocol.RpcProtocolV2
-
- getErrorMsg() - Method in class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
Getter method for property errorMsg.
- getExecutor() - Method in class com.alipay.remoting.AbstractRemotingProcessor
-
Getter method for property executor.
- getExecutor() - Method in interface com.alipay.remoting.InvokeCallback
-
User defined executor.
- getExecutor() - Method in interface com.alipay.remoting.RemotingProcessor
-
Get the executor.
- getExecutor() - Method in class com.alipay.remoting.rpc.protocol.AbstractUserProcessor
-
By default return null.
- getExecutor() - Method in interface com.alipay.remoting.rpc.protocol.UserProcessor
-
Get user executor.
- getExecutorSelector() - Method in class com.alipay.remoting.rpc.protocol.AbstractUserProcessor
-
- getExecutorSelector() - Method in interface com.alipay.remoting.rpc.protocol.UserProcessor
-
Use this method to get the executor selector.
- getFirstByte() - Method in class com.alipay.remoting.ProtocolCode
-
get the first single byte if your protocol code is single code.
- getFutureTaskResult(RunStateRecordedFutureTask<T>, Logger) - Static method in class com.alipay.remoting.util.FutureTaskUtil
-
get the result of a future task
Notice: the run method of this task should have been called at first.
- getGroupRequestCallBack(Integer, Channel) - Static method in class com.alipay.remoting.util.ConnectionUtil
-
- getHeader() - Method in class com.alipay.remoting.rpc.RpcCommand
-
- getHeaderLength() - Method in class com.alipay.remoting.rpc.RpcCommand
-
- getHeartbeatTrigger() - Method in interface com.alipay.remoting.Protocol
-
Get the heartbeat trigger for the protocol.
- getHeartbeatTrigger() - Method in class com.alipay.remoting.rpc.protocol.RpcProtocol
-
- getHeartbeatTrigger() - Method in class com.alipay.remoting.rpc.protocol.RpcProtocolV2
-
- getId() - Method in interface com.alipay.remoting.RemotingCommand
-
Get the id of the command
- getId() - Method in class com.alipay.remoting.rpc.RpcCommand
-
- getInt(String, String) - Static method in class com.alipay.remoting.config.ConfigManager
-
- getInteger(String) - Static method in class com.alipay.remoting.config.ConfigManager
-
- getInvokeCallback() - Method in interface com.alipay.remoting.InvokeFuture
-
Get the application callback of the future.
- getInvokeCallback() - Method in class com.alipay.remoting.rpc.DefaultInvokeFuture
-
- getInvokeContext() - Method in interface com.alipay.remoting.BizContext
-
get invoke context.
- getInvokeContext() - Method in class com.alipay.remoting.DefaultBizContext
-
- getInvokeContext() - Method in interface com.alipay.remoting.InvokeFuture
-
Get invoke context.
- getInvokeContext() - Method in interface com.alipay.remoting.RemotingCommand
-
Get invoke context for this command
- getInvokeContext() - Method in class com.alipay.remoting.RemotingContext
-
Getter method for property invokeContext.
- getInvokeContext() - Method in class com.alipay.remoting.rpc.DefaultInvokeFuture
-
- getInvokeContext() - Method in class com.alipay.remoting.rpc.RpcCommand
-
- getInvokeFuture(int) - Method in class com.alipay.remoting.Connection
-
Get the InvokeFuture with invokeId of id.
- getInvokeFutureMap() - Method in class com.alipay.remoting.Connection
-
Getter method for property invokeFutureMap.
- getIp() - Method in class com.alipay.remoting.Url
-
- getLastAccessTimestamp() - Method in class com.alipay.remoting.ConnectionPool
-
Getter method for property lastAccessTimestamp.
- getLocalAddress() - Method in class com.alipay.remoting.Connection
-
Get the address of the local peer.
- getLocalIP() - Method in class com.alipay.remoting.Connection
-
Get the local IP.
- getLocalPort() - Method in class com.alipay.remoting.Connection
-
Get the local port.
- getLogger(Class<?>) - Static method in class com.alipay.remoting.log.BoltLoggerFactory
-
- getLogger(String) - Static method in class com.alipay.remoting.log.BoltLoggerFactory
-
- getLong(String, String) - Static method in class com.alipay.remoting.config.ConfigManager
-
- getOriginUrl() - Method in class com.alipay.remoting.Url
-
- getPoolKeys() - Method in class com.alipay.remoting.Connection
-
get all pool keys
- getPort() - Method in class com.alipay.remoting.Url
-
- getProcessor(CommandCode) - Method in class com.alipay.remoting.ProcessorManager
-
Get the specific processor with command code of cmdCode if registered, otherwise the default processor is returned.
- getProperties() - Method in class com.alipay.remoting.Url
-
- getProperty(String) - Method in class com.alipay.remoting.Url
-
Get property value according to property key
- getProtocol(ProtocolCode) - Static method in class com.alipay.remoting.ProtocolManager
-
- getProtocol() - Method in class com.alipay.remoting.Url
-
- getProtocolCode() - Method in interface com.alipay.remoting.InvokeFuture
-
Get the protocol code of command.
- getProtocolCode() - Method in interface com.alipay.remoting.RemotingCommand
-
Get the code of the protocol that this command belongs to
- getProtocolCode() - Method in class com.alipay.remoting.rpc.DefaultInvokeFuture
-
- getProtocolCode() - Method in class com.alipay.remoting.rpc.RpcCommand
-
- getProtocolSwitch() - Method in interface com.alipay.remoting.RemotingCommand
-
Get the protocol switch status for this command
- getProtocolSwitch() - Method in class com.alipay.remoting.rpc.RpcCommand
-
- getRemoteAddress() - Method in interface com.alipay.remoting.BizContext
-
get remote address
- getRemoteAddress() - Method in class com.alipay.remoting.Connection
-
Get the address of the remote peer.
- getRemoteAddress() - Method in class com.alipay.remoting.DefaultBizContext
-
- getRemoteAddress() - Method in interface com.alipay.remoting.InvokeCallbackListener
-
Get the remote address.
- getRemoteAddress() - Method in class com.alipay.remoting.rpc.RpcInvokeCallbackListener
-
- getRemoteHost() - Method in interface com.alipay.remoting.BizContext
-
get remote host ip
- getRemoteHost() - Method in class com.alipay.remoting.DefaultBizContext
-
- getRemoteIP() - Method in class com.alipay.remoting.Connection
-
Get the remote IP.
- getRemotePort() - Method in interface com.alipay.remoting.BizContext
-
get remote port
- getRemotePort() - Method in class com.alipay.remoting.Connection
-
Get the remote port.
- getRemotePort() - Method in class com.alipay.remoting.DefaultBizContext
-
- getRemotingCtx() - Method in class com.alipay.remoting.DefaultBizContext
-
get remoting context
- getRequestClass() - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
Getter method for property requestClass.
- getRequestHeader() - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
Getter method for property requestHeader.
- getRequestHeaderLength() - Static method in class com.alipay.remoting.rpc.protocol.RpcProtocol
-
Get the length of request header.
- getRequestHeaderLength() - Static method in class com.alipay.remoting.rpc.protocol.RpcProtocolV2
-
- getRequestObject() - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
Getter method for property requestObject.
- getResponseClass() - Method in class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
Getter method for property responseClass.
- getResponseHeader() - Method in class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
Getter method for property responseHeader.
- getResponseHeaderLength() - Static method in class com.alipay.remoting.rpc.protocol.RpcProtocol
-
Get the length of response header.
- getResponseHeaderLength() - Static method in class com.alipay.remoting.rpc.protocol.RpcProtocolV2
-
- getResponseHost() - Method in class com.alipay.remoting.rpc.ResponseCommand
-
Getter method for property responseHost.
- getResponseObject() - Method in class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
Getter method for property responseObject.
- getResponseStatus() - Method in class com.alipay.remoting.rpc.ResponseCommand
-
Getter method for property responseStatus.
- getResponseTimeMillis() - Method in class com.alipay.remoting.rpc.ResponseCommand
-
Getter method for property responseTimeMillis.
- getSerializer() - Method in interface com.alipay.remoting.RemotingCommand
-
Get serializer type for this command
- getSerializer() - Method in class com.alipay.remoting.rpc.RpcCommand
-
- getSerializer(int) - Static method in class com.alipay.remoting.serialization.SerializerManager
-
- getServerSocketChannelClass() - Static method in class com.alipay.remoting.util.NettyEventLoopUtil
-
- getString(String, String) - Static method in class com.alipay.remoting.config.ConfigManager
-
- getTimeout() - Method in class com.alipay.remoting.RemotingContext
-
Getter method for property timeout.
- getTimeout() - Method in class com.alipay.remoting.rpc.RequestCommand
-
Getter method for property timeout.
- getTimer() - Static method in class com.alipay.remoting.TimerHolder
-
Get a singleton instance of Timer.
- getType() - Method in class com.alipay.remoting.rpc.RpcCommand
-
- getUniqueKey() - Method in class com.alipay.remoting.Url
-
- getUrl() - Method in class com.alipay.remoting.Connection
-
Getter method for property url.
- getUserProcessor(String) - Method in class com.alipay.remoting.RemotingContext
-
Get user processor for class name.
- getValue() - Method in enum com.alipay.remoting.ResponseStatus
-
Convert to short.
- getVersion() - Method in class com.alipay.remoting.rpc.RpcCommand
-
- getVersion() - Method in class com.alipay.remoting.Url
-
- GlobalSwitch - Class in com.alipay.remoting.config.switches
-
Deprecated.
- GlobalSwitch() - Constructor for class com.alipay.remoting.config.switches.GlobalSwitch
-
Deprecated.
Init with system default value
if settings exist by system property then use system property at first;
if no settings exist by system property then use default value in
Configs
All these settings can be overwrite by user api settings.
- IDGenerator - Class in com.alipay.remoting.util
-
IDGenerator is used for generating request id in integer form.
- IDGenerator() - Constructor for class com.alipay.remoting.util.IDGenerator
-
- increaseRef() - Method in class com.alipay.remoting.Connection
-
increase the reference count
- init() - Method in class com.alipay.remoting.AbstractRemotingServer
-
Deprecated.
- init(ConnectionEventHandler) - Method in class com.alipay.remoting.connection.AbstractConnectionFactory
-
- init(ConnectionEventHandler) - Method in interface com.alipay.remoting.connection.ConnectionFactory
-
Initialize the factory.
- init() - Method in interface com.alipay.remoting.ConnectionManager
-
Deprecated.
- init() - Method in class com.alipay.remoting.DefaultConnectionManager
-
Deprecated.
- init() - Method in interface com.alipay.remoting.RemotingServer
-
Deprecated.
- init() - Method in class com.alipay.remoting.rpc.RpcClient
-
Deprecated.
- INITIAL_SIZE - Static variable in class com.alipay.remoting.InvokeContext
-
- initProtocols() - Static method in class com.alipay.remoting.rpc.protocol.RpcProtocolManager
-
- initRpcRemoting() - Method in class com.alipay.remoting.rpc.RpcServer
-
init rpc remoting
- initUrlArgs(Url) - Method in interface com.alipay.remoting.RemotingAddressParser
-
- initUrlArgs(Url) - Method in class com.alipay.remoting.rpc.RpcAddressParser
-
- initWriteBufferWaterMark(int, int) - Method in class com.alipay.remoting.AbstractBoltClient
-
- initWriteBufferWaterMark(int, int) - Method in class com.alipay.remoting.AbstractRemotingServer
-
- initWriteBufferWaterMark(int, int) - Method in interface com.alipay.remoting.config.ConfigurableInstance
-
Deprecated.
- interest() - Method in class com.alipay.remoting.rpc.protocol.AbstractMultiInterestUserProcessor
-
do not need to implement this method because of the multiple interests
- interest() - Method in class com.alipay.remoting.rpc.protocol.AsyncUserProcessor
-
- interest() - Method in class com.alipay.remoting.rpc.protocol.SyncUserProcessor
-
- interest() - Method in interface com.alipay.remoting.rpc.protocol.UserProcessor
-
The class name of user request.
- internalBuffer() - Method in class com.alipay.remoting.codec.AbstractBatchDecoder
-
Returns the internal cumulative buffer of this decoder.
- InvokeCallback - Interface in com.alipay.remoting
-
Invoke callback.
- InvokeCallbackListener - Interface in com.alipay.remoting
-
Listener to listen response and invoke callback.
- InvokeContext - Class in com.alipay.remoting
-
Invoke context
- InvokeContext() - Constructor for class com.alipay.remoting.InvokeContext
-
default construct
- InvokeException - Exception in com.alipay.remoting.rpc.exception
-
Exception when invoke failed
- InvokeException() - Constructor for exception com.alipay.remoting.rpc.exception.InvokeException
-
Default constructor.
- InvokeException(String) - Constructor for exception com.alipay.remoting.rpc.exception.InvokeException
-
- InvokeException(String, Throwable) - Constructor for exception com.alipay.remoting.rpc.exception.InvokeException
-
- InvokeFuture - Interface in com.alipay.remoting
-
The future of an invocation.
- invokeId() - Method in interface com.alipay.remoting.InvokeFuture
-
Get the id of the invocation.
- invokeId() - Method in class com.alipay.remoting.rpc.DefaultInvokeFuture
-
- InvokeSendFailedException - Exception in com.alipay.remoting.rpc.exception
-
Exception when invoke send failed
- InvokeSendFailedException() - Constructor for exception com.alipay.remoting.rpc.exception.InvokeSendFailedException
-
Default constructor.
- InvokeSendFailedException(String) - Constructor for exception com.alipay.remoting.rpc.exception.InvokeSendFailedException
-
- InvokeSendFailedException(String, Throwable) - Constructor for exception com.alipay.remoting.rpc.exception.InvokeSendFailedException
-
- InvokeServerBusyException - Exception in com.alipay.remoting.rpc.exception
-
Exception when thread pool busy of process server
- InvokeServerBusyException() - Constructor for exception com.alipay.remoting.rpc.exception.InvokeServerBusyException
-
Default constructor.
- InvokeServerBusyException(String) - Constructor for exception com.alipay.remoting.rpc.exception.InvokeServerBusyException
-
- InvokeServerBusyException(String, Throwable) - Constructor for exception com.alipay.remoting.rpc.exception.InvokeServerBusyException
-
- InvokeServerException - Exception in com.alipay.remoting.rpc.exception
-
Server exception caught when invoking
- InvokeServerException() - Constructor for exception com.alipay.remoting.rpc.exception.InvokeServerException
-
Default constructor.
- InvokeServerException(String) - Constructor for exception com.alipay.remoting.rpc.exception.InvokeServerException
-
- InvokeServerException(String, Throwable) - Constructor for exception com.alipay.remoting.rpc.exception.InvokeServerException
-
- invokeSync(Connection, RemotingCommand, int) - Method in class com.alipay.remoting.BaseRemoting
-
Synchronous invocation
- invokeSync(String, Object, int) - Method in interface com.alipay.remoting.BoltClient
-
Synchronous invocation using a string address, address format example - 127.0.0.1:12200?
- invokeSync(String, Object, InvokeContext, int) - Method in interface com.alipay.remoting.BoltClient
-
- invokeSync(Url, Object, int) - Method in interface com.alipay.remoting.BoltClient
-
Synchronous invocation using a parsed
Url
Notice:
DO NOT modify the request object concurrently when this method is called.
- invokeSync(Url, Object, InvokeContext, int) - Method in interface com.alipay.remoting.BoltClient
-
- invokeSync(Connection, Object, int) - Method in interface com.alipay.remoting.BoltClient
-
Synchronous invocation using a
Connection
Notice:
DO NOT modify the request object concurrently when this method is called.
- invokeSync(Connection, Object, InvokeContext, int) - Method in interface com.alipay.remoting.BoltClient
-
- invokeSync(String, Object, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeSync(String, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeSync(Url, Object, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeSync(Url, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeSync(Connection, Object, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeSync(Connection, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeSync(Url, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcClientRemoting
-
- invokeSync(String, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcRemoting
-
Synchronous rpc invocation.
- invokeSync(Url, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcRemoting
-
Synchronous rpc invocation.
- invokeSync(Connection, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcRemoting
-
Synchronous rpc invocation.
- invokeSync(String, Object, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
Synchronous invocation using a string address, address format example - 127.0.0.1:12200?
- invokeSync(String, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
- invokeSync(Url, Object, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
Synchronous invocation using a parsed
Url
Notice:
DO NOT modify the request object concurrently when this method is called.
- invokeSync(Url, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
- invokeSync(Connection, Object, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
Synchronous invocation using a
Connection
Notice:
DO NOT modify the request object concurrently when this method is called.
- invokeSync(Connection, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
- invokeSync(Url, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcServerRemoting
-
- InvokeTimeoutException - Exception in com.alipay.remoting.rpc.exception
-
Exception when invoke timeout
- InvokeTimeoutException() - Constructor for exception com.alipay.remoting.rpc.exception.InvokeTimeoutException
-
Default constructor.
- InvokeTimeoutException(String) - Constructor for exception com.alipay.remoting.rpc.exception.InvokeTimeoutException
-
Constructor.
- InvokeTimeoutException(String, Throwable) - Constructor for exception com.alipay.remoting.rpc.exception.InvokeTimeoutException
-
Constructor.
- invokeWithCallback(Connection, RemotingCommand, InvokeCallback, int) - Method in class com.alipay.remoting.BaseRemoting
-
Invocation with callback.
- invokeWithCallback(String, Object, InvokeCallback, int) - Method in interface com.alipay.remoting.BoltClient
-
Callback invocation using a string address, address format example - 127.0.0.1:12200?
- invokeWithCallback(String, Object, InvokeContext, InvokeCallback, int) - Method in interface com.alipay.remoting.BoltClient
-
- invokeWithCallback(Url, Object, InvokeCallback, int) - Method in interface com.alipay.remoting.BoltClient
-
Callback invocation using a parsed
Url
You can specify an implementation of
InvokeCallback to get the result.
- invokeWithCallback(Url, Object, InvokeContext, InvokeCallback, int) - Method in interface com.alipay.remoting.BoltClient
-
- invokeWithCallback(Connection, Object, InvokeCallback, int) - Method in interface com.alipay.remoting.BoltClient
-
- invokeWithCallback(Connection, Object, InvokeContext, InvokeCallback, int) - Method in interface com.alipay.remoting.BoltClient
-
- invokeWithCallback(String, Object, InvokeCallback, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeWithCallback(String, Object, InvokeContext, InvokeCallback, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeWithCallback(Url, Object, InvokeCallback, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeWithCallback(Url, Object, InvokeContext, InvokeCallback, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeWithCallback(Connection, Object, InvokeCallback, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeWithCallback(Connection, Object, InvokeContext, InvokeCallback, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeWithCallback(Url, Object, InvokeContext, InvokeCallback, int) - Method in class com.alipay.remoting.rpc.RpcClientRemoting
-
- invokeWithCallback(String, Object, InvokeContext, InvokeCallback, int) - Method in class com.alipay.remoting.rpc.RpcRemoting
-
Rpc invocation with callback.
- invokeWithCallback(Url, Object, InvokeContext, InvokeCallback, int) - Method in class com.alipay.remoting.rpc.RpcRemoting
-
Rpc invocation with callback.
- invokeWithCallback(Connection, Object, InvokeContext, InvokeCallback, int) - Method in class com.alipay.remoting.rpc.RpcRemoting
-
Rpc invocation with callback.
- invokeWithCallback(String, Object, InvokeCallback, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
Callback invocation using a string address, address format example - 127.0.0.1:12200?
- invokeWithCallback(String, Object, InvokeContext, InvokeCallback, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
- invokeWithCallback(Url, Object, InvokeCallback, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
Callback invocation using a parsed
Url
You can specify an implementation of
InvokeCallback to get the result.
- invokeWithCallback(Url, Object, InvokeContext, InvokeCallback, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
- invokeWithCallback(Connection, Object, InvokeCallback, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
- invokeWithCallback(Connection, Object, InvokeContext, InvokeCallback, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
- invokeWithCallback(Url, Object, InvokeContext, InvokeCallback, int) - Method in class com.alipay.remoting.rpc.RpcServerRemoting
-
- invokeWithFuture(Connection, RemotingCommand, int) - Method in class com.alipay.remoting.BaseRemoting
-
Invocation with future returned.
- invokeWithFuture(String, Object, int) - Method in interface com.alipay.remoting.BoltClient
-
Future invocation using a string address, address format example - 127.0.0.1:12200?
- invokeWithFuture(String, Object, InvokeContext, int) - Method in interface com.alipay.remoting.BoltClient
-
- invokeWithFuture(Url, Object, int) - Method in interface com.alipay.remoting.BoltClient
-
- invokeWithFuture(Url, Object, InvokeContext, int) - Method in interface com.alipay.remoting.BoltClient
-
- invokeWithFuture(Connection, Object, int) - Method in interface com.alipay.remoting.BoltClient
-
- invokeWithFuture(Connection, Object, InvokeContext, int) - Method in interface com.alipay.remoting.BoltClient
-
- invokeWithFuture(String, Object, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeWithFuture(String, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeWithFuture(Url, Object, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeWithFuture(Url, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeWithFuture(Connection, Object, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeWithFuture(Connection, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcClient
-
- invokeWithFuture(Url, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcClientRemoting
-
- invokeWithFuture(String, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcRemoting
-
Rpc invocation with future returned.
- invokeWithFuture(Url, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcRemoting
-
Rpc invocation with future returned.
- invokeWithFuture(Connection, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcRemoting
-
Rpc invocation with future returned.
- invokeWithFuture(String, Object, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
Future invocation using a string address, address format example - 127.0.0.1:12200?
- invokeWithFuture(String, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
- invokeWithFuture(Url, Object, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
- invokeWithFuture(Url, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
- invokeWithFuture(Connection, Object, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
- invokeWithFuture(Connection, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcServer
-
- invokeWithFuture(Url, Object, InvokeContext, int) - Method in class com.alipay.remoting.rpc.RpcServerRemoting
-
- IoUtils - Class in com.alipay.remoting.util
-
IO Utilities
- IoUtils() - Constructor for class com.alipay.remoting.util.IoUtils
-
- ip() - Method in class com.alipay.remoting.AbstractRemotingServer
-
- ip() - Method in interface com.alipay.remoting.RemotingServer
-
Get the ip of the server.
- isAsyncCreationDone() - Method in class com.alipay.remoting.ConnectionPool
-
is async create connection done
- isBlank(CharSequence) - Static method in class com.alipay.remoting.util.StringUtils
-
- isCollected - Static variable in class com.alipay.remoting.Url
-
for unit test only, indicate this object have already been GCed
- isConnected(String) - Method in class com.alipay.remoting.rpc.RpcServer
-
check whether a client address connected
- isConnected(Url) - Method in class com.alipay.remoting.rpc.RpcServer
-
check whether a
Url connected
- isConnectionMonitorSwitchOn() - Method in interface com.alipay.remoting.BoltClient
-
is connection monitor switch on
- isConnectionMonitorSwitchOn() - Method in class com.alipay.remoting.rpc.RpcClient
-
Deprecated.
- isConnWarmup() - Method in class com.alipay.remoting.Url
-
- isDone() - Method in interface com.alipay.remoting.InvokeFuture
-
Whether the future is done.
- isDone() - Method in class com.alipay.remoting.rpc.DefaultInvokeFuture
-
- isDone() - Method in class com.alipay.remoting.rpc.RpcResponseFuture
-
Whether the future is done.
- isEmpty() - Method in class com.alipay.remoting.ConnectionPool
-
is connection pool empty
- isEmpty(CharSequence) - Static method in class com.alipay.remoting.util.StringUtils
-
- isFine() - Method in class com.alipay.remoting.Connection
-
to check whether the connection is fine to use
- isInvokeFutureMapFinish() - Method in class com.alipay.remoting.Connection
-
Whether invokeFutures is completed
- isNotBlank(CharSequence) - Static method in class com.alipay.remoting.util.StringUtils
-
- isNotEmpty(CharSequence) - Static method in class com.alipay.remoting.util.StringUtils
-
- isNumeric(String) - Static method in class com.alipay.remoting.util.StringUtils
-
- isOn(int) - Method in class com.alipay.remoting.config.switches.GlobalSwitch
-
Deprecated.
- isOn(int) - Method in class com.alipay.remoting.config.switches.ProtocolSwitch
-
- isOn(int, int) - Static method in class com.alipay.remoting.config.switches.ProtocolSwitch
-
check switch status whether on according to specified value
- isOn(int) - Method in interface com.alipay.remoting.config.switches.Switch
-
check switch whether on
- isReconnectSwitchOn() - Method in interface com.alipay.remoting.BoltClient
-
is reconnect switch on
- isReconnectSwitchOn() - Method in class com.alipay.remoting.rpc.RpcClient
-
Deprecated.
- isRequestTimeout() - Method in interface com.alipay.remoting.BizContext
-
check whether request already timeout
- isRequestTimeout() - Method in class com.alipay.remoting.DefaultBizContext
-
- isRequestTimeout() - Method in class com.alipay.remoting.RemotingContext
-
whether this request already timeout
- isServerSide() - Method in exception com.alipay.remoting.exception.DeserializationException
-
Getter method for property serverSide.
- isServerSide() - Method in exception com.alipay.remoting.exception.SerializationException
-
Getter method for property serverSide.
- isServerSide() - Method in class com.alipay.remoting.RemotingContext
-
The server side
- isSingleDecode() - Method in class com.alipay.remoting.codec.AbstractBatchDecoder
-
- isStarted() - Method in class com.alipay.remoting.AbstractLifeCycle
-
- isStarted() - Method in interface com.alipay.remoting.LifeCycle
-
- isTimeoutDiscard() - Method in class com.alipay.remoting.RemotingContext
-
- iterator() - Method in class com.alipay.remoting.util.ConcurrentHashSet
-
- parse(String) - Method in interface com.alipay.remoting.RemotingAddressParser
-
Parse a simple string url to get
Url
- parse(String) - Method in class com.alipay.remoting.rpc.RpcAddressParser
-
- parsedUrls - Static variable in class com.alipay.remoting.Url
-
- parseLocalAddress(Channel) - Static method in class com.alipay.remoting.util.RemotingUtil
-
Parse the local address of the channel.
- parseLocalIP(Channel) - Static method in class com.alipay.remoting.util.RemotingUtil
-
Parse the local host ip of the channel.
- parseLocalPort(Channel) - Static method in class com.alipay.remoting.util.RemotingUtil
-
Parse the local host port of the channel.
- parseProperty(String, String) - Method in interface com.alipay.remoting.RemotingAddressParser
-
Parse to get property value according to specified property key
- parseProperty(String, String) - Method in class com.alipay.remoting.rpc.RpcAddressParser
-
- parseRemoteAddress(Channel) - Static method in class com.alipay.remoting.util.RemotingUtil
-
Parse the remote address of the channel.
- parseRemoteHostName(Channel) - Static method in class com.alipay.remoting.util.RemotingUtil
-
Parse the remote hostname of the channel.
- parseRemoteIP(Channel) - Static method in class com.alipay.remoting.util.RemotingUtil
-
Parse the remote host ip of the channel.
- parseRemotePort(Channel) - Static method in class com.alipay.remoting.util.RemotingUtil
-
Parse the remote host port of the channel.
- parseSocketAddressToHostIp(SocketAddress) - Static method in class com.alipay.remoting.util.RemotingUtil
-
Parse the host ip of socket address.
- parseSocketAddressToString(SocketAddress) - Static method in class com.alipay.remoting.util.RemotingUtil
-
Parse the socket address, omit the leading "/" if present.
- parseUniqueKey(String) - Method in interface com.alipay.remoting.RemotingAddressParser
-
Parse a simple string url to get a unique key of a certain address
- parseUniqueKey(String) - Method in class com.alipay.remoting.rpc.RpcAddressParser
-
- port() - Method in class com.alipay.remoting.AbstractRemotingServer
-
- port() - Method in interface com.alipay.remoting.RemotingServer
-
Get the port of the server.
- preHandleRequest(RemotingContext, T) - Method in class com.alipay.remoting.rpc.protocol.AbstractUserProcessor
-
- preHandleRequest(RemotingContext, T) - Method in interface com.alipay.remoting.rpc.protocol.UserProcessor
-
Pre handle request, to avoid expose
RemotingContext directly to biz handle request logic.
- preProcessInvokeContext(InvokeContext, RemotingCommand, Connection) - Method in class com.alipay.remoting.rpc.RpcClientRemoting
-
- preProcessInvokeContext(InvokeContext, RemotingCommand, Connection) - Method in class com.alipay.remoting.rpc.RpcRemoting
-
- preProcessInvokeContext(InvokeContext, RemotingCommand, Connection) - Method in class com.alipay.remoting.rpc.RpcServerRemoting
-
- printConnectionTraceLog(Logger, String, InvokeContext) - Static method in class com.alipay.remoting.util.TraceLogUtil
-
print trace log
- process(RemotingContext, T, ExecutorService) - Method in class com.alipay.remoting.AbstractRemotingProcessor
-
Process the remoting command with its own executor or with the defaultExecutor if its own if null.
- process(RemotingContext, T, ExecutorService) - Method in interface com.alipay.remoting.RemotingProcessor
-
Process the remoting command.
- process(RemotingContext, RpcRequestCommand, ExecutorService) - Method in class com.alipay.remoting.rpc.protocol.RpcRequestProcessor
-
- processInIOThread() - Method in class com.alipay.remoting.rpc.protocol.AbstractUserProcessor
-
By default, return false, means not deserialize and process biz logic in io thread
- processInIOThread() - Method in interface com.alipay.remoting.rpc.protocol.UserProcessor
-
Whether deserialize and process biz logic in io thread.
- ProcessorManager - Class in com.alipay.remoting
-
Manager of processors
Maintains the relationship between command and command processor through command code.
- ProcessorManager() - Constructor for class com.alipay.remoting.ProcessorManager
-
- PROTOCOL - Static variable in class com.alipay.remoting.Connection
-
Attribute key for protocol
- Protocol - Interface in com.alipay.remoting
-
A protocol contains a group of commands.
- PROTOCOL_CODE - Static variable in class com.alipay.remoting.rpc.protocol.RpcProtocol
-
- PROTOCOL_CODE - Static variable in class com.alipay.remoting.rpc.protocol.RpcProtocolV2
-
- PROTOCOL_VERSION_1 - Static variable in class com.alipay.remoting.rpc.protocol.RpcProtocolV2
-
version 1, is the same with RpcProtocol
- PROTOCOL_VERSION_2 - Static variable in class com.alipay.remoting.rpc.protocol.RpcProtocolV2
-
version 2, is the protocol version for RpcProtocolV2
- ProtocolCode - Class in com.alipay.remoting
-
Protocol code definition, you can define your own protocol code in byte array
ProtocolCode.version
We suggest to use just one byte for simplicity.
- ProtocolCodeBasedDecoder - Class in com.alipay.remoting.codec
-
Protocol code based decoder, the main decoder for a certain protocol, which is lead by one or multi bytes (magic code).
- ProtocolCodeBasedDecoder(int) - Constructor for class com.alipay.remoting.codec.ProtocolCodeBasedDecoder
-
- ProtocolCodeBasedEncoder - Class in com.alipay.remoting.codec
-
Protocol code based newEncoder, the main newEncoder for a certain protocol, which is lead by one or multi bytes (magic code).
- ProtocolCodeBasedEncoder(ProtocolCode) - Constructor for class com.alipay.remoting.codec.ProtocolCodeBasedEncoder
-
- protocolCodeLength - Variable in class com.alipay.remoting.codec.ProtocolCodeBasedDecoder
-
the length of protocol code
- ProtocolManager - Class in com.alipay.remoting
-
Manager of all protocols
- ProtocolManager() - Constructor for class com.alipay.remoting.ProtocolManager
-
- ProtocolSwitch - Class in com.alipay.remoting.config.switches
-
Switches used in protocol, this is runtime switch.
- ProtocolSwitch() - Constructor for class com.alipay.remoting.config.switches.ProtocolSwitch
-
- put(String, String) - Method in interface com.alipay.remoting.BizContext
-
put a key and value
- put(String, String) - Method in class com.alipay.remoting.DefaultBizContext
-
- put(String, Object) - Method in class com.alipay.remoting.InvokeContext
-
put
- putIfAbsent(String, Object) - Method in class com.alipay.remoting.InvokeContext
-
put if absent
- putResponse(RemotingCommand) - Method in interface com.alipay.remoting.InvokeFuture
-
Put the response to the future.
- putResponse(RemotingCommand) - Method in class com.alipay.remoting.rpc.DefaultInvokeFuture
-
- RandomSelectStrategy - Class in com.alipay.remoting
-
Select a connection randomly
- RandomSelectStrategy(Configuration) - Constructor for class com.alipay.remoting.RandomSelectStrategy
-
- reconnect(Url) - Method in class com.alipay.remoting.ReconnectManager
-
- reconnect(Url) - Method in interface com.alipay.remoting.Reconnector
-
Do reconnecting in async mode.
- ReconnectManager - Class in com.alipay.remoting
-
Reconnect manager.
- ReconnectManager(ConnectionManager) - Constructor for class com.alipay.remoting.ReconnectManager
-
- Reconnector - Interface in com.alipay.remoting
-
Reconnect manager interface.
- registerCustomSerializer(String, CustomSerializer) - Static method in class com.alipay.remoting.CustomSerializerManager
-
Register custom serializer for class name.
- registerCustomSerializer(CommandCode, CustomSerializer) - Static method in class com.alipay.remoting.CustomSerializerManager
-
Register custom serializer for command code.
- registerDefaultExecutor(ExecutorService) - Method in interface com.alipay.remoting.CommandHandler
-
Register default executor for the handler.
- registerDefaultExecutor(ExecutorService) - Method in class com.alipay.remoting.ProcessorManager
-
Set the default executor.
- registerDefaultExecutor(byte, ExecutorService) - Method in interface com.alipay.remoting.RemotingServer
-
Register default executor service for server.
- registerDefaultExecutor(ExecutorService) - Method in class com.alipay.remoting.rpc.protocol.RpcCommandHandler
-
- registerDefaultExecutor(byte, ExecutorService) - Method in class com.alipay.remoting.rpc.RpcServer
-
- registerDefaultProcessor(RemotingProcessor<?>) - Method in class com.alipay.remoting.ProcessorManager
-
Register the default processor to process command with no specific processor registered.
- registerProcessor(CommandCode, RemotingProcessor<?>) - Method in interface com.alipay.remoting.CommandHandler
-
Register processor for command with specified code.
- registerProcessor(CommandCode, RemotingProcessor<?>) - Method in class com.alipay.remoting.ProcessorManager
-
Register processor to process command that has the command code of cmdCode.
- registerProcessor(byte, CommandCode, RemotingProcessor<?>) - Method in interface com.alipay.remoting.RemotingServer
-
Register processor for command with the command code.
- registerProcessor(CommandCode, RemotingProcessor) - Method in class com.alipay.remoting.rpc.protocol.RpcCommandHandler
-
- registerProcessor(byte, CommandCode, RemotingProcessor<?>) - Method in class com.alipay.remoting.rpc.RpcServer
-
- registerProtocol(Protocol, byte...) - Static method in class com.alipay.remoting.ProtocolManager
-
- registerProtocol(Protocol, ProtocolCode) - Static method in class com.alipay.remoting.ProtocolManager
-
- registerUserProcessor(UserProcessor<?>) - Method in interface com.alipay.remoting.BoltClient
-
- registerUserProcessor(UserProcessor<?>) - Method in interface com.alipay.remoting.RemotingServer
-
Register user processor.
- registerUserProcessor(UserProcessor<?>, ConcurrentHashMap<String, UserProcessor<?>>) - Static method in class com.alipay.remoting.rpc.protocol.UserProcessorRegisterHelper
-
Help register single-interest user processor.
- registerUserProcessor(UserProcessor<?>) - Method in class com.alipay.remoting.rpc.RpcClient
-
- registerUserProcessor(UserProcessor<?>) - Method in class com.alipay.remoting.rpc.RpcServer
-
- RejectedExecutionPolicy - Enum in com.alipay.remoting
-
RejectedExecutionPolicy determines how to deal with this situation that user executor rejected the RpcInvokeCallbackListener.CallbackTask.
- rejectedExecutionPolicy() - Method in interface com.alipay.remoting.RejectionProcessableInvokeCallback
-
when user executor rejected the
RpcInvokeCallbackListener.CallbackTask,
bolt will handle the rejected task according to this
RejectedExecutionPolicy
- RejectionProcessableInvokeCallback - Interface in com.alipay.remoting
-
- RemotingAddressParser - Interface in com.alipay.remoting
-
Remoting address parser
Implement this to generate a
Url
- RemotingCommand - Interface in com.alipay.remoting
-
Remoting command.
- RemotingContext - Class in com.alipay.remoting
-
Wrap the ChannelHandlerContext.
- RemotingContext(ChannelHandlerContext) - Constructor for class com.alipay.remoting.RemotingContext
-
Constructor.
- RemotingContext(ChannelHandlerContext, boolean) - Constructor for class com.alipay.remoting.RemotingContext
-
Constructor.
- RemotingContext(ChannelHandlerContext, boolean, ConcurrentHashMap<String, UserProcessor<?>>) - Constructor for class com.alipay.remoting.RemotingContext
-
Constructor.
- RemotingContext(ChannelHandlerContext, InvokeContext, boolean, ConcurrentHashMap<String, UserProcessor<?>>) - Constructor for class com.alipay.remoting.RemotingContext
-
Constructor.
- RemotingException - Exception in com.alipay.remoting.exception
-
Exception for default remoting problems
- RemotingException() - Constructor for exception com.alipay.remoting.exception.RemotingException
-
Constructor.
- RemotingException(String) - Constructor for exception com.alipay.remoting.exception.RemotingException
-
Constructor.
- RemotingException(String, Throwable) - Constructor for exception com.alipay.remoting.exception.RemotingException
-
Constructor.
- RemotingProcessor<T extends RemotingCommand> - Interface in com.alipay.remoting
-
Remoting processor processes remoting commands.
- RemotingServer - Interface in com.alipay.remoting
-
- RemotingUtil - Class in com.alipay.remoting.util
-
Some utilities for remoting.
- RemotingUtil() - Constructor for class com.alipay.remoting.util.RemotingUtil
-
- remove(Connection) - Method in interface com.alipay.remoting.ConnectionManager
-
- remove(Connection, String) - Method in interface com.alipay.remoting.ConnectionManager
-
- remove(String) - Method in interface com.alipay.remoting.ConnectionManager
-
Remove and close all connections from
ConnectionPool with the specified poolKey.
- remove(Connection) - Method in class com.alipay.remoting.DefaultConnectionManager
-
- remove(Connection, String) - Method in class com.alipay.remoting.DefaultConnectionManager
-
- remove(String) - Method in class com.alipay.remoting.DefaultConnectionManager
-
- remove(Object) - Method in class com.alipay.remoting.util.ConcurrentHashSet
-
- removeAll() - Method in interface com.alipay.remoting.ConnectionManager
-
Deprecated.
- removeAll() - Method in class com.alipay.remoting.DefaultConnectionManager
-
Deprecated.
- removeAllAndTryClose() - Method in class com.alipay.remoting.ConnectionPool
-
remove all connections
- removeAndTryClose(Connection) - Method in class com.alipay.remoting.ConnectionPool
-
removeAndTryClose a connection
- removeAttribute(String) - Method in class com.alipay.remoting.Connection
-
Remove attribute.
- removeCancelUrl(Url) - Method in class com.alipay.remoting.ReconnectManager
-
Deprecated.
- removeIdGroupCallbackMapping(Integer, Channel) - Static method in class com.alipay.remoting.util.ConnectionUtil
-
- removeIdPoolKeyMapping(Integer) - Method in class com.alipay.remoting.Connection
-
remove id to group Mapping
- removeIdPoolKeyMapping(Integer, Channel) - Static method in class com.alipay.remoting.util.ConnectionUtil
-
- removeInvokeFuture(int) - Method in class com.alipay.remoting.Connection
-
Remove InvokeFuture who's invokeId is id
- removePoolKey(String) - Method in class com.alipay.remoting.Connection
-
remove pool key
- removeTask(String) - Method in class com.alipay.remoting.DefaultConnectionManager
-
remove task and remove all connections
- REQUEST - Static variable in class com.alipay.remoting.rpc.RpcCommandType
-
rpc request
- REQUEST_ONEWAY - Static variable in class com.alipay.remoting.rpc.RpcCommandType
-
rpc oneway request
- RequestCommand - Class in com.alipay.remoting.rpc
-
Command of request.
- RequestCommand() - Constructor for class com.alipay.remoting.rpc.RequestCommand
-
- RequestCommand(CommandCode) - Constructor for class com.alipay.remoting.rpc.RequestCommand
-
- RequestCommand(byte, CommandCode) - Constructor for class com.alipay.remoting.rpc.RequestCommand
-
- RequestCommand(byte, byte, CommandCode) - Constructor for class com.alipay.remoting.rpc.RequestCommand
-
- resetId() - Static method in class com.alipay.remoting.util.IDGenerator
-
- resolveResponseObject(ResponseCommand, String) - Static method in class com.alipay.remoting.rpc.RpcResponseResolver
-
Analyze the response command and generate the response object.
- RESPONSE - Static variable in class com.alipay.remoting.rpc.RpcCommandType
-
rpc response
- ResponseCommand - Class in com.alipay.remoting.rpc
-
Command of response.
- ResponseCommand() - Constructor for class com.alipay.remoting.rpc.ResponseCommand
-
- ResponseCommand(CommandCode) - Constructor for class com.alipay.remoting.rpc.ResponseCommand
-
- ResponseCommand(int) - Constructor for class com.alipay.remoting.rpc.ResponseCommand
-
- ResponseCommand(CommandCode, int) - Constructor for class com.alipay.remoting.rpc.ResponseCommand
-
- ResponseCommand(byte, byte, CommandCode, int) - Constructor for class com.alipay.remoting.rpc.ResponseCommand
-
- ResponseStatus - Enum in com.alipay.remoting
-
Status of the response.
- retry_detect_period() - Static method in class com.alipay.remoting.config.ConfigManager
-
- RETRY_DETECT_PERIOD - Static variable in class com.alipay.remoting.config.Configs
-
Deprecated.
- RETRY_DETECT_PERIOD_DEFAULT - Static variable in class com.alipay.remoting.config.Configs
-
- RpcAddressParser - Class in com.alipay.remoting.rpc
-
This is address parser for RPC.
- RpcAddressParser() - Constructor for class com.alipay.remoting.rpc.RpcAddressParser
-
- RpcAsyncContext - Class in com.alipay.remoting.rpc.protocol
-
Async biz context of Rpc.
- RpcAsyncContext(RemotingContext, RpcRequestCommand, RpcRequestProcessor) - Constructor for class com.alipay.remoting.rpc.protocol.RpcAsyncContext
-
Default constructor.
- RpcClient - Class in com.alipay.remoting.rpc
-
Client for Rpc.
- RpcClient() - Constructor for class com.alipay.remoting.rpc.RpcClient
-
- RpcClientRemoting - Class in com.alipay.remoting.rpc
-
Rpc client remoting
- RpcClientRemoting(CommandFactory, RemotingAddressParser, ConnectionManager) - Constructor for class com.alipay.remoting.rpc.RpcClientRemoting
-
- RpcCodec - Class in com.alipay.remoting.rpc
-
- RpcCodec() - Constructor for class com.alipay.remoting.rpc.RpcCodec
-
- RpcCommand - Class in com.alipay.remoting.rpc
-
Remoting command.
- RpcCommand() - Constructor for class com.alipay.remoting.rpc.RpcCommand
-
- RpcCommand(byte) - Constructor for class com.alipay.remoting.rpc.RpcCommand
-
- RpcCommand(CommandCode) - Constructor for class com.alipay.remoting.rpc.RpcCommand
-
- RpcCommand(byte, CommandCode) - Constructor for class com.alipay.remoting.rpc.RpcCommand
-
- RpcCommand(byte, byte, CommandCode) - Constructor for class com.alipay.remoting.rpc.RpcCommand
-
- RpcCommandCode - Enum in com.alipay.remoting.rpc.protocol
-
Command code for rpc remoting command.
- RpcCommandDecoder - Class in com.alipay.remoting.rpc.protocol
-
Command decoder for Rpc.
- RpcCommandDecoder() - Constructor for class com.alipay.remoting.rpc.protocol.RpcCommandDecoder
-
- RpcCommandDecoderV2 - Class in com.alipay.remoting.rpc.protocol
-
Command decoder for Rpc v2.
- RpcCommandDecoderV2() - Constructor for class com.alipay.remoting.rpc.protocol.RpcCommandDecoderV2
-
- RpcCommandEncoder - Class in com.alipay.remoting.rpc.protocol
-
Encode remoting command into ByteBuf.
- RpcCommandEncoder() - Constructor for class com.alipay.remoting.rpc.protocol.RpcCommandEncoder
-
- RpcCommandEncoderV2 - Class in com.alipay.remoting.rpc.protocol
-
Encode remoting command into ByteBuf v2.
- RpcCommandEncoderV2() - Constructor for class com.alipay.remoting.rpc.protocol.RpcCommandEncoderV2
-
- RpcCommandFactory - Class in com.alipay.remoting.rpc
-
command factory for rpc protocol
- RpcCommandFactory() - Constructor for class com.alipay.remoting.rpc.RpcCommandFactory
-
- RpcCommandHandler - Class in com.alipay.remoting.rpc.protocol
-
Rpc command handler.
- RpcCommandHandler(CommandFactory) - Constructor for class com.alipay.remoting.rpc.protocol.RpcCommandHandler
-
Constructor.
- RpcCommandType - Class in com.alipay.remoting.rpc
-
The type of command in the request/response model.
- RpcCommandType() - Constructor for class com.alipay.remoting.rpc.RpcCommandType
-
- RpcConfigManager - Class in com.alipay.remoting.rpc
-
RPC framework config manager.
- RpcConfigManager() - Constructor for class com.alipay.remoting.rpc.RpcConfigManager
-
- RpcConfigs - Class in com.alipay.remoting.rpc
-
Constants for rpc.
- RpcConfigs() - Constructor for class com.alipay.remoting.rpc.RpcConfigs
-
- RpcConnectionEventHandler - Class in com.alipay.remoting.rpc
-
ConnectionEventHandler for Rpc.
- RpcConnectionEventHandler() - Constructor for class com.alipay.remoting.rpc.RpcConnectionEventHandler
-
- RpcConnectionEventHandler(Configuration) - Constructor for class com.alipay.remoting.rpc.RpcConnectionEventHandler
-
- RpcConnectionFactory - Class in com.alipay.remoting.rpc
-
Default RPC connection factory impl.
- RpcConnectionFactory(ConcurrentHashMap<String, UserProcessor<?>>, Configuration) - Constructor for class com.alipay.remoting.rpc.RpcConnectionFactory
-
- RpcDeserializeLevel - Class in com.alipay.remoting.rpc.protocol
-
Rpc deserialize level.
- RpcDeserializeLevel() - Constructor for class com.alipay.remoting.rpc.protocol.RpcDeserializeLevel
-
- RpcHandler - Class in com.alipay.remoting.rpc
-
Dispatch messages to corresponding protocol.
- RpcHandler(ConcurrentHashMap<String, UserProcessor<?>>) - Constructor for class com.alipay.remoting.rpc.RpcHandler
-
- RpcHandler(boolean, ConcurrentHashMap<String, UserProcessor<?>>) - Constructor for class com.alipay.remoting.rpc.RpcHandler
-
- RpcHeartBeatProcessor - Class in com.alipay.remoting.rpc.protocol
-
Processor for heart beat.
- RpcHeartBeatProcessor() - Constructor for class com.alipay.remoting.rpc.protocol.RpcHeartBeatProcessor
-
- RpcHeartbeatTrigger - Class in com.alipay.remoting.rpc.protocol
-
Handler for heart beat.
- RpcHeartbeatTrigger(CommandFactory) - Constructor for class com.alipay.remoting.rpc.protocol.RpcHeartbeatTrigger
-
- RpcInvokeCallbackListener - Class in com.alipay.remoting.rpc
-
Listener which listens the Rpc invoke result, and then invokes the call back.
- RpcInvokeCallbackListener() - Constructor for class com.alipay.remoting.rpc.RpcInvokeCallbackListener
-
- RpcInvokeCallbackListener(String) - Constructor for class com.alipay.remoting.rpc.RpcInvokeCallbackListener
-
- RpcProtocol - Class in com.alipay.remoting.rpc.protocol
-
Request command protocol for v1
0 1 2 4 6 8 10 12 14 16
+-----+-----+-----+-----+-----+-----+-----+-----+-----+-----+-----+-----+-----+-----+-----+-----+
|proto| type| cmdcode |ver2 | requestId |codec| timeout | classLen |
+-----------+-----------+-----------+-----------+-----------+-----------+-----------+-----------+
|headerLen | contentLen |
- RpcProtocol() - Constructor for class com.alipay.remoting.rpc.protocol.RpcProtocol
-
- RpcProtocolDecoder - Class in com.alipay.remoting.rpc.protocol
-
Rpc protocol decoder.
- RpcProtocolDecoder(int) - Constructor for class com.alipay.remoting.rpc.protocol.RpcProtocolDecoder
-
- RpcProtocolManager - Class in com.alipay.remoting.rpc.protocol
-
Protocol manager.
- RpcProtocolManager() - Constructor for class com.alipay.remoting.rpc.protocol.RpcProtocolManager
-
- RpcProtocolV2 - Class in com.alipay.remoting.rpc.protocol
-
Request command protocol for v2
0 1 2 4 6 8 10 11 12 14 16
+-----+-----+-----+-----+-----+-----+-----+-----+-----+-----+-----+------+-----+-----+-----+-----+
|proto| ver1|type | cmdcode |ver2 | requestId |codec|switch| timeout |
+-----------+-----------+-----------+-----------+-----------+------------+-----------+-----------+
|classLen |headerLen |contentLen |
- RpcProtocolV2() - Constructor for class com.alipay.remoting.rpc.protocol.RpcProtocolV2
-
- rpcRemoting - Variable in class com.alipay.remoting.rpc.RpcClient
-
- RpcRemoting - Class in com.alipay.remoting.rpc
-
Rpc remoting capability.
- RpcRemoting(CommandFactory) - Constructor for class com.alipay.remoting.rpc.RpcRemoting
-
default constructor
- RpcRemoting(CommandFactory, RemotingAddressParser, ConnectionManager) - Constructor for class com.alipay.remoting.rpc.RpcRemoting
-
- rpcRemoting - Variable in class com.alipay.remoting.rpc.RpcServer
-
rpc remoting
- RpcRequestCommand - Class in com.alipay.remoting.rpc.protocol
-
Request command for Rpc.
- RpcRequestCommand() - Constructor for class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
create request command without id
- RpcRequestCommand(Object) - Constructor for class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
create request command with id and request object
- RpcRequestProcessor - Class in com.alipay.remoting.rpc.protocol
-
Process Rpc request.
- RpcRequestProcessor() - Constructor for class com.alipay.remoting.rpc.protocol.RpcRequestProcessor
-
Default constructor.
- RpcRequestProcessor(CommandFactory) - Constructor for class com.alipay.remoting.rpc.protocol.RpcRequestProcessor
-
Constructor.
- RpcRequestProcessor(ExecutorService) - Constructor for class com.alipay.remoting.rpc.protocol.RpcRequestProcessor
-
Constructor.
- RpcResponseCommand - Class in com.alipay.remoting.rpc.protocol
-
Response command for Rpc.
- RpcResponseCommand() - Constructor for class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
- RpcResponseCommand(Object) - Constructor for class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
- RpcResponseCommand(int, Object) - Constructor for class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
- RpcResponseFuture - Class in com.alipay.remoting.rpc
-
The future for response.
- RpcResponseFuture(String, InvokeFuture) - Constructor for class com.alipay.remoting.rpc.RpcResponseFuture
-
Constructor
- RpcResponseProcessor - Class in com.alipay.remoting.rpc.protocol
-
Processor to process RpcResponse.
- RpcResponseProcessor() - Constructor for class com.alipay.remoting.rpc.protocol.RpcResponseProcessor
-
Default constructor.
- RpcResponseProcessor(ExecutorService) - Constructor for class com.alipay.remoting.rpc.protocol.RpcResponseProcessor
-
Constructor.
- RpcResponseResolver - Class in com.alipay.remoting.rpc
-
Resolve response object from response command.
- RpcResponseResolver() - Constructor for class com.alipay.remoting.rpc.RpcResponseResolver
-
- RpcServer - Class in com.alipay.remoting.rpc
-
Server for Rpc.
- RpcServer() - Constructor for class com.alipay.remoting.rpc.RpcServer
-
- RpcServer(boolean) - Constructor for class com.alipay.remoting.rpc.RpcServer
-
- RpcServer(int) - Constructor for class com.alipay.remoting.rpc.RpcServer
-
Construct a rpc server.
- RpcServer(String, int) - Constructor for class com.alipay.remoting.rpc.RpcServer
-
Construct a rpc server.
- RpcServer(int, boolean) - Constructor for class com.alipay.remoting.rpc.RpcServer
-
Construct a rpc server.
- RpcServer(String, int, boolean) - Constructor for class com.alipay.remoting.rpc.RpcServer
-
Construct a rpc server.
- RpcServer(int, boolean, boolean) - Constructor for class com.alipay.remoting.rpc.RpcServer
-
Construct a rpc server.
- RpcServerException - Exception in com.alipay.remoting.rpc.exception
-
Rpc server exception when processing request
- RpcServerException() - Constructor for exception com.alipay.remoting.rpc.exception.RpcServerException
-
Default constructor.
- RpcServerException(String) - Constructor for exception com.alipay.remoting.rpc.exception.RpcServerException
-
- RpcServerException(String, Throwable) - Constructor for exception com.alipay.remoting.rpc.exception.RpcServerException
-
- RpcServerRemoting - Class in com.alipay.remoting.rpc
-
Rpc server remoting
- RpcServerRemoting(CommandFactory) - Constructor for class com.alipay.remoting.rpc.RpcServerRemoting
-
default constructor
- RpcServerRemoting(CommandFactory, RemotingAddressParser, DefaultConnectionManager) - Constructor for class com.alipay.remoting.rpc.RpcServerRemoting
-
- RpcTaskScanner - Class in com.alipay.remoting.rpc
-
Scanner is used to do scan task.
- RpcTaskScanner() - Constructor for class com.alipay.remoting.rpc.RpcTaskScanner
-
- run() - Method in class com.alipay.remoting.util.RunStateRecordedFutureTask
-
- RunStateRecordedFutureTask<V> - Class in com.alipay.remoting.util
-
A customized FutureTask which can record whether the run method has been called.
- RunStateRecordedFutureTask(Callable<V>) - Constructor for class com.alipay.remoting.util.RunStateRecordedFutureTask
-
- scan() - Method in class com.alipay.remoting.ConnectionPool
-
- scan() - Method in class com.alipay.remoting.DefaultConnectionManager
-
in case of cache pollution and connection leak, to do schedule scan
- scan() - Method in interface com.alipay.remoting.Scannable
-
Scan it.
- Scannable - Interface in com.alipay.remoting
-
Can be scanned.
- ScheduledDisconnectStrategy - Class in com.alipay.remoting
-
- ScheduledDisconnectStrategy() - Constructor for class com.alipay.remoting.ScheduledDisconnectStrategy
-
- select(List<Connection>) - Method in interface com.alipay.remoting.ConnectionSelectStrategy
-
select strategy
- select(List<Connection>) - Method in class com.alipay.remoting.RandomSelectStrategy
-
- select(String, Object) - Method in interface com.alipay.remoting.rpc.protocol.UserProcessor.ExecutorSelector
-
- sendException(Throwable) - Method in interface com.alipay.remoting.AsyncContext
-
send exception back
- sendException(Throwable) - Method in class com.alipay.remoting.rpc.protocol.RpcAsyncContext
-
- sendResponse(Object) - Method in interface com.alipay.remoting.AsyncContext
-
send response back
- sendResponse(Object) - Method in class com.alipay.remoting.rpc.protocol.RpcAsyncContext
-
- sendResponseIfNecessary(RemotingContext, byte, RemotingCommand) - Method in class com.alipay.remoting.rpc.protocol.RpcRequestProcessor
-
Send response using remoting context if necessary.
- SerializationException - Exception in com.alipay.remoting.exception
-
Exception when serialize failed
- SerializationException() - Constructor for exception com.alipay.remoting.exception.SerializationException
-
Constructor.
- SerializationException(String) - Constructor for exception com.alipay.remoting.exception.SerializationException
-
Constructor.
- SerializationException(String, boolean) - Constructor for exception com.alipay.remoting.exception.SerializationException
-
Constructor.
- SerializationException(String, Throwable) - Constructor for exception com.alipay.remoting.exception.SerializationException
-
Constructor.
- SerializationException(String, Throwable, boolean) - Constructor for exception com.alipay.remoting.exception.SerializationException
-
Constructor.
- serialize() - Method in interface com.alipay.remoting.RemotingCommand
-
Serialize all parts of remoting command
- serialize() - Method in class com.alipay.remoting.rpc.RpcCommand
-
Serialize the class header and content.
- serialize(Object) - Method in class com.alipay.remoting.serialization.HessianSerializer
-
- serialize(Object) - Method in interface com.alipay.remoting.serialization.Serializer
-
Encode object into bytes.
- serializeClazz() - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
- serializeClazz() - Method in class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
- serializeClazz() - Method in class com.alipay.remoting.rpc.RpcCommand
-
Serialize content class.
- serializeContent(T, InvokeContext) - Method in interface com.alipay.remoting.CustomSerializer
-
Serialize the content of RequestCommand.
- serializeContent(T) - Method in interface com.alipay.remoting.CustomSerializer
-
Serialize the content of ResponseCommand.
- serializeContent(T, InvokeContext) - Method in class com.alipay.remoting.DefaultCustomSerializer
-
- serializeContent(T) - Method in class com.alipay.remoting.DefaultCustomSerializer
-
- serializeContent(InvokeContext) - Method in interface com.alipay.remoting.RemotingCommand
-
Serialize content of remoting command
- serializeContent(InvokeContext) - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
- serializeContent(InvokeContext) - Method in class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
- serializeContent(InvokeContext) - Method in class com.alipay.remoting.rpc.RpcCommand
-
Serialize the content.
- serializeHeader(T, InvokeContext) - Method in interface com.alipay.remoting.CustomSerializer
-
Serialize the header of RequestCommand.
- serializeHeader(T) - Method in interface com.alipay.remoting.CustomSerializer
-
Serialize the header of ResponseCommand.
- serializeHeader(T, InvokeContext) - Method in class com.alipay.remoting.DefaultCustomSerializer
-
- serializeHeader(T) - Method in class com.alipay.remoting.DefaultCustomSerializer
-
- serializeHeader(InvokeContext) - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
- serializeHeader(InvokeContext) - Method in class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
- serializeHeader(InvokeContext) - Method in class com.alipay.remoting.rpc.RpcCommand
-
Serialize the header.
- serializer - Static variable in class com.alipay.remoting.config.ConfigManager
-
- serializer() - Static method in class com.alipay.remoting.config.ConfigManager
-
- SERIALIZER - Static variable in class com.alipay.remoting.config.Configs
-
Codec type
- Serializer - Interface in com.alipay.remoting.serialization
-
Serializer for serialize and deserialize.
- SERIALIZER_DEFAULT - Static variable in class com.alipay.remoting.config.Configs
-
- SerializerManager - Class in com.alipay.remoting.serialization
-
Manage all serializers.
- SerializerManager() - Constructor for class com.alipay.remoting.serialization.SerializerManager
-
- SERVER_LOCAL_IP - Static variable in class com.alipay.remoting.InvokeContext
-
- SERVER_LOCAL_PORT - Static variable in class com.alipay.remoting.InvokeContext
-
- SERVER_MANAGE_CONNECTION_SWITCH - Static variable in class com.alipay.remoting.config.BoltServerOption
-
- SERVER_REMOTE_IP - Static variable in class com.alipay.remoting.InvokeContext
-
- SERVER_REMOTE_PORT - Static variable in class com.alipay.remoting.InvokeContext
-
- server_ssl_enable() - Static method in class com.alipay.remoting.rpc.RpcConfigManager
-
Deprecated.
- server_ssl_keystore() - Static method in class com.alipay.remoting.rpc.RpcConfigManager
-
Deprecated.
- server_ssl_keystore_pass() - Static method in class com.alipay.remoting.rpc.RpcConfigManager
-
Deprecated.
- server_ssl_keystore_type() - Static method in class com.alipay.remoting.rpc.RpcConfigManager
-
Deprecated.
- server_ssl_kmf_algorithm() - Static method in class com.alipay.remoting.rpc.RpcConfigManager
-
Deprecated.
- server_ssl_need_client_auth() - Static method in class com.alipay.remoting.rpc.RpcConfigManager
-
Deprecated.
- SERVER_SYNC_STOP - Static variable in class com.alipay.remoting.config.BoltServerOption
-
- ServerConnectionManager - Interface in com.alipay.remoting
-
Connection manager in server side.
- ServerIdleHandler - Class in com.alipay.remoting
-
Server Idle handler.
- ServerIdleHandler() - Constructor for class com.alipay.remoting.ServerIdleHandler
-
- set(ConfigType, ConfigItem, Object) - Method in interface com.alipay.remoting.config.configs.ConfigContainer
-
Deprecated.
init a config item with certain config type, and the value can be any type.
- set(ConfigType, ConfigItem, Object) - Method in class com.alipay.remoting.config.configs.DefaultConfigContainer
-
Deprecated.
- setAddressParser(RemotingAddressParser) - Method in interface com.alipay.remoting.BoltClient
-
Setter method for property addressParser.
- setAddressParser(RemotingAddressParser) - Method in class com.alipay.remoting.DefaultConnectionManager
-
Setter method for property addressParser.
- setAddressParser(RemotingAddressParser) - Method in class com.alipay.remoting.rpc.RpcClient
-
- setAddressParser(RemotingAddressParser) - Method in class com.alipay.remoting.rpc.RpcServer
-
Setter method for property addressParser.
- setArriveBodyTimeInNano(long) - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
- setArriveHeaderTimeInNano(long) - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
- setArriveTime(long) - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
Setter method for property arriveTime.
- setArriveTimestamp(long) - Method in class com.alipay.remoting.RemotingContext
-
Setter method for property arriveTimestamp.
- setAttribute(String, Object) - Method in class com.alipay.remoting.Connection
-
Set attribute key=value.
- setAttributeIfAbsent(String, Object) - Method in class com.alipay.remoting.Connection
-
set attribute if key absent.
- setBeforeEnterQueueTime(long) - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
- setBs(BitSet) - Method in class com.alipay.remoting.config.switches.ProtocolSwitch
-
Setter method for property bs.
- setCause(Throwable) - Method in interface com.alipay.remoting.InvokeFuture
-
Set the cause if exception caught.
- setCause(Throwable) - Method in class com.alipay.remoting.rpc.DefaultInvokeFuture
-
- setCause(Throwable) - Method in class com.alipay.remoting.rpc.ResponseCommand
-
Setter method for property cause.
- setChannelContext(ChannelHandlerContext) - Method in class com.alipay.remoting.RemotingContext
-
Set the channel handler context.
- setClazz(byte[]) - Method in class com.alipay.remoting.rpc.RpcCommand
-
- setCmdCode(CommandCode) - Method in class com.alipay.remoting.rpc.RpcCommand
-
- setCommandFactory(CommandFactory) - Method in class com.alipay.remoting.AbstractRemotingProcessor
-
- setConnectionEventHandler(ConnectionEventHandler) - Method in class com.alipay.remoting.DefaultConnectionManager
-
Setter method for property connectionEventHandler.
- setConnectionEventListener(ConnectionEventListener) - Method in class com.alipay.remoting.ConnectionEventHandler
-
- setConnectionEventListener(ConnectionEventListener) - Method in class com.alipay.remoting.DefaultConnectionManager
-
Setter method for property connectionEventListener.
- setConnectionFactory(ConnectionFactory) - Method in class com.alipay.remoting.DefaultConnectionManager
-
Setter method for property connctionFactory.
- setConnectionManager(ConnectionManager) - Method in interface com.alipay.remoting.BoltClient
-
Setter method for property connectionManager.
- setConnectionManager(ConnectionManager) - Method in class com.alipay.remoting.ConnectionEventHandler
-
- setConnectionManager(ConnectionManager) - Method in class com.alipay.remoting.rpc.RpcClient
-
- setConnectionSelectStrategy(ConnectionSelectStrategy) - Method in class com.alipay.remoting.DefaultConnectionManager
-
Setter method for property connectionSelectStrategy.
- setConnectTimeout(int) - Method in class com.alipay.remoting.Url
-
- setConnNum(int) - Method in class com.alipay.remoting.Url
-
- setConnWarmup(boolean) - Method in class com.alipay.remoting.Url
-
- setContent(byte[]) - Method in class com.alipay.remoting.rpc.RpcCommand
-
- setCumulator(AbstractBatchDecoder.Cumulator) - Method in class com.alipay.remoting.codec.AbstractBatchDecoder
-
- setDiscardAfterReads(int) - Method in class com.alipay.remoting.codec.AbstractBatchDecoder
-
Set the number of reads after which ByteBuf.discardSomeReadBytes() are called and so free up memory.
- setErrorMsg(String) - Method in class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
Setter method for property errorMsg.
- setExecutor(ExecutorService) - Method in class com.alipay.remoting.AbstractRemotingProcessor
-
Setter method for property executor.
- setExecutor(ExecutorService) - Method in interface com.alipay.remoting.RemotingProcessor
-
Set executor.
- setExecutorSelector(UserProcessor.ExecutorSelector) - Method in class com.alipay.remoting.rpc.protocol.AbstractUserProcessor
-
- setExecutorSelector(UserProcessor.ExecutorSelector) - Method in interface com.alipay.remoting.rpc.protocol.UserProcessor
-
Use this method to set executor selector.
- setHeader(byte[]) - Method in class com.alipay.remoting.rpc.RpcCommand
-
- setId(int) - Method in class com.alipay.remoting.rpc.RpcCommand
-
- setInvokeContext(InvokeContext) - Method in interface com.alipay.remoting.InvokeFuture
-
set invoke context
- setInvokeContext(InvokeContext) - Method in class com.alipay.remoting.rpc.DefaultInvokeFuture
-
- setInvokeContext(InvokeContext) - Method in class com.alipay.remoting.rpc.RpcCommand
-
- setLocalBindingPort(int) - Method in class com.alipay.remoting.AbstractRemotingServer
-
override the random port zero with the actual binding port value.
- setMonitorStrategy(ConnectionMonitorStrategy) - Method in interface com.alipay.remoting.BoltClient
-
Setter method for property monitorStrategy.
- setMonitorStrategy(ConnectionMonitorStrategy) - Method in class com.alipay.remoting.rpc.RpcClient
-
- setProtocol(byte) - Method in class com.alipay.remoting.Url
-
- setProtocolSwitch(ProtocolSwitch) - Method in class com.alipay.remoting.rpc.RpcCommand
-
- setReconnectManager(ReconnectManager) - Method in class com.alipay.remoting.ConnectionEventHandler
-
Deprecated.
- setReconnector(Reconnector) - Method in class com.alipay.remoting.ConnectionEventHandler
-
- setRequestClass(String) - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
Setter method for property requestClass.
- setRequestHeader(Object) - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
Setter method for property requestHeader.
- setRequestObject(Object) - Method in class com.alipay.remoting.rpc.protocol.RpcRequestCommand
-
Setter method for property requestObject.
- setResponseClass(String) - Method in class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
Setter method for property responseClass.
- setResponseHeader(Object) - Method in class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
Setter method for property responseHeader.
- setResponseHost(InetSocketAddress) - Method in class com.alipay.remoting.rpc.ResponseCommand
-
Setter method for property responseHost.
- setResponseObject(Object) - Method in class com.alipay.remoting.rpc.protocol.RpcResponseCommand
-
Setter method for property responseObject.
- setResponseStatus(ResponseStatus) - Method in class com.alipay.remoting.rpc.ResponseCommand
-
Setter method for property responseStatus.
- setResponseTimeMillis(long) - Method in class com.alipay.remoting.rpc.ResponseCommand
-
Setter method for property responseTimeMillis.
- setRpcCommandType(int) - Method in class com.alipay.remoting.RemotingContext
-
Setter method for property rpcCommandType.
- setSerializer(byte) - Method in class com.alipay.remoting.rpc.RpcCommand
-
- setSingleDecode(boolean) - Method in class com.alipay.remoting.codec.AbstractBatchDecoder
-
- setTimeout(int) - Method in class com.alipay.remoting.RemotingContext
-
Setter method for property timeout.
- setTimeout(int) - Method in class com.alipay.remoting.rpc.RequestCommand
-
Setter method for property timeout.
- setTimeoutDiscard(boolean) - Method in class com.alipay.remoting.RemotingContext
-
- setType(byte) - Method in class com.alipay.remoting.rpc.RpcCommand
-
- setVersion(byte) - Method in class com.alipay.remoting.rpc.RpcCommand
-
- setVersion(byte) - Method in class com.alipay.remoting.Url
-
- shutdown() - Method in class com.alipay.remoting.AbstractLifeCycle
-
- shutdown() - Method in class com.alipay.remoting.AbstractRemotingServer
-
- shutdown() - Method in class com.alipay.remoting.DefaultConnectionManager
-
- shutdown() - Method in class com.alipay.remoting.DefaultConnectionMonitor
-
- shutdown() - Method in interface com.alipay.remoting.LifeCycle
-
- shutdown() - Method in class com.alipay.remoting.ReconnectManager
-
- shutdown() - Method in class com.alipay.remoting.rpc.RpcClient
-
Shutdown.
- shutdown() - Method in class com.alipay.remoting.rpc.RpcTaskScanner
-
- size() - Method in class com.alipay.remoting.ConnectionPool
-
connection pool size
- size() - Method in class com.alipay.remoting.util.ConcurrentHashSet
-
return the size of the map
- split(String, char) - Static method in class com.alipay.remoting.util.StringUtils
-
- SRV_SSL_ENABLE - Static variable in class com.alipay.remoting.config.BoltServerOption
-
- SRV_SSL_ENABLE - Static variable in class com.alipay.remoting.rpc.RpcConfigs
-
Whether to enable server SSL support, default is false(disabled).
- SRV_SSL_KEYSTORE - Static variable in class com.alipay.remoting.config.BoltServerOption
-
- SRV_SSL_KEYSTORE - Static variable in class com.alipay.remoting.rpc.RpcConfigs
-
Server SSL keystore file path
- SRV_SSL_KEYSTORE_PASS - Static variable in class com.alipay.remoting.config.BoltServerOption
-
- SRV_SSL_KEYSTORE_PASS - Static variable in class com.alipay.remoting.rpc.RpcConfigs
-
Server SSL keystore password
- SRV_SSL_KEYSTORE_TYPE - Static variable in class com.alipay.remoting.config.BoltServerOption
-
- SRV_SSL_KEYTSTORE_YPE - Static variable in class com.alipay.remoting.rpc.RpcConfigs
-
Server SSL keystore type, JKS or pkcs12 for example.
- SRV_SSL_KMF_ALGO - Static variable in class com.alipay.remoting.config.BoltServerOption
-
- SRV_SSL_KMF_ALGO - Static variable in class com.alipay.remoting.rpc.RpcConfigs
-
Server SSL KeyManagerFactory algorithm.
- SRV_SSL_NEED_CLIENT_AUTH - Static variable in class com.alipay.remoting.config.BoltServerOption
-
- SRV_SSL_NEED_CLIENT_AUTH - Static variable in class com.alipay.remoting.rpc.RpcConfigs
-
Whether to enable server SSL client auth, default is false(disabled).
- SSL_HANDLER - Static variable in class com.alipay.remoting.constant.Constants
-
- start() - Method in class com.alipay.remoting.AbstractRemotingServer
-
Deprecated.
- start() - Method in class com.alipay.remoting.DefaultConnectionMonitor
-
Deprecated.
- start() - Method in interface com.alipay.remoting.RemotingServer
-
Deprecated.
- start() - Method in class com.alipay.remoting.rpc.RpcTaskScanner
-
Deprecated.
- startup() - Method in class com.alipay.remoting.AbstractLifeCycle
-
- startup() - Method in class com.alipay.remoting.AbstractRemotingServer
-
- startup() - Method in class com.alipay.remoting.DefaultClientConnectionManager
-
- startup() - Method in class com.alipay.remoting.DefaultConnectionManager
-
- startup() - Method in class com.alipay.remoting.DefaultConnectionMonitor
-
- startup() - Method in interface com.alipay.remoting.LifeCycle
-
- startup() - Method in class com.alipay.remoting.ReconnectManager
-
- startup() - Method in class com.alipay.remoting.rpc.RpcClient
-
- startup() - Method in class com.alipay.remoting.rpc.RpcTaskScanner
-
- stop() - Method in class com.alipay.remoting.AbstractRemotingServer
-
Deprecated.
- stop() - Method in class com.alipay.remoting.ReconnectManager
-
Deprecated.
- stop() - Method in interface com.alipay.remoting.RemotingServer
-
Deprecated.
- StringUtils - Class in com.alipay.remoting.util
-
Created by zhangg on 2016/7/14 21:07.
- StringUtils() - Constructor for class com.alipay.remoting.util.StringUtils
-
- Switch - Interface in com.alipay.remoting.config.switches
-
switch interface
- switches() - Method in class com.alipay.remoting.AbstractBoltClient
-
Deprecated.
- switches() - Method in class com.alipay.remoting.AbstractRemotingServer
-
Deprecated.
- switches() - Method in interface com.alipay.remoting.config.ConfigurableInstance
-
Deprecated.
- SyncMultiInterestUserProcessor<T> - Class in com.alipay.remoting.rpc.protocol
-
Extends this to process user defined request in SYNC way.
- SyncMultiInterestUserProcessor() - Constructor for class com.alipay.remoting.rpc.protocol.SyncMultiInterestUserProcessor
-
- SyncUserProcessor<T> - Class in com.alipay.remoting.rpc.protocol
-
Extends this to process user defined request in SYNC way.
- SyncUserProcessor() - Constructor for class com.alipay.remoting.rpc.protocol.SyncUserProcessor
-
- value() - Method in interface com.alipay.remoting.CommandCode
-
- value() - Method in enum com.alipay.remoting.CommonCommandCode
-
- value() - Method in enum com.alipay.remoting.rpc.protocol.RpcCommandCode
-
- valueOf(String) - Static method in enum com.alipay.remoting.CommonCommandCode
-
Returns the enum constant of this type with the specified name.
- valueOf(short) - Static method in enum com.alipay.remoting.CommonCommandCode
-
- valueOf(String) - Static method in class com.alipay.remoting.config.BoltOption
-
- valueOf(String, T) - Static method in class com.alipay.remoting.config.BoltOption
-
- valueOf(String) - Static method in enum com.alipay.remoting.config.configs.ConfigItem
-
Deprecated.
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.alipay.remoting.config.configs.ConfigType
-
Deprecated.
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.alipay.remoting.ConnectionEventType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.alipay.remoting.RejectedExecutionPolicy
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.alipay.remoting.ResponseStatus
-
Returns the enum constant of this type with the specified name.
- valueOf(short) - Static method in enum com.alipay.remoting.ResponseStatus
-
Convert to ResponseStatus.
- valueOf(String) - Static method in enum com.alipay.remoting.rpc.protocol.RpcCommandCode
-
Returns the enum constant of this type with the specified name.
- valueOf(short) - Static method in enum com.alipay.remoting.rpc.protocol.RpcCommandCode
-
- valueOf(int) - Static method in class com.alipay.remoting.rpc.protocol.RpcDeserializeLevel
-
Convert to String.
- values() - Static method in enum com.alipay.remoting.CommonCommandCode
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.alipay.remoting.config.configs.ConfigItem
-
Deprecated.
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.alipay.remoting.config.configs.ConfigType
-
Deprecated.
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.alipay.remoting.ConnectionEventType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.alipay.remoting.RejectedExecutionPolicy
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.alipay.remoting.ResponseStatus
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.alipay.remoting.rpc.protocol.RpcCommandCode
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- VERSION - Static variable in class com.alipay.remoting.Connection
-
Attribute key for version