Emelia Lei
Emelia Lei
Broker side: - Added support for the authentication protocol. - Introduced a new `AuthenticationEvent` event type. - Implemented the authenticator component to handle authentication logic, using `AuthenticationContext` to encapsulate relevant...
Similar to PR #581, this PR invokes CSL commit callback for QueueAssignmentAdvisories and the queue assignment part of LeaderAdvisory, effectively making CSL the source of truth.
Similar to PR https://github.com/bloomberg/blazingmq/pull/581, this PR invokes CSL commit callback for PartitionPrimaryAdvisory and the partition primary assignment part of LeaderAdvisory, effectively making CSL the source of truth.
Add d-trace support for PUT and PUSH messages. Producers serialize the current d-trace span (if present) into a message property and consumers will deserialize the span and create a child...
This PR introduces several refactors and preparations for upcoming authentication support: - Adds an `Authenticator` class to encapsulate authentication logic. - Migrates connection initialization logic from `InitialConnectionHandler` to `InitialConnectionContext`. Note...
# Summary This PR introduces optional client authentication (and scheduled re‑authentication) into the BlazingMQ SDK by inserting an `AuthenticatedChannelFactory` layer between the existing stat and negotiated channel factories. When a...