This is an automated email from the ASF dual-hosted git repository. chenguangsheng pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/eventmesh-go.git
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]
