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
