Add echo channel and fix __str__ on redis backend

django · Nov 6, 2015 · f3c3a23 · f3c3a23
1 parent a41516f
commit f3c3a23
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 1 deletion.
diff --git a/channels/backends/redis_py.py b/channels/backends/redis_py.py
@@ -183,4 +183,4 @@ def unlock_channel(self, channel):
         self.connection(self.consistent_hash(channel)).delete(key)
 
     def __str__(self):
-        return "%s(host=%s, port=%s)" % (self.__class__.__name__, self.host, self.port)
+        return "%s(hosts=%s)" % (self.__class__.__name__, self.hosts)
diff --git a/channels/consumer_registry.py b/channels/consumer_registry.py
@@ -14,6 +14,8 @@ class ConsumerRegistry(object):
 
     def __init__(self, routing=None):
         self.consumers = {}
+        # Add basic internal consumers
+        self.add_consumer(self.echo_consumer, ["__channels__.echo"])
         # Initialise with any routing that was passed in
         if routing:
             # If the routing was a string, import it
@@ -56,3 +58,11 @@ def consumer_for_channel(self, channel):
             return self.consumers[channel]
         except KeyError:
             return None
+
+    def echo_consumer(self, message):
+        """
+        Implements the echo message standard.
+        """
+        message.reply_channel.send({
+            "content": message.content.get("content", None),
+        })