File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -35,13 +35,14 @@ namespace Ventilator
3535 // Sends batch of tasks to workers via that socket
3636 Console .WriteLine (" ====== VENTILATOR ======" );
3737 using (var sender = new PushSocket (" @tcp://*:5557" ))
38+ using (var sink = new PushSocket (" >tcp://localhost:5558" ))
3839 {
3940 Console .WriteLine (" Press enter when worker are ready" );
4041 Console .ReadLine ();
4142 // the first message it "0" and signals start of batch
4243 // see the Sink.csproj Program.cs file for where this is used
4344 Console .WriteLine (" Sending start of batch to Sink" );
44- sender .SendFrame (" 0" );
45+ sink .SendFrame (" 0" );
4546 Console .WriteLine (" Sending tasks to workers" );
4647 // initialise random number generator
4748 Random rand = new Random (0 );
You can’t perform that action at this time.
0 commit comments