This is an automated email from the ASF dual-hosted git repository.
mikexue 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 0cb92db Update consumer.go
new c8345a4 Merge pull request #11 from harshithasudhakar/patch-5
0cb92db is described below
commit 0cb92dbf160270b0f18c195bd70dc3523b1bf04d
Author: Harshitha Sudhakar
<[email protected]>
AuthorDate: Mon Apr 24 11:07:28 2023 +0530
Update consumer.go
Updated line 123
---
plugin/connector/standalone/consumer.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/plugin/connector/standalone/consumer.go
b/plugin/connector/standalone/consumer.go
index 2da2b03..5a35ae7 100644
--- a/plugin/connector/standalone/consumer.go
+++ b/plugin/connector/standalone/consumer.go
@@ -120,7 +120,7 @@ func (c *Consumer) Start() error {
func (c *Consumer) Shutdown() error {
c.started.CAS(true, false)
if ok := c.started.CAS(true, false); ok {
- for topicName, _ := range c.subscribes {
+ for topicName := range c.subscribes {
c.Unsubscribe(topicName)
delete(c.subscribes, topicName)
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
