|
|
@@ -80,13 +80,12 @@ namespace VehicleControlSystem.ControlLayer.MQ
|
|
|
sub.Connect( "tcp://127.0.0.1:5566" );
|
|
|
sub.Subscribe( "" ); //All
|
|
|
sub.ReceiveReady += Sub_ReceiveReady;
|
|
|
-
|
|
|
+
|
|
|
req = new RequestSocket();
|
|
|
this.monitor = new NetMQMonitor( req, "inproc://rep.inproc", SocketEvents.Disconnected | SocketEvents.Connected );
|
|
|
this.monitor.Connected += ( s, a ) => { this.IsReqConnected = true; };
|
|
|
this.monitor.Disconnected += ( s, a ) => { this.IsReqConnected = false; };
|
|
|
this.monitor.StartAsync();
|
|
|
-
|
|
|
req.Connect( "tcp://127.0.0.1:5567" );
|
|
|
|
|
|
this.poller = new NetMQPoller { this.sub, this.rep };
|