Skip to content
This repository has been archived by the owner on Jan 13, 2021. It is now read-only.

Commit

Permalink
queue: fix failing queue test
Browse files Browse the repository at this point in the history
  • Loading branch information
potsables committed Feb 14, 2019
1 parent c26c3ae commit 72670ac
Showing 1 changed file with 0 additions and 24 deletions.
24 changes: 0 additions & 24 deletions queue/queue_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,6 @@ package queue

import (
"context"
"os"
"strings"
"sync"
"testing"
"time"
Expand All @@ -24,28 +22,6 @@ const (
testCfgPath = "../testenv/config.json"
)

func TestParseQueueFull(t *testing.T) {
cfg, err := config.LoadConfig(testCfgPath)
if err != nil {
t.Fatal(err)
}
loggerConsumer, err := log.NewLogger("", true)
if err != nil {
t.Fatal(err)
}
qmConsumer, err := New(IpfsKeyCreationQueue, testRabbitAddress, false, cfg, loggerConsumer)
if err != nil {
t.Fatal(err)
}
host, err := os.Hostname()
if err != nil {
t.Fatal(err)
}
if ok := strings.Contains(qmConsumer.QueueName.String(), host); !ok {
t.Fatal("failed to properly parse queue name")
}
}

func TestQueue_Publish(t *testing.T) {
type args struct {
queueName Queue
Expand Down

0 comments on commit 72670ac

Please sign in to comment.