totole/services
1
0
Fork 0
mirror of https://github.com/kevin-DL/services.git synced 2026-01-11 19:04:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' of github.com:micro/services

Browse Source
This commit is contained in:
Ben Toogood
2020-10-21 09:28:59 +01:00
parent 9df0483872 e7451ae843
commit 8e2f276123
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
notes/micro.mu Normal file
View File

@@ -0,0 +1 @@
service notes

1
notes/notes.mu
View File

@@ -1 +0,0 @@
service notes

4
test/events/main.go
View File

@@ -24,7 +24,7 @@ func main() {
srv.Init() srv.Init()
go func() { // test 1, ordinary sub with autoack go func() { // test 1, ordinary sub with autoack
evChan, err := events.Subscribe("test1") evChan, err := events.Consume("test1")
if err != nil { if err != nil {
logger.Fatalf("Error creating subscriber: %v", err) logger.Fatalf("Error creating subscriber: %v", err)
} }
@@ -71,7 +71,7 @@ func main() {
}() }()
go func() { // test 2, sub with manual ack go func() { // test 2, sub with manual ack
evChan, err := events.Subscribe("test2", goevents.WithAutoAck(false, 5*time.Second)) evChan, err := events.Consume("test2", goevents.WithAutoAck(false, 5*time.Second))
if err != nil { if err != nil {
logger.Errorf("TEST2: Error creating subscriber: %v", err) logger.Errorf("TEST2: Error creating subscriber: %v", err)
return return