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 d6efef2 Removed invalid code.[consumer_test.go] #3773
new d9b782b Merge pull request #5 from piyush280599/patch-3
d6efef2 is described below
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]
