diff --git a/api/v1/env.go b/api/v1/env.go
index 03451a6..11df9d7 100644
--- a/api/v1/env.go
+++ b/api/v1/env.go
@@ -124,7 +124,7 @@ func (s *Store) getWorker() []corev1.EnvVar {
 			{
 				Name: "MESSENGER_TRANSPORT_DSN",
 				Value: fmt.Sprintf(
-					"rediss://%s:%d/messages/symfony/consumer?auto_setup=true&serializer=1&stream_max_entries=0&dbindex=%d",
+					"redis://%s:%d/messages/symfony/consumer?auto_setup=true&serializer=1&stream_max_entries=0&dbindex=%d",
 					s.Spec.Worker.RedisHost,
 					s.Spec.Worker.RedisPort,
 					s.Spec.Worker.RedisIndex,