diff options
Diffstat (limited to 'tests/plugins/jobs/jobs_amqp_test.go')
| -rw-r--r-- | tests/plugins/jobs/jobs_amqp_test.go | 15 |
1 files changed, 1 insertions, 14 deletions
diff --git a/tests/plugins/jobs/jobs_amqp_test.go b/tests/plugins/jobs/jobs_amqp_test.go index 52bb6c7c..a95ac98b 100644 --- a/tests/plugins/jobs/jobs_amqp_test.go +++ b/tests/plugins/jobs/jobs_amqp_test.go @@ -205,7 +205,7 @@ func TestAMQPDeclare(t *testing.T) { time.Sleep(time.Second * 3) t.Run("DeclareAMQPPipeline", declareAMQPPipe) - t.Run("ConsumeAMQPPipeline", consumeAMQPPipe) + t.Run("ConsumeAMQPPipeline", resumePipes("test-3")) t.Run("PushAMQPPipeline", pushToPipe("test-3")) t.Run("PauseAMQPPipeline", pausePipelines("test-3")) t.Run("DestroyAMQPPipeline", destroyPipelines("test-3")) @@ -238,16 +238,3 @@ func declareAMQPPipe(t *testing.T) { err = client.Call("jobs.Declare", pipe, er) assert.NoError(t, err) } - -func consumeAMQPPipe(t *testing.T) { - conn, err := net.Dial("tcp", "127.0.0.1:6001") - assert.NoError(t, err) - client := rpc.NewClientWithCodec(goridgeRpc.NewClientCodec(conn)) - - pipe := &jobsv1beta.Pipelines{Pipelines: make([]string, 1)} - pipe.GetPipelines()[0] = "test-3" - - er := &jobsv1beta.Empty{} - err = client.Call("jobs.Resume", pipe, er) - assert.NoError(t, err) -} |