Commit 624fe1d2 authored by legoc's avatar legoc
Browse files

Use of synchronizer port for publisher

parent 3aeb66c0
......@@ -129,7 +129,7 @@ void PublisherImpl::cancelWaitForSubscribers() {
request.pushInt(message::CANCEL);
// Create a request socket only for the request.
std::unique_ptr<RequestSocketImpl> requestSocket = application::This::getCom().createRequestSocket(application::This::getEndpoint().withPort(m_publisherPort + 1).toString());
std::unique_ptr<RequestSocketImpl> requestSocket = application::This::getCom().createRequestSocket(application::This::getEndpoint().withPort(m_synchronizerPort).toString());
requestSocket->request(request.toString());
}
......
......@@ -137,7 +137,7 @@ public class PublisherImpl {
}
public void cancelWaitForSubscribers() {
Endpoint endpoint = This.getEndpoint().withPort(publisherPort + 1);
Endpoint endpoint = This.getEndpoint().withPort(synchronizerPort);
JSONObject request = new JSONObject();
request.put(Messages.TYPE, Messages.CANCEL);
......
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