diff options
Diffstat (limited to 'tests/functional/consumer-with-deadletter/fiinha.go')
| -rw-r--r-- | tests/functional/consumer-with-deadletter/fiinha.go | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/tests/functional/consumer-with-deadletter/fiinha.go b/tests/functional/consumer-with-deadletter/fiinha.go index 7d88e0e..37893e1 100644 --- a/tests/functional/consumer-with-deadletter/fiinha.go +++ b/tests/functional/consumer-with-deadletter/fiinha.go @@ -4,7 +4,7 @@ import ( "errors" "runtime" - "guuid" + "uuid" g "gobang" ) @@ -47,7 +47,7 @@ func MainTest() { g.TErrorIf(err) defer queue.Close() - pub := func(payload []byte, flowID guuid.UUID) { + pub := func(payload []byte, flowID uuid.UUID) { unsent := UnsentMessage{ Topic: topicX, FlowID: flowID, @@ -59,7 +59,7 @@ func MainTest() { g.Testing("we can WaitFor() a message after a deadletter", func() { - flowID := guuid.New() + flowID := uuid.New() handlerFn := func(message Message) error { messageY, err := processNewEventXToY(message) @@ -73,10 +73,10 @@ func MainTest() { queue.Subscribe(topicX, "main-worker", handlerFn) defer queue.Unsubscribe(topicX, "main-worker") - pub([]byte("event 1"), guuid.New()) - pub([]byte("event 2"), guuid.New()) - pub([]byte("event 3"), guuid.New()) - pub([]byte("event 4"), guuid.New()) + pub([]byte("event 1"), uuid.New()) + pub([]byte("event 2"), uuid.New()) + pub([]byte("event 3"), uuid.New()) + pub([]byte("event 4"), uuid.New()) pub([]byte("event 5"), flowID) given := <- queue.WaitFor(topicY, flowID, "waiter").Channel |