Commit 53ee8bf1 authored by legoc's avatar legoc
Browse files

Create a request socket to cancel the publisher

parent 260fa990
......@@ -157,16 +157,13 @@ public class PublisherImpl {
CancelPublisherSyncCommand command = CancelPublisherSyncCommand.newBuilder().build();
request.add(command.toByteArray());
try {
Zmq.Msg reply = application.tryRequest(request, endpoint);
byte[] messageData = reply.getFirstData();
RequestResponse requestResponse = null;
requestResponse = RequestResponse.parseFrom(messageData);
} catch (InvalidProtocolBufferException e) {
throw new UnexpectedException("Cannot parse response");
}
// Create the request socket. We can create it here because it should be called only once.
RequestSocket requestSocket = application.createRequestSocket(endpoint);
requestSocket.request(request);
// Terminate the socket.
requestSocket.terminate();
}
public void send(byte[] data) {
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment