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 d6efef25e6af65e124e5508ac9619351e34de11f Author: Piyush <[email protected]> AuthorDate: Thu Apr 20 18:32:31 2023 +0530 Removed invalid code.[consumer_test.go] #3773 --- plugin/connector/rocketmq/consumer_test.go | 25 ------------------------- 1 file changed, 25 deletions(-) diff --git a/plugin/connector/rocketmq/consumer_test.go b/plugin/connector/rocketmq/consumer_test.go index a801cca..1590878 100644 --- a/plugin/connector/rocketmq/consumer_test.go +++ b/plugin/connector/rocketmq/consumer_test.go @@ -93,31 +93,6 @@ func TestConsumer_Subscribe(t *testing.T) { consumer.Shutdown() } -//func TestConsumer_Subscribe_Broker(t *testing.T) { -// properties := make(map[string]string) -// properties["access_points"] = "127.0.0.1:9876" -// properties["consumer_group"] = "test_group" -// consumer := NewConsumer() -// consumer.InitConsumer(properties) -// consumer.Start() -// -// listener := &connector.EventListener{ -// Consume: func(event *ce.Event, commitFunc connector.CommitFunc) error { -// fmt.Println(event) -// commitFunc(connector.CommitMessage) -// return nil -// }, -// } -// -// consumer.RegisterEventListener(listener) -// err := consumer.Subscribe("TopicTest") -// if err != nil { -// panic(err) -// } -// -// time.Sleep(100 * time.Second) -//} - func GetFullMessage() *primitive.Message { event := ce.NewEvent() event.SetSubject("TopicTest") --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
