Add key_prefix option to change the key named used in redis

README.md

@@ -35,6 +35,7 @@ Option                  | Description
 `:password`             | The redis-server password                                                 | `""`           |
 `:compression_level`    | Compression level applied to serialized terms (`0` - none, `9` - highest) | `0`            |
 `:socket_opts`          | The redis-server network layer options                                    | `[]`           |
+`:key_prefix`           | The key prefix to use for the redis key                                   | `phx`           |
 
 And also add `:phoenix_pubsub_redis` to your list of applications:
 

lib/phoenix_pubsub_redis/redis.ex

@@ -28,6 +28,7 @@ defmodule Phoenix.PubSub.Redis do
     * `:compression_level` - Compression level applied to serialized terms - from `0` (no compression), to `9` (highest). Defaults `0`
     * `:socket_opts` - List of options that are passed to the network layer when connecting to the Redis server. Default `[]`
     * `:sentinel` - Redix sentinel configuration. Default to `nil`
+    * `:key_prefix` - Key prefix to add to the redis PubSub key. Defaults `phx`
 
   """
 
@@ -66,6 +67,7 @@ defmodule Phoenix.PubSub.Redis do
     pubsub_name = Keyword.fetch!(opts, :name)
     adapter_name = Keyword.fetch!(opts, :adapter_name)
     compression_level = Keyword.get(opts, :compression_level, 0)
+    key_prefix = Keyword.get(opts, :key_prefix, nil)
 
     opts = handle_url_opts(opts)
     opts = Keyword.merge(@defaults, opts)
@@ -74,8 +76,10 @@ defmodule Phoenix.PubSub.Redis do
     node_name = opts[:node_name] || node()
     validate_node_name!(node_name)
 
+
     :ets.new(adapter_name, [:public, :named_table, read_concurrency: true])
     :ets.insert(adapter_name, {:node_name, node_name})
+    :ets.insert(adapter_name, {:key_prefix, key_prefix})
     :ets.insert(adapter_name, {:compression_level, compression_level})
 
     pool_opts = [

lib/phoenix_pubsub_redis/redis_server.ex

@@ -22,7 +22,7 @@ defmodule Phoenix.PubSub.RedisServer do
   end
 
   defp publish(adapter_name, mode, node_name, topic, message, dispatcher) do
-    namespace = redis_namespace(adapter_name)
+    namespace = redis_namespace(adapter_name, key_prefix(adapter_name))
     compression_level = compression_level(adapter_name)
     redis_msg = {@redis_msg_vsn, mode, node_name, topic, message, dispatcher}
     bin_msg = :erlang.term_to_binary(redis_msg, compressed: compression_level)
@@ -46,6 +46,10 @@ defmodule Phoenix.PubSub.RedisServer do
     :ets.lookup_element(adapter_name, :compression_level, 2)
   end
 
+  def key_prefix(adapter_name) do
+    :ets.lookup_element(adapter_name, :key_prefix, 2)
+  end
+
   ## Server callbacks
 
   def start_link({_, adapter_name, _, _} = state) do
@@ -125,7 +129,13 @@ defmodule Phoenix.PubSub.RedisServer do
   end
 
   defp establish_success(%{redix_pid: redix_pid, adapter_name: adapter_name} = state) do
-    {:ok, _reference} = Redix.PubSub.subscribe(redix_pid, redis_namespace(adapter_name), self())
+    {:ok, _reference} =
+      Redix.PubSub.subscribe(
+        redix_pid,
+        redis_namespace(adapter_name, key_prefix(adapter_name)),
+        self()
+      )
+
     state
   end
 
@@ -139,5 +149,7 @@ defmodule Phoenix.PubSub.RedisServer do
     end
   end
 
-  defp redis_namespace(adapter_name), do: "phx:#{adapter_name}"
+  defp redis_namespace(adapter_name, prefix)
+  defp redis_namespace(adapter_name, nil), do: "phx:#{adapter_name}"
+  defp redis_namespace(adapter_name, key_prefix), do: "#{key_prefix}:#{adapter_name}"
 end