diff options
Diffstat (limited to 'tests/functional/new-instance-takeover/fiinha.go')
| -rw-r--r-- | tests/functional/new-instance-takeover/fiinha.go | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/tests/functional/new-instance-takeover/fiinha.go b/tests/functional/new-instance-takeover/fiinha.go index 5fdb9b4..5e6ad4b 100644 --- a/tests/functional/new-instance-takeover/fiinha.go +++ b/tests/functional/new-instance-takeover/fiinha.go @@ -4,7 +4,7 @@ import ( "runtime" "os" - "guuid" + "uuid" g "gobang" ) @@ -14,7 +14,7 @@ const topic = "topic" -func pub(queue IQueue, topic string, flowID guuid.UUID) { +func pub(queue IQueue, topic string, flowID uuid.UUID) { unsent := UnsentMessage{ Topic: topic, FlowID: flowID, @@ -24,7 +24,7 @@ func pub(queue IQueue, topic string, flowID guuid.UUID) { g.TErrorIf(err) } -func handlerFn(publish func(guuid.UUID)) func(Message) error { +func handlerFn(publish func(uuid.UUID)) func(Message) error { return func(message Message) error { publish(message.FlowID) return nil @@ -49,8 +49,8 @@ func startInstance( queue.queries = queries - pub_ := func(topic string) func(guuid.UUID) { - return func(flowID guuid.UUID) { + pub_ := func(topic string) func(uuid.UUID) { + return func(flowID uuid.UUID) { pub(queue, topic, flowID) } } @@ -76,16 +76,16 @@ func MainTest() { instanceID1 := os.Getpid() instanceID2 := instanceID1 + 1 - flowID1 := guuid.New() - flowID2 := guuid.New() + flowID1 := uuid.New() + flowID2 := uuid.New() g.Testing("new instances take ownership of topic+name combo", func() { q1, err := startInstance(dbpath, instanceID1, "first") g.TErrorIf(err) defer q1.Close() - pub(q1, topic, guuid.New()) - pub(q1, topic, guuid.New()) + pub(q1, topic, uuid.New()) + pub(q1, topic, uuid.New()) pub(q1, topic, flowID1) <- q1.WaitFor("individual-first", flowID1, "w").Channel @@ -97,8 +97,8 @@ func MainTest() { <- q2.WaitFor("individual-second", flowID1, "w").Channel - pub(q2, topic, guuid.New()) - pub(q2, topic, guuid.New()) + pub(q2, topic, uuid.New()) + pub(q2, topic, uuid.New()) pub(q2, topic, flowID2) // FIXME: notify multiple instances so we can add this: |