Skip to content

Commit

Permalink
chore: rotate ports
Browse files Browse the repository at this point in the history
Signed-off-by: Valery Piashchynski <[email protected]>
  • Loading branch information
rustatian committed Oct 7, 2023
1 parent 888fd2e commit 90b79e1
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
2 changes: 1 addition & 1 deletion tests/configs/.rr-sqs-declare_fifo.yaml
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
version: '3'

rpc:
listen: tcp://127.0.0.1:6001
listen: tcp://127.0.0.1:32341

server:
command: "php php_test_files/jobs/jobs_ok.php"
Expand Down
10 changes: 5 additions & 5 deletions tests/jobs_sqs_fifo_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -276,7 +276,7 @@ func TestSQSDeclareFifo(t *testing.T) {
cont := endure.New(slog.LevelDebug)

cfg := &config.Plugin{
Version: "2.9.0",
Version: "2023.3.0",
Path: "configs/.rr-sqs-declare_fifo.yaml",
Prefix: "rr",
}
Expand Down Expand Up @@ -341,12 +341,12 @@ func TestSQSDeclareFifo(t *testing.T) {
time.Sleep(time.Second * 3)

t.Run("DeclarePipelineFifo", declareSQSPipeFifo("default-decl.fifo"))
t.Run("ConsumePipelineFifo", helpers.ResumePipes("127.0.0.1:6001", "test-3"))
t.Run("PushPipelineFifo", helpers.PushToPipe("test-3", false, "127.0.0.1:6001"))
t.Run("ConsumePipelineFifo", helpers.ResumePipes("127.0.0.1:32341", "test-3"))
t.Run("PushPipelineFifo", helpers.PushToPipe("test-3", false, "127.0.0.1:32341"))
time.Sleep(time.Second)
t.Run("PausePipelineFifo", helpers.PausePipelines("127.0.0.1:6001", "test-3"))
t.Run("PausePipelineFifo", helpers.PausePipelines("127.0.0.1:32341", "test-3"))
time.Sleep(time.Second)
t.Run("DestroyPipelineFifo", helpers.DestroyPipelines("127.0.0.1:6001", "test-3"))
t.Run("DestroyPipelineFifo", helpers.DestroyPipelines("127.0.0.1:32341", "test-3"))

time.Sleep(time.Second * 5)
stopCh <- struct{}{}
Expand Down

0 comments on commit 90b79e1

Please sign in to comment.