NodeRPCConnection.java вместо NodeRPCConnection.kt - PullRequest
0 голосов
/ 26 марта 2019

Я хочу подключить RPC-соединение, используя java вместо kotlin. В корде 4.0 они дали использование kotlin, но мне это нужно в java.

Я пытался использовать Java, но он не работает ...

@RestController
@RequestMapping("/api/example/")

1 Ответ

0 голосов
/ 27 марта 2019

ниже фрагмент кода из модуля WebFlux, который подключается к корда-узлу с помощью RPC:

@Component
public class NodeRPCConnection implements AutoCloseable {
// The host of the node we are connecting to.
@Value("${config.rpc.host}")
private String host;
// The RPC port of the node we are connecting to.
@Value("${config.rpc.username}")
private String username;
// The username for logging into the RPC client.
@Value("${config.rpc.password}")
private String password;
// The password for logging into the RPC client.
@Value("${config.rpc.port}")
private int rpcPort;

private CordaRPCConnection rpcConnection;
private CordaRPCOps proxy;



@PostConstruct
public void initialiseNodeRPCConnection() {
    NetworkHostAndPort rpcAddress = new NetworkHostAndPort(host, rpcPort);
    CordaRPCClient rpcClient = new CordaRPCClient(rpcAddress);
    rpcConnection = rpcClient.start(username, password);
    proxy = rpcConnection.getProxy();
}

@PreDestroy
public void close() {
    rpcConnection.notifyServerAndClose();
}

public CordaRPCOps getProxy() {
    return proxy;
}
}
...