This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
from 20485d8a2 [ISSUE #3719]Swap these 2 arguments so they are in the
correct order: expected value, actual value.[NetUtilsTest]
add f6cd4d3b4 [ISSUE #3729]Do some code
optimization[AdminShutdownProcessor]
No new revisions were added by this update.
Summary of changes:
.../grpc/processor/BatchPublishMessageProcessor.java | 2 +-
.../protocol/grpc/processor/HeartbeatProcessor.java | 3 ++-
.../protocol/grpc/processor/ReplyMessageProcessor.java | 2 +-
.../grpc/processor/RequestMessageProcessor.java | 2 +-
.../grpc/processor/SendAsyncMessageProcessor.java | 2 +-
.../core/protocol/grpc/push/WebhookPushRequest.java | 4 ++--
.../core/protocol/grpc/service/ProducerService.java | 2 +-
.../core/protocol/http/consumer/EventMeshConsumer.java | 2 +-
.../http/processor/AdminShutdownProcessor.java | 18 ++++++++----------
.../http/processor/BatchSendMessageProcessor.java | 4 ++--
.../http/processor/BatchSendMessageV2Processor.java | 4 ++--
.../core/protocol/http/push/AsyncHTTPPushRequest.java | 4 ++--
.../tcp/client/EventMeshTcpMessageDispatcher.java | 2 +-
.../core/protocol/tcp/client/session/Session.java | 2 +-
.../tcp/client/session/push/SessionPusher.java | 2 +-
.../tcp/client/session/send/SessionSender.java | 2 +-
.../core/protocol/tcp/client/task/HelloTask.java | 2 +-
.../core/protocol/tcp/client/task/MessageAckTask.java | 3 ++-
.../protocol/tcp/client/task/MessageTransferTask.java | 2 +-
.../core/protocol/tcp/client/task/RecommendTask.java | 2 +-
.../core/protocol/tcp/client/task/UnSubscribeTask.java | 3 ++-
.../java/org/apache/eventmesh/runtime/util/Utils.java | 3 ++-
22 files changed, 37 insertions(+), 35 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
