[incubator-eventmesh] branch eventmesh-server-go updated (e5c57fa6 -> c062edbc)

[wa...@apache.org]

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

walleliu pushed a change to branch eventmesh-server-go
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git


    from e5c57fa6 Merge pull request #1267 from horoc/go-server-rocketmq-message-convert
     new 6a3b4b73 add go server rocketmq consumer
     new 9b027fe1 fix int str convert
     new c062edbc Merge pull request #1289 from horoc/go-server-add-rocketmq-consumer

The 1331 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 eventmesh-server-go/plugin/connector/connector.go  |  25 ++-
 .../connector/rocketmq/client/rocketmq_consumer.go | 159 ++++++++++++++
 .../connector/rocketmq/client/rocketmq_producer.go | 168 +++++++++++++++
 .../connector/rocketmq/config/client_config.go     |  41 ++++
 .../constants/rocketmq_message_properties.go       |  61 ++++++
 .../plugin/connector/rocketmq/consumer.go          | 221 +++++++++++++++++++
 .../rocketmq/convert/message_ext_convert.go        |  25 ++-
 .../connector/{standalone => rocketmq}/factory.go  |  61 +++---
 .../plugin/connector/rocketmq/producer.go          | 236 +++++++++++++++++++++
 .../connector/{standalone => rocketmq}/resource.go |   6 +-
 .../plugin/connector/rocketmq/utils/oms_util.go    |  17 +-
 .../plugin/connector/standalone/consumer.go        |   4 +-
 .../plugin/connector/standalone/producer.go        |  13 +-
 .../standalone/standalone_connector_test.go        |  22 +-
 14 files changed, 985 insertions(+), 74 deletions(-)
 create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/client/rocketmq_consumer.go
 create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/client/rocketmq_producer.go
 create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/config/client_config.go
 create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/constants/rocketmq_message_properties.go
 create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/consumer.go
 copy eventmesh-sdk-go/common/id/id_uuid.go => eventmesh-server-go/plugin/connector/rocketmq/convert/message_ext_convert.go (56%)
 copy eventmesh-server-go/plugin/connector/{standalone => rocketmq}/factory.go (75%)
 create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/producer.go
 copy eventmesh-server-go/plugin/connector/{standalone => rocketmq}/resource.go (91%)
 copy eventmesh-sdk-go/common/protocol/subscription_mode.go => eventmesh-server-go/plugin/connector/rocketmq/utils/oms_util.go (78%)


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org