"\xFF\0\0\0\0\0\0\0\1\x7F"
that's a ZMTP connection; anything else and you can let the HTTP infrastructure deal with it.
Is there a way to detect when a PUB socket is dropping messages from the PUB end? I.e. have the publisher notice that messages are dropping and then do something with that information? Currently, I have the subscriber that can see missing nonces and then take action but was wondering if there was something I could do on the publisher side
Found noDrop
in the zeromq.js library
@drr00t are you dispatching your domain events within one application or between applications? Do you require an ordered stream of events? Do you require to archive and replay events at some later point in time?
Hi @sappo sorry by delay, yes my ideia i kind use zmq as a layer to propagate ordered domain events as they were generated, but i think that i can handler this with incremental id field for the generated events (all events are groups as a "transaction"), so i can propagate inside application (like a observer) and cross-applications (syncing different microservices)
@drr00t are you dispatching your domain events within one application or between applications? Do you require an ordered stream of events? Do you require to archive and replay events at some later point in time?
Hi @sappo sorry by delay, yes my ideia i kind use zmq as a layer to propagate ordered domain events as they were generated, but i think that i can handler this with incremental id field for the generated events (all events are groups as a "transaction"), so i can propagate inside application (like a observer) and cross-applications (syncing different microservices)
@drr00t You might want to look into dafka. I'll make some time next week to think more about your problem.
@drr00t are you dispatching your domain events within one application or between applications? Do you require an ordered stream of events? Do you require to archive and replay events at some later point in time?
Hi @sappo sorry by delay, yes my ideia i kind use zmq as a layer to propagate ordered domain events as they were generated, but i think that i can handler this with incremental id field for the generated events (all events are groups as a "transaction"), so i can propagate inside application (like a observer) and cross-applications (syncing different microservices)
@drr00t You might want to look into dafka. I'll make some time next week to think more about your problem.
ok, jdafka is it some kind of sdk for dafka? is it possibli generate a dotnet version? thank you @sappo