Hey Gwen,
Receive and Send are meant to encapsulate the idea of sending or receiving
bytes. They are supposed to represent a send or receive that is in
progress. The purpose of these interfaces is to allow sends and receives
using transferTo when we need to do that on the server side, this require
1. The controller -> broker communication doesn't have to be blocking. It
just needs to call a callback on completion of a request. We can leave this
out for now. It just means that we can't run the inter cluster
communication through non-plaintext port until we port this code to the
common network
Hi,
I started work on converting core to use common network code and I ran into
two questions that hopefully someone can help me with:
1. BlockingChannel - Looks like the inter-broker communication is mostly
through blocking channel. There's no client equivalent (i.e client code is
all non-blocki