mirror of
https://github.com/kevin-DL/services.git
synced 2026-01-11 19:04:35 +00:00
fix breaking compilation in events test
This commit is contained in:
@@ -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
|
||||||
|
|||||||
Reference in New Issue
Block a user