summaryrefslogtreecommitdiff
path: root/plugins/app/tests/plugin_pipes.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/app/tests/plugin_pipes.go')
-rw-r--r--plugins/app/tests/plugin_pipes.go7
1 files changed, 4 insertions, 3 deletions
diff --git a/plugins/app/tests/plugin_pipes.go b/plugins/app/tests/plugin_pipes.go
index 704ec988..fc999718 100644
--- a/plugins/app/tests/plugin_pipes.go
+++ b/plugins/app/tests/plugin_pipes.go
@@ -11,6 +11,7 @@ import (
)
const ConfigSection = "app"
+const Response = "test"
var testPoolConfig = roadrunner.Config{
NumWorkers: 10,
@@ -44,7 +45,7 @@ func (f *Foo) Serve() chan error {
// test payload for echo
r := roadrunner.Payload{
Context: nil,
- Body: []byte("test"),
+ Body: []byte(Response),
}
errCh := make(chan error, 1)
@@ -88,7 +89,7 @@ func (f *Foo) Serve() chan error {
return errCh
}
- if string(rsp.Body) != "test" {
+ if string(rsp.Body) != Response {
errCh <- errors.E("response from worker is wrong", errors.Errorf("response: %s", rsp.Body))
return errCh
}
@@ -115,7 +116,7 @@ func (f *Foo) Serve() chan error {
}
// echo of the "test" should be -> test
- if string(rsp.Body) != "test" {
+ if string(rsp.Body) != Response {
errCh <- errors.E("response from worker is wrong", errors.Errorf("response: %s", rsp.Body))
return errCh
}