This is an automated email from the ASF dual-hosted git repository.
walleliu pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/eventmesh-go.git
The following commit(s) were added to refs/heads/main by this push:
new 19fb439 Removed invalid code.[producer_test.go] #3774
new 9dabd4b Merge pull request #4 from piyush280599/patch-2
19fb439 is described below
commit 19fb439312cb931336f11d69e5e739398d6bc7d0
Author: Piyush <[email protected]>
AuthorDate: Thu Apr 20 18:30:35 2023 +0530
Removed invalid code.[producer_test.go] #3774
---
plugin/connector/rocketmq/producer_test.go | 25 -------------------------
1 file changed, 25 deletions(-)
diff --git a/plugin/connector/rocketmq/producer_test.go
b/plugin/connector/rocketmq/producer_test.go
index 576fe41..6ea0299 100644
--- a/plugin/connector/rocketmq/producer_test.go
+++ b/plugin/connector/rocketmq/producer_test.go
@@ -187,28 +187,3 @@ func GetFullEvent() *ce.Event {
return &event
}
-//func TestProducer_Publish_Broker(t *testing.T) {
-// properties := make(map[string]string)
-// properties["access_points"] = "127.0.0.1:9876"
-// producer := NewProducer()
-// producer.InitProducer(properties)
-// producer.Start()
-//
-// var wg sync.WaitGroup
-// wg.Add(1)
-// callback := &connector.SendCallback{
-// OnSuccess: func(result *connector.SendResult) {
-// require.True(t, result.Topic == "TopicTest")
-// wg.Done()
-// },
-// OnError: func(result *connector.ErrorResult) {
-// panic(result.Err)
-// },
-// }
-//
-// err := producer.Publish(context.Background(), GetFullEvent(), callback)
-// require.True(t, err == nil)
-//
-// wg.Wait()
-// producer.Shutdown()
-//}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
