This is an automated email from the ASF dual-hosted git repository.
maciej pushed a change to branch io_uring_final
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 8cb27e1b3 handle not found properly in http
add 191f7e8ae align java SDK with new server implementation
No new revisions were added by this update.
Summary of changes:
.../apache/iggy/async/AsyncConsumerExample.java | 9 +-
.../java/org/apache/iggy/async/AsyncProducer.java | 9 +-
.../org/apache/iggy/consumer/SimpleConsumer.java | 5 +-
.../org/apache/iggy/producer/SimpleProducer.java | 3 +-
.../apache/iggy/client/async/StreamsClient.java | 2 +-
.../org/apache/iggy/client/async/TopicsClient.java | 35 ++--
.../client/async/tcp/AsyncBytesSerializer.java | 23 +++
.../iggy/client/async/tcp/MessagesTcpClient.java | 25 +--
.../iggy/client/async/tcp/StreamsTcpClient.java | 5 +-
.../iggy/client/async/tcp/TopicsTcpClient.java | 4 +-
.../iggy/client/blocking/ConsumerGroupsClient.java | 6 +-
.../apache/iggy/client/blocking/StreamsClient.java | 2 +-
.../apache/iggy/client/blocking/TopicsClient.java | 3 -
.../blocking/http/ConsumerGroupsHttpClient.java | 7 +-
.../client/blocking/http/StreamsHttpClient.java | 6 +-
.../client/blocking/http/TopicsHttpClient.java | 5 +-
.../iggy/client/blocking/tcp/BytesSerializer.java | 13 ++
.../blocking/tcp/ConsumerGroupsTcpClient.java | 5 +-
.../blocking/tcp/ConsumerOffsetTcpClient.java | 4 +-
.../client/blocking/tcp/MessagesTcpClient.java | 3 +-
.../iggy/client/blocking/tcp/StreamsTcpClient.java | 5 +-
.../iggy/client/blocking/tcp/TopicsTcpClient.java | 5 +-
.../test/java/org/apache/iggy/TestConstants.java | 14 ++
.../client/async/AsyncClientIntegrationTest.java | 228 ++++++++++-----------
.../iggy/client/async/AsyncPollMessageTest.java | 147 +++++++------
.../blocking/ConsumerGroupsClientBaseTest.java | 59 +++---
.../blocking/ConsumerOffsetsClientBaseTest.java | 21 +-
.../iggy/client/blocking/IntegrationTest.java | 36 ++--
.../client/blocking/MessagesClientBaseTest.java | 15 +-
.../client/blocking/PartitionsClientBaseTest.java | 12 +-
.../blocking/PersonalAccessTokensBaseTest.java | 2 +-
.../iggy/client/blocking/StreamClientBaseTest.java | 22 +-
.../iggy/client/blocking/TopicsClientBaseTest.java | 24 +--
.../iggy/client/blocking/UsersClientBaseTest.java | 4 +-
.../blocking/tcp/ConsumerGroupsTcpClientTest.java | 18 +-
35 files changed, 409 insertions(+), 377 deletions(-)
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/TestConstants.java
