Package org.fisco.bcos.sdk.client

Class JsonRpcService

java.lang.Object

org.fisco.bcos.sdk.client.JsonRpcService

public class JsonRpcService
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
Channel	channel
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper

Constructor Summary

Constructors

Constructor	Description
JsonRpcService(GroupManagerService groupManagerService, Channel channel, java.lang.Integer groupId)

Method Summary

Modifier and Type	Method	Description
<T extends JsonRpcResponse> void	asyncSendRequestToGroup(JsonRpcRequest request, java.lang.Class<T> responseType, RespCallback<T> callback)
<T extends JsonRpcResponse> void	asyncSendRequestToGroup(JsonRpcRequest request, MsgType messageType, java.lang.Class<T> responseType, RespCallback<T> callback)
<T extends JsonRpcResponse> void	asyncSendRequestToPeer(JsonRpcRequest request, java.lang.String peerIpAndPort, java.lang.Class<T> responseType, RespCallback<T> callback)
<T extends JsonRpcResponse> void	asyncSendRequestToPeer(JsonRpcRequest request, MsgType messageType, java.lang.String peerIpAndPort, java.lang.Class<T> responseType, RespCallback<T> callback)
<T extends JsonRpcResponse> void	asyncSendTransactionToGroup(JsonRpcRequest request, TransactionCallback callback, java.lang.Class<T> responseType)
Channel	getChannel()
GroupManagerService	getGroupManagerService()
protected <T extends JsonRpcResponse> T	parseResponseIntoJsonRpcResponse(JsonRpcRequest request, Response response, java.lang.Class<T> responseType)
<T extends JsonRpcResponse> T	sendRequestToGroup(JsonRpcRequest request, java.lang.Class<T> responseType)
<T extends JsonRpcResponse> T	sendRequestToGroup(JsonRpcRequest request, MsgType messageType, java.lang.Class<T> responseType)
<T extends JsonRpcResponse> T	sendRequestToPeer(JsonRpcRequest request, java.lang.String peerIpPort, java.lang.Class<T> responseType)
<T extends JsonRpcResponse> T	sendRequestToPeer(JsonRpcRequest request, MsgType messageType, java.lang.Class<T> responseType, java.lang.String peerIpPort)

Methods inherited from class java.lang.Object

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

Field Details

objectMapper

protected final com.fasterxml.jackson.databind.ObjectMapper objectMapper

channel

public final Channel channel

Constructor Details

JsonRpcService

public JsonRpcService(GroupManagerService groupManagerService, Channel channel, java.lang.Integer groupId)

Method Details

getChannel

public Channel getChannel()

getGroupManagerService

public GroupManagerService getGroupManagerService()

sendRequestToPeer

public <T extends JsonRpcResponse> T sendRequestToPeer(JsonRpcRequest request, java.lang.String peerIpPort, java.lang.Class<T> responseType)

sendRequestToGroup

public <T extends JsonRpcResponse> T sendRequestToGroup(JsonRpcRequest request, java.lang.Class<T> responseType)

sendRequestToPeer

public <T extends JsonRpcResponse> T sendRequestToPeer(JsonRpcRequest request, MsgType messageType, java.lang.Class<T> responseType, java.lang.String peerIpPort)

sendRequestToGroup

public <T extends JsonRpcResponse> T sendRequestToGroup(JsonRpcRequest request, MsgType messageType, java.lang.Class<T> responseType)

asyncSendRequestToPeer

public <T extends JsonRpcResponse> void asyncSendRequestToPeer(JsonRpcRequest request, java.lang.String peerIpAndPort, java.lang.Class<T> responseType, RespCallback<T> callback)

asyncSendRequestToPeer

public <T extends JsonRpcResponse> void asyncSendRequestToPeer(JsonRpcRequest request, MsgType messageType, java.lang.String peerIpAndPort, java.lang.Class<T> responseType, RespCallback<T> callback)

asyncSendRequestToGroup

public <T extends JsonRpcResponse> void asyncSendRequestToGroup(JsonRpcRequest request, java.lang.Class<T> responseType, RespCallback<T> callback)

asyncSendRequestToGroup

public <T extends JsonRpcResponse> void asyncSendRequestToGroup(JsonRpcRequest request, MsgType messageType, java.lang.Class<T> responseType, RespCallback<T> callback)

asyncSendTransactionToGroup

public <T extends JsonRpcResponse> void asyncSendTransactionToGroup(JsonRpcRequest request, TransactionCallback callback, java.lang.Class<T> responseType)

parseResponseIntoJsonRpcResponse

protected <T extends JsonRpcResponse> T parseResponseIntoJsonRpcResponse(JsonRpcRequest request, Response response, java.lang.Class<T> responseType)