OrgGo/eventials.goevents
1
0
Fork 0
mirror of https://github.com/eventials/goevents.git synced 2025-04-24 13:48:53 +08:00
Code Issues Projects Releases Wiki Activity

fix tests

Browse Source
This commit is contained in:
Guilherme 2017-10-10 19:49:27 -03:00
parent d1f7a11786
commit 18a4a1bbd9
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
amqp/consumer_test.go
View File

@ -503,7 +503,7 @@ func TestActionExitsMaxRetriesWhenDelayedWindow(t *testing.T) {
select { select {
case <-time.After(1 * time.Second): case <-time.After(1 * time.Second):
assert.Equal(t, 6, timesCalled, "Consumer got wrong quantity of messages.") assert.Equal(t, 4, timesCalled, "Consumer got wrong quantity of messages.")
} }
} }
} }
@ -519,9 +519,8 @@ func TestActionRetryTimeout(t *testing.T) {
defer conn.Close() defer conn.Close()
c, err := NewConsumerConfig(conn, false, "webhooks", "TestActionRetryTimeout", ConsumerConfig{ c, err := NewConsumerConfig(conn, false, "webhooks", "TestActionRetryTimeout", ConsumerConfig{
ConsumeRetryInterval: 2 * time.Second, ConsumeRetryInterval: 2 * time.Second,
PrefetchCount: 1, PrefetchCount: 1,
RetryTimeoutBeforeRequeue: 650 * time.Millisecond,
}) })
if assert.Nil(t, err) { if assert.Nil(t, err) {
@ -561,7 +560,7 @@ func TestActionRetryTimeout(t *testing.T) {
select { select {
case <-time.After(1 * time.Second): case <-time.After(1 * time.Second):
assert.Equal(t, 5, myActionTimesCalled, "Consumer got wrong quantity of messages.") assert.Equal(t, 3, myActionTimesCalled, "Consumer got wrong quantity of messages.")
assert.Equal(t, 1, myAction2TimesCalled, "Consumer got wrong quantity of messages.") assert.Equal(t, 1, myAction2TimesCalled, "Consumer got wrong quantity of messages.")
} }
} }