diff --git a/cyclone/sse.py b/cyclone/sse.py index 49095f96da..5f8b2e26b1 100644 --- a/cyclone/sse.py +++ b/cyclone/sse.py @@ -79,7 +79,7 @@ def _execute(self, transforms, *args, **kwargs): self.flush() self.request.connection.setRawMode() self.notifyFinish().addCallback(self.on_connection_closed) - self.bind() + self.bind(*args, **kwargs) def on_connection_closed(self, *args, **kwargs): if self.settings.get("debug"): diff --git a/demos/redis/README b/demos/redis/README index dedb422212..01b18733f2 100644 --- a/demos/redis/README +++ b/demos/redis/README @@ -12,3 +12,11 @@ Test redis pubsub feature (redis 2.x) Send messages to channels: curl -D - -d "message=hello world" http://localhost:8888/queue/foo.bar curl -D - -d "message=yes, we can" http://localhost:8888/queue/l33t + +NOTE +---- + +1. It is recommned not to use numeric channel names. The QueueHandler will +get the channel as integer while at other places it would be string. +If you still want to use numeric channel name, make sure you cast the +name to str to avoid any issues.