程序包 com.webank.wedpr.sdk.jni.transport.impl

类 TransportImpl

java.lang.Object

com.webank.wedpr.sdk.jni.transport.impl.TransportImpl

所有已实现的接口:

WeDPRTransport

public class TransportImpl
extends Object
implements WeDPRTransport

构造器概要

构造器

限定符	构造器	说明
protected	TransportImpl(Transport transport, TransportConfig transportConfig)

方法概要

修饰符和类型	方法	说明
void	asyncGetPeers(GetPeersCallback handler)	async get peers information
void	asyncSendMessageByAgency(String topic, String agency, byte[] payload, int seq, int timeout, MessageErrorCallback errorCallback, MessageCallback msgCallback)	send message by the agency
void	asyncSendMessageByComponent(String topic, String dstInst, String component, byte[] payload, int seq, int timeout, MessageErrorCallback errorCallback, MessageCallback msgCallback)
void	asyncSendMessageByNodeID(String topic, byte[] dstNode, byte[] payload, int seq, int timeout, MessageErrorCallback errorCallback, MessageCallback msgCallback)	async send message by the nodeID
void	asyncSendMessageByTopic(String topic, String dstInst, byte[] payload, int seq, int timeout, MessageErrorCallback errorCallback, MessageCallback msgCallback)	send message by the topic(will register firstly)
void	asyncSendResponse(byte[] dstNode, String traceID, byte[] payload, int seq, MessageErrorCallback errorCallback)	send response to given node
static WeDPRTransport	build(TransportConfig transportConfig)
List<ServiceMeta.EntryPointMeta>	getAliveEntryPoints(String serviceName)
TransportConfig	getTransportConfig()
IMessage	peek(String topic)
IMessage	pop(String topic, int timeout)
void	pushByComponent(String topic, String dstInst, String component, int seq, byte[] payload, int timeout)
void	pushByInst(String topic, String dstInst, int seq, byte[] payload, int timeout)
void	pushByNodeID(String topic, byte[] dstNodeID, int seq, byte[] payload, int timeout)
void	registerComponent(String component)	register the component
void	registerComponentHandler(String component, MessageDispatcherCallback messageDispatcherCallback)	register handlers according to component
void	registerService(String serviceName, String entryPoint)
void	registerTopic(String topic)	register the topic
void	registerTopicHandler(String topic, MessageDispatcherCallback messageHandler)	register the message handler
void	removeTopic(String topic)
List<String>	selectNodeListByPolicy(RouteType routeType, String dstInst, String dstComponent, String dstNode)
void	start()
void	stop()
void	unRegisterComponent(String component)	unregister the component
void	unRegisterTopic(String topic)	unRegister the topic

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

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

构造器详细资料

TransportImpl

protected TransportImpl(Transport transport,
 TransportConfig transportConfig)
                 throws WeDPRSDKException

抛出:

WeDPRSDKException

方法详细资料

build

public static WeDPRTransport build(TransportConfig transportConfig)
                            throws WeDPRSDKException

抛出:

WeDPRSDKException

start

public void start()

指定者:

start 在接口中 WeDPRTransport

stop

public void stop()

指定者:

stop 在接口中 WeDPRTransport

registerComponent

public void registerComponent(String component)

从接口复制的说明: WeDPRTransport

register the component

指定者:

registerComponent 在接口中 WeDPRTransport

参数:

component - the component used to router

unRegisterComponent

public void unRegisterComponent(String component)

从接口复制的说明: WeDPRTransport

unregister the component

指定者:

unRegisterComponent 在接口中 WeDPRTransport

参数:

component - the component used to route

registerTopic

public void registerTopic(String topic)
                   throws Exception

register the topic

指定者:

registerTopic 在接口中 WeDPRTransport

参数:

topic - the topic used to route

抛出:

Exception - failed case

unRegisterTopic

public void unRegisterTopic(String topic)
                     throws Exception

unRegister the topic

指定者:

unRegisterTopic 在接口中 WeDPRTransport

参数:

topic - the topic used to route

抛出:

Exception - failed case

registerComponentHandler

public void registerComponentHandler(String component,
 MessageDispatcherCallback messageDispatcherCallback)

register handlers according to component

指定者:

registerComponentHandler 在接口中 WeDPRTransport

参数:

component - the component of the message should handled by the given callback

messageDispatcherCallback - the message callback

asyncGetPeers

public void asyncGetPeers(GetPeersCallback handler)

async get peers information

指定者:

asyncGetPeers 在接口中 WeDPRTransport

参数:

handler - the handler that handle the peersInfo

registerTopicHandler

public void registerTopicHandler(String topic,
 MessageDispatcherCallback messageHandler)

从接口复制的说明: WeDPRTransport

register the message handler

指定者:

registerTopicHandler 在接口中 WeDPRTransport

参数:

topic - the topic

messageHandler - the message handler

asyncSendMessageByNodeID

public void asyncSendMessageByNodeID(String topic,
 byte[] dstNode,
 byte[] payload,
 int seq,
 int timeout,
 MessageErrorCallback errorCallback,
 MessageCallback msgCallback)

async send message by the nodeID

指定者:

asyncSendMessageByNodeID 在接口中 WeDPRTransport

参数:

topic - the topic

dstNode - the dstNode

payload - the payload

seq - the seq of the payload

timeout - the timeout setting

errorCallback - the handler called after receive the message related to the topic

asyncSendMessageByAgency

public void asyncSendMessageByAgency(String topic,
 String agency,
 byte[] payload,
 int seq,
 int timeout,
 MessageErrorCallback errorCallback,
 MessageCallback msgCallback)

send message by the agency

指定者:

asyncSendMessageByAgency 在接口中 WeDPRTransport

参数:

topic - the topic

agency - the agency

payload - the payload

seq - the seq

timeout - the timeout

errorCallback - the handler called after receive the message related to the topic

asyncSendMessageByComponent

public void asyncSendMessageByComponent(String topic,
 String dstInst,
 String component,
 byte[] payload,
 int seq,
 int timeout,
 MessageErrorCallback errorCallback,
 MessageCallback msgCallback)

指定者:

asyncSendMessageByComponent 在接口中 WeDPRTransport

asyncSendMessageByTopic

public void asyncSendMessageByTopic(String topic,
 String dstInst,
 byte[] payload,
 int seq,
 int timeout,
 MessageErrorCallback errorCallback,
 MessageCallback msgCallback)

send message by the topic(will register firstly)

指定者:

asyncSendMessageByTopic 在接口中 WeDPRTransport

参数:

topic - the topic(used to route too

payload - the payload(the payload)

seq - the seq(the seq)

timeout - the timeout

errorCallback - the handler

asyncSendResponse

public void asyncSendResponse(byte[] dstNode,
 String traceID,
 byte[] payload,
 int seq,
 MessageErrorCallback errorCallback)

从接口复制的说明: WeDPRTransport

send response to given node

指定者:

asyncSendResponse 在接口中 WeDPRTransport

参数:

dstNode - the node that should receive the response

traceID - the traceID of the response

payload - the payload

seq - the seq

errorCallback - the error callback

removeTopic

public void removeTopic(String topic)
                 throws WeDPRSDKException

指定者:

removeTopic 在接口中 WeDPRTransport

参数:

topic - the topic to remove

抛出:

WeDPRSDKException

pushByNodeID

public void pushByNodeID(String topic,
 byte[] dstNodeID,
 int seq,
 byte[] payload,
 int timeout)
                  throws WeDPRSDKException

指定者:

pushByNodeID 在接口中 WeDPRTransport

抛出:

WeDPRSDKException

pushByComponent

public void pushByComponent(String topic,
 String dstInst,
 String component,
 int seq,
 byte[] payload,
 int timeout)
                     throws WeDPRSDKException

指定者:

pushByComponent 在接口中 WeDPRTransport

抛出:

WeDPRSDKException

pushByInst

public void pushByInst(String topic,
 String dstInst,
 int seq,
 byte[] payload,
 int timeout)
                throws WeDPRSDKException

指定者:

pushByInst 在接口中 WeDPRTransport

抛出:

WeDPRSDKException

pop

public IMessage pop(String topic,
 int timeout)
             throws WeDPRSDKException

指定者:

pop 在接口中 WeDPRTransport

抛出:

WeDPRSDKException

peek

public IMessage peek(String topic)

指定者:

peek 在接口中 WeDPRTransport

selectNodeListByPolicy

public List<String> selectNodeListByPolicy(RouteType routeType,
 String dstInst,
 String dstComponent,
 String dstNode)

指定者:

selectNodeListByPolicy 在接口中 WeDPRTransport

getAliveEntryPoints

public List<ServiceMeta.EntryPointMeta> getAliveEntryPoints(String serviceName)

指定者:

getAliveEntryPoints 在接口中 WeDPRTransport

registerService

public void registerService(String serviceName,
 String entryPoint)
                     throws Exception

指定者:

registerService 在接口中 WeDPRTransport

抛出:

Exception

getTransportConfig

public TransportConfig getTransportConfig()

指定者:

getTransportConfig 在接口中 WeDPRTransport