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:
Germano Fronza 2017-03-09 23:17:03 -03:00
parent ba58d7e31c
commit 200c10ebb2
1 changed files with 12 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
amqp/integration_test.go
View File

@ -39,13 +39,11 @@ func TestPublishConsume(t *testing.T) {
go c.Consume()
p, err := NewProducer(conn, "events-exchange", "events-queue")
p, err := NewProducer(conn, "events-exchange")
assert.Nil(t, err)
err = p.Publish("my_action_1", []byte(""))
assert.Nil(t, err)
p.Publish("my_action_1", []byte(""))
select {
case <-func1:
@ -88,13 +86,11 @@ func TestPublishConsumeWildcardAction(t *testing.T) {
go c.Consume()
p, err := NewProducer(conn, "webhooks", "event_PublishConsumeer")
p, err := NewProducer(conn, "webhooks")
assert.Nil(t, err)
err = p.Publish("webinar.state_changed", []byte(""))
assert.Nil(t, err)
p.Publish("webinar.state_changed", []byte(""))
select {
case <-func1:
@ -137,13 +133,11 @@ func TestPublishConsumeWildcardActionOrderMatters1(t *testing.T) {
go c.Consume()
p, err := NewProducer(conn, "webhooks", "event_PublishConsumeer")
p, err := NewProducer(conn, "webhooks")
assert.Nil(t, err)
err = p.Publish("webinar.state_changed", []byte(""))
assert.Nil(t, err)
p.Publish("webinar.state_changed", []byte(""))
select {
case <-func1:
@ -186,13 +180,11 @@ func TestPublishConsumeWildcardActionOrderMatters2(t *testing.T) {
go c.Consume()
p, err := NewProducer(conn, "webhooks", "event_PublishConsumeer")
p, err := NewProducer(conn, "webhooks")
assert.Nil(t, err)
err = p.Publish("webinar.state_changed", []byte(""))
assert.Nil(t, err)
p.Publish("webinar.state_changed", []byte(""))
select {
case <-func1:
@ -235,13 +227,11 @@ func TestPublishConsumeRequeueIfFail(t *testing.T) {
go c.Consume()
p, err := NewProducer(conn, "webhooks", "event_PublishConsumeer")
p, err := NewProducer(conn, "webhooks")
assert.Nil(t, err)
err = p.Publish("my_action", []byte(""))
assert.Nil(t, err)
p.Publish("my_action", []byte(""))
select {
case <-called:
@ -282,13 +272,11 @@ func TestPublishConsumeRequeueIfPanic(t *testing.T) {
go c.Consume()
p, err := NewProducer(conn, "webhooks", "event_PublishConsumeer")
p, err := NewProducer(conn, "webhooks")
assert.Nil(t, err)
err = p.Publish("my_action", []byte(""))
assert.Nil(t, err)
p.Publish("my_action", []byte(""))
select {
case <-called: