The primary change introduced in this PR is the conversion of BrokerMessage from a generic definition (Arc<dyn Any + Send + Sync>) to an enum. While the generic approach is convenient, it requires the message to be downcast each time a match occurs - usually as a reference. The change allows for more compact matching and should also open the door for a refactor of the connection and replication flow (more to come on that in a future PR).
The primary change introduced in this PR is the conversion of
BrokerMessagefrom a generic definition (Arc<dyn Any + Send + Sync>) to anenum. While the generic approach is convenient, it requires the message to be downcast each time a match occurs - usually as a reference. The change allows for more compact matching and should also open the door for a refactor of the connection and replication flow (more to come on that in a future PR).Other minor changes:
StoBlobEvent->StoreBlobEventetc.)*imports with explicit imports (frombrokermodule)