diff options
| author | EuAndreh <eu@euandre.org> | 2025-05-03 19:50:33 -0300 |
|---|---|---|
| committer | EuAndreh <eu@euandre.org> | 2025-05-03 19:50:33 -0300 |
| commit | 7bf98f14cf2fa74c3591ce7b2b32c4e3c9263c3b (patch) | |
| tree | 494f86b809ec0d6d69148c7422ea2930c4d437e5 /tests/functional/consumer-with-deadletter/fiinha.go | |
| parent | src/fiinha.go: os.Exit(rc) instead of ignoring rc (diff) | |
| download | fiinha-7bf98f14cf2fa74c3591ce7b2b32c4e3c9263c3b.tar.gz fiinha-7bf98f14cf2fa74c3591ce7b2b32c4e3c9263c3b.tar.xz | |
re s/guuid/uuid/g
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 |