You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@iggy.apache.org by hg...@apache.org on 2026/03/10 11:15:47 UTC

(iggy) branch drain-bus updated (7aac5d31f -> be67b221f)

This is an automated email from the ASF dual-hosted git repository.

hgruszecki pushed a change to branch drain-bus
in repository https://gitbox.apache.org/repos/asf/iggy.git


    from 7aac5d31f feat(message_bus): add drain method to collect buffered outbound messages
     add 3b29d336d refactor(java): use generation-based auth for pooled channels (#2910)
     add 5af953c17 test(java): add async-specific tests for ConsumerGroupsTcpClient (#2890)
     add be67b221f Merge branch 'master' into drain-bus

No new revisions were added by this update.

Summary of changes:
 .../iggy/client/async/tcp/AsyncIggyTcpClient.java  |   4 +-
 .../iggy/client/async/tcp/AsyncTcpConnection.java  | 278 +++++------
 .../iggy/client/async/tcp/IggyAuthenticator.java   |  46 +-
 .../iggy/client/async/tcp/IggyFrameEncoder.java    |  24 +-
 .../client/async/AsyncConnectionPoolAuthTest.java  | 263 ++++++++++
 .../iggy/client/async/AsyncConsumerGroupsTest.java | 529 +++++++++++++++++++++
 6 files changed, 959 insertions(+), 185 deletions(-)
 create mode 100644 foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/AsyncConnectionPoolAuthTest.java
 create mode 100644 foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/AsyncConsumerGroupsTest.java