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
35
35
// Sends batch of tasks to workers via that socket
36
36
Console .WriteLine (" ====== VENTILATOR ======" );
37
37
using (var sender = new PushSocket (" @tcp://*:5557" ))
38
+ using (var sink = new PushSocket (" >tcp://localhost:5558" ))
38
39
{
39
40
Console .WriteLine (" Press enter when worker are ready" );
40
41
Console .ReadLine ();
41
42
// the first message it "0" and signals start of batch
42
43
// see the Sink.csproj Program.cs file for where this is used
43
44
Console .WriteLine (" Sending start of batch to Sink" );
44
- sender .SendFrame (" 0" );
45
+ sink .SendFrame (" 0" );
45
46
Console .WriteLine (" Sending tasks to workers" );
46
47
// initialise random number generator
47
48
Random rand = new Random (0 );
You can’t perform that action at this time.
0 commit comments