To import the package, first add the opApi.jar
file as a library dependency.
Open
OPClientConnection api = new OPClientConnection();
api.open("127.0.0.1", 60000);
OPClientConnection api = new OPClientConnection("127.0.0.1", 60000);
SendRequest
String serviceId = "getBrokerIdentity";
String requestJson = "{}";
String guid = api.sendRequest(serviceId, requestJson);
ReceiveReply
String replyJson = api.receiveReply(guid, 100);
DeleteRequest
SendRecvDelete
replyJson = api.sendRecvDelete(serviceId, requestJson, 100);
Close
Status Callback
import com.sun.jna.WString;
class StatusCallback implements OPStatusCallback {
@Override
public void statusCallback(
int connection, WString
id, WString statusMsg) {
System.out.println(statusMsg);
}
}
public class OPClient {
public static void main(String[] args) throws OPException, java.lang.InterruptedException {
StatusCallback callback = new StatusCallback();
OPClientConnection api = new OPClientConnection("127.0.0.1", 60000, callback);
}
}