christopherread / obvs.netmq Goto Github PK

var serviceBus = ServiceBus
    .Configure()
    .WithNetMqEndpoints<IMyServiceMessage>()
    .Named("MyService")
    .BindToAddress("inproc://test")
    .OnPort(default)
    .SerializedAsNetJson()
    .AsClientAndServer()
    .UsingConsoleLogging()
    .Create()
;
return serviceBus;

bus.Commands.Subscribe(
    async (c) =>
    {
       Console.WriteLine("RECV(COMMAND): {0}", c.GetType().Name);
       Console.WriteLine("sending event");
       await bus.PublishAsync(new MyEvent($"OK: {c}")).GetAwaiter().GetResult();
    }
);

 bus.Events.Subscribe(
                (e) =>
                {
                    _logger.LogInformation("RECV(EVENT): {e}", e);
                });

var serverPair = new NetMQCertificate();
using var server = new DealerSocket();
server.Options.CurveServer = true;
server.Options.CurveCertificate = serverPair;
server.Bind($"tcp://127.0.0.1:55367");

var clientPair = new NetMQCertificate();
using var client = new DealerSocket();
client.Options.CurveServerKey = serverPair.PublicKey;
client.Options.CurveCertificate = clientPair;
client.Connect("tcp://127.0.0.1:55367");