diff --git a/ers/amqp_it_test.go b/ers/amqp_it_test.go
index e6f24609ee..441b8bd296 100644
--- a/ers/amqp_it_test.go
+++ b/ers/amqp_it_test.go
@@ -78,7 +78,7 @@ func TestAMQPER(t *testing.T) {
 	rdrExit = make(chan struct{}, 1)
 
 	if rdr, err = NewAMQPER(cfg, 1, rdrEvents, make(chan *erEvent, 1),
-		rdrErr, new(engine.FilterS), nil, rdrExit); err != nil {
+		rdrErr, new(engine.FilterS), rdrExit); err != nil {
 		t.Fatal(err)
 	}
 	connection, err := amqp.Dial("amqp://guest:guest@localhost:5672/")