1 files changed, 0 insertions, 66 deletions
diff --git a/plugins/jobs/oooold/broker/beanstalk/stat_test.go b/plugins/jobs/oooold/broker/beanstalk/stat_test.go
deleted file mode 100644
index 14a55859..00000000
--- a/plugins/jobs/oooold/broker/beanstalk/stat_test.go
+++ /dev/null
@@ -1,66 +0,0 @@
-package beanstalk
-
-import (
-	"github.com/spiral/jobs/v2"
-	"github.com/stretchr/testify/assert"
-	"testing"
-	"time"
-)
-
-func TestBroker_Stat(t *testing.T) {
-	b := &Broker{}
-		_, err := b.Init(cfg)
-	if err != nil {
-		t.Fatal(err)
-	}
-	b.Register(pipe)
-
-	ready := make(chan interface{})
-	b.Listen(func(event int, ctx interface{}) {
-		if event == jobs.EventBrokerReady {
-			close(ready)
-		}
-	})
-
-	exec := make(chan jobs.Handler, 1)
-
-	go func() { assert.NoError(t, b.Serve()) }()
-	defer b.Stop()
-
-	<-ready
-
-	jid, perr := b.Push(pipe, &jobs.Job{Job: "test", Payload: "body", Options: &jobs.Options{}})
-
-	assert.NotEqual(t, "", jid)
-	assert.NoError(t, perr)
-
-	// beanstalk reserves job right after push
-	time.Sleep(time.Millisecond * 100)
-
-	stat, err := b.Stat(pipe)
-	assert.NoError(t, err)
-	assert.Equal(t, int64(1), stat.Queue)
-	assert.Equal(t, int64(0), stat.Active)
-
-	assert.NoError(t, b.Consume(pipe, exec, func(id string, j *jobs.Job, err error) {}))
-
-	waitJob := make(chan interface{})
-	exec <- func(id string, j *jobs.Job) error {
-		assert.Equal(t, jid, id)
-		assert.Equal(t, "body", j.Payload)
-
-		stat, err := b.Stat(pipe)
-		assert.NoError(t, err)
-		assert.Equal(t, int64(0), stat.Queue)
-		assert.Equal(t, int64(1), stat.Active)
-
-		close(waitJob)
-		return nil
-	}
-
-	<-waitJob
-
-	stat, err = b.Stat(pipe)
-	assert.NoError(t, err)
-	assert.Equal(t, int64(0), stat.Queue)
-}