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 d182e55ae [ISSUE #4031] Specifies the default character set (#4057)
add 3f49cd4b7 [ISSUE #3485]Optimize Grpc protocol for Java (#3746)
No new revisions were added by this update.
Summary of changes:
build.gradle | 16 +-
eventmesh-common/build.gradle | 2 +-
...tpMethod.java => EventMeshDataContentType.java} | 13 +-
.../eventmesh/common/protocol/HeartbeatItem.java | 16 +-
.../common/protocol/SubscriptionMode.java | 8 +-
.../common/protocol/SubscriptionType.java | 7 +-
.../protocol/grpc/cloudevents/CloudEvent.java | 3550 ++++++++++++++++++
.../protocol/grpc/cloudevents/CloudEventBatch.java | 772 ++++
.../grpc/cloudevents/CloudEventBatchOrBuilder.java | 33 +
.../grpc/cloudevents/CloudEventOrBuilder.java | 174 +
.../ConsumerServiceGrpc.java | 295 +-
.../grpc/cloudevents/EventMeshCloudEvents.java | 105 +
.../grpc/cloudevents/EventMeshGrpcService.java | 70 +
.../HeartbeatServiceGrpc.java | 170 +-
.../grpc/cloudevents/PublisherServiceGrpc.java | 632 ++++
...r.java => BatchEventMeshCloudEventWrapper.java} | 14 +-
.../protocol/{http => grpc}/common/ClientType.java | 21 +-
.../grpc/common/EventMeshCloudEventUtils.java | 427 +++
...rapper.java => EventMeshCloudEventWrapper.java} | 14 +-
...SimpleMessageWrapper.java => ProtoSupport.java} | 28 +-
.../common/protocol/grpc/common/ProtocolKey.java | 32 +-
.../common/protocol/grpc/common/Response.java | 23 +-
.../common/protocol/grpc/common/StatusCode.java | 4 +-
.../protocol/grpc/common/SubscriptionReply.java | 34 +-
.../common/protocol/grpc/protos/BatchMessage.java | 2453 ------------
.../grpc/protos/BatchMessageOrBuilder.java | 84 -
.../common/protocol/grpc/protos/EventmeshGrpc.java | 283 --
.../common/protocol/grpc/protos/Heartbeat.java | 1988 ----------
.../protocol/grpc/protos/HeartbeatOrBuilder.java | 93 -
.../protocol/grpc/protos/PublisherServiceGrpc.java | 476 ---
.../common/protocol/grpc/protos/RequestHeader.java | 1507 --------
.../grpc/protos/RequestHeaderOrBuilder.java | 147 -
.../common/protocol/grpc/protos/Response.java | 701 ----
.../protocol/grpc/protos/ResponseOrBuilder.java | 57 -
.../common/protocol/grpc/protos/SimpleMessage.java | 1802 ---------
.../grpc/protos/SimpleMessageOrBuilder.java | 144 -
.../common/protocol/grpc/protos/Subscription.java | 3932 --------------------
.../grpc/protos/SubscriptionOrBuilder.java | 97 -
.../eventmesh/common/utils/RandomStringUtils.java | 7 +
.../grpc/common/EventMeshCloudEventUtilsTest.java | 271 ++
eventmesh-examples/build.gradle | 2 +-
.../eventmesh-protocol-cloudevents/build.gradle | 7 +
.../cloudevents/CloudEventsProtocolAdaptor.java | 28 +-
.../cloudevents/CloudEventsProtocolConstant.java | 2 +
.../GrpcEventMeshCloudEventProtocolResolver.java | 66 +
.../resolver/grpc/GrpcMessageProtocolResolver.java | 182 -
.../eventmesh-protocol-grpc/build.gradle | 4 +-
.../src/main/proto/eventmesh-cloudevents.proto | 86 +
.../src/main/proto/eventmesh-service.proto | 58 +
.../eventmesh-protocol-meshmessage/build.gradle | 7 +
.../meshmessage/MeshMessageProtocolAdaptor.java | 34 +-
.../meshmessage/MeshMessageProtocolConstant.java | 2 +
.../GrpcEventMeshCloudEventProtocolResolver.java | 70 +
.../resolver/grpc/GrpcMessageProtocolResolver.java | 275 --
eventmesh-runtime/build.gradle | 1 +
.../runtime/boot/EventMeshGrpcServer.java | 8 +-
.../protocol/grpc/consumer/ConsumerManager.java | 3 +-
.../protocol/grpc/consumer/EventMeshConsumer.java | 7 +-
.../consumergroup/ConsumerGroupClient.java | 8 +-
.../consumergroup/ConsumerGroupTopicConfig.java | 2 +-
.../consumer/consumergroup/StreamTopicConfig.java | 30 +-
.../consumer/consumergroup/WebhookTopicConfig.java | 3 +-
.../AbstractPublishBatchCloudEventProcessor.java | 105 +
.../AbstractPublishCloudEventProcessor.java | 104 +
.../processor/BatchPublishCloudEventProcessor.java | 92 +
.../processor/BatchPublishMessageProcessor.java | 146 -
.../grpc/processor/HeartbeatProcessor.java | 73 +-
.../processor/PublishCloudEventsProcessor.java | 87 +
.../protocol/grpc/processor/PublishProcessor.java | 20 +-
.../grpc/processor/ReplyMessageProcessor.java | 60 +-
.../grpc/processor/RequestCloudEventProcessor.java | 98 +
.../grpc/processor/RequestMessageProcessor.java | 156 -
.../grpc/processor/SendAsyncMessageProcessor.java | 146 -
.../grpc/processor/SubscribeProcessor.java | 62 +-
.../grpc/processor/SubscribeStreamProcessor.java | 62 +-
.../grpc/processor/UnsubscribeProcessor.java | 46 +-
.../protocol/grpc/push/AbstractPushRequest.java | 29 +-
.../core/protocol/grpc/push/HandleMsgContext.java | 2 +-
.../core/protocol/grpc/push/StreamPushRequest.java | 36 +-
.../protocol/grpc/push/WebhookPushRequest.java | 57 +-
.../protocol/grpc/service/ConsumerService.java | 83 +-
.../protocol/grpc/service/HeartbeatService.java | 15 +-
...{ProducerService.java => PublisherService.java} | 91 +-
.../core/protocol/grpc/service/ServiceUtils.java | 212 +-
eventmesh-sdks/eventmesh-sdk-java/build.gradle | 3 +-
.../grpc/config/EventMeshGrpcClientConfig.java | 5 +
.../grpc/consumer/EventMeshGrpcConsumer.java | 195 +-
.../client/grpc/consumer/SubStreamHandler.java | 82 +-
.../exception/ProtocolNotSupportException.java | 80 +
.../client/grpc/producer/CloudEventProducer.java | 101 +-
.../grpc/producer/EventMeshGrpcProducer.java | 6 +-
.../grpc/producer/EventMeshMessageProducer.java | 52 +-
.../client/grpc/producer/GrpcProducer.java | 4 +-
.../client/grpc/util/EventMeshClientUtil.java | 265 --
.../grpc/util/EventMeshCloudEventBuilder.java | 309 ++
.../grpc/consumer/EventMeshGrpcConsumerTest.java | 65 +-
.../grpc/producer/CloudEventProducerTest.java | 43 +-
.../grpc/producer/EventMeshGrpcProducerTest.java | 40 +-
.../producer/EventMeshMessageProducerTest.java | 32 +-
.../client/grpc/util/EventMeshClientUtilTest.java | 176 -
.../grpc/util/EventMeshCloudEventBuilderTest.java | 170 +
.../eventmesh-storage-kafka/build.gradle | 2 +-
102 files changed, 8563 insertions(+), 16236 deletions(-)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/enums/{HttpMethod.java
=> EventMeshDataContentType.java} (80%)
copy
eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/HeartbeatItem.java
(82%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/cloudevents/CloudEvent.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/cloudevents/CloudEventBatch.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/cloudevents/CloudEventBatchOrBuilder.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/cloudevents/CloudEventOrBuilder.java
rename
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/{protos
=> cloudevents}/ConsumerServiceGrpc.java (54%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/cloudevents/EventMeshCloudEvents.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/cloudevents/EventMeshGrpcService.java
rename
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/{protos
=> cloudevents}/HeartbeatServiceGrpc.java (58%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/cloudevents/PublisherServiceGrpc.java
rename
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/{BatchMessageWrapper.java
=> BatchEventMeshCloudEventWrapper.java} (71%)
copy eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/{http
=> grpc}/common/ClientType.java (76%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/EventMeshCloudEventUtils.java
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/{SimpleMessageWrapper.java
=> EventMeshCloudEventWrapper.java} (73%)
rename
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/{SimpleMessageWrapper.java
=> ProtoSupport.java} (57%)
copy
eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/Response.java
(79%)
copy
eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/SubscriptionReply.java
(62%)
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/BatchMessage.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/BatchMessageOrBuilder.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/EventmeshGrpc.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/Heartbeat.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/HeartbeatOrBuilder.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/PublisherServiceGrpc.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/RequestHeader.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/RequestHeaderOrBuilder.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/Response.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/ResponseOrBuilder.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/SimpleMessage.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/SimpleMessageOrBuilder.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/Subscription.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/SubscriptionOrBuilder.java
create mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/grpc/common/EventMeshCloudEventUtilsTest.java
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/grpc/GrpcEventMeshCloudEventProtocolResolver.java
delete mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/grpc/GrpcMessageProtocolResolver.java
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-grpc/src/main/proto/eventmesh-cloudevents.proto
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-grpc/src/main/proto/eventmesh-service.proto
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/grpc/GrpcEventMeshCloudEventProtocolResolver.java
delete mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/grpc/GrpcMessageProtocolResolver.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/AbstractPublishBatchCloudEventProcessor.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/AbstractPublishCloudEventProcessor.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/BatchPublishCloudEventProcessor.java
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/BatchPublishMessageProcessor.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/PublishCloudEventsProcessor.java
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/BaseRequestBody.java
=>
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/PublishProcessor.java
(72%)
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/RequestCloudEventProcessor.java
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/RequestMessageProcessor.java
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/SendAsyncMessageProcessor.java
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/{ProducerService.java
=> PublisherService.java} (53%)
create mode 100644
eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/exception/ProtocolNotSupportException.java
delete mode 100644
eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtil.java
create mode 100644
eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/util/EventMeshCloudEventBuilder.java
delete mode 100644
eventmesh-sdks/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtilTest.java
create mode 100644
eventmesh-sdks/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/grpc/util/EventMeshCloudEventBuilderTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
