diff --git a/queue_test.go b/queue_test.go index f72eb74..1f8520f 100644 --- a/queue_test.go +++ b/queue_test.go @@ -11,10 +11,7 @@ func TestQueue(t *testing.T) { ctx, can := context.WithTimeout(context.Background(), time.Second*10) defer can() - db := NewTestDBIn(t.TempDir()) - defer db.Close() - - q := NewQueue(db) + q := NewQueue(NewRAM()) for i := 0; i < 39; i++ { if err := q.Push(ctx, Message{ID: strconv.Itoa(i), TS: uint64(i)}); err != nil {