diff --git a/src/NOCQ/DB/RedisDataase.cs b/src/NOCQ/DB/RedisDataase.cs
index 3166e72..8537467 100644
--- a/src/NOCQ/DB/RedisDataase.cs
+++ b/src/NOCQ/DB/RedisDataase.cs
@@ -9,27 +9,28 @@ namespace NOCQ
     {
 		public RedisDataase(){}
 
-		public static async Task SaveAlert(IAlert alert)
+		public static async Task SaveAlert(IAlert alert, string q)
 		{
-			using (var redis = new RedisClientAsync(ConfigurationManager.AppSettings["DBQueueKey"],
+			using (var redis = new RedisClientAsync(q,
 				Convert.ToInt32(ConfigurationManager.AppSettings["Port"]),
 				Convert.ToInt32(ConfigurationManager.AppSettings["Timeout"])
 			))
 			{
-				await redis.LPush(ConfigurationManager.AppSettings["DBQueueKey"], alert);
+				await redis.LPush(q, alert);
 
 			}
 
 		}
 
-		public static async Task<Alert> GetNextAlert()
+		public static async Task<Alert> GetNextAlert(string q)
 		{
-			using (var redis = new RedisClientAsync(ConfigurationManager.AppSettings["DBQueueKey"],
+
+			using (var redis = new RedisClientAsync(q,
 				Convert.ToInt32(ConfigurationManager.AppSettings["Port"]),
 				Convert.ToInt32(ConfigurationManager.AppSettings["Timeout"])
 			))
 			{
-				var ts = await redis.RPop(ConfigurationManager.AppSettings["DBQueueKey"]);
+				var ts = await redis.RPop(q);
 
 				return JsonConvert.DeserializeObject<Alert>(ts);
 
diff --git a/src/NOCQ/DB/RedisQueues.cs b/src/NOCQ/DB/RedisQueues.cs
new file mode 100644
index 0000000..e6c8556
--- /dev/null
+++ b/src/NOCQ/DB/RedisQueues.cs
@@ -0,0 +1,12 @@
+using System;
+using System.Configuration;
+
+namespace NOCQ
+{
+	public struct RedisQueues
+    {
+		public static string Input = ConfigurationManager.AppSettings["DBQueueInput"];
+		public static string Output = ConfigurationManager.AppSettings["DBQueueOutput"];
+    }
+}
+
diff --git a/src/NOCQ/NOCQ.csproj b/src/NOCQ/NOCQ.csproj
index 6531573..b7fc16f 100644
--- a/src/NOCQ/NOCQ.csproj
+++ b/src/NOCQ/NOCQ.csproj
@@ -75,6 +75,7 @@
     <Compile Include="Model\Alert.cs" />
     <Compile Include="Plugins\Email\IParseRule.cs" />
     <Compile Include="Model\IAlert.cs" />
+    <Compile Include="DB\RedisQueues.cs" />
   </ItemGroup>
   <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
   <ItemGroup>