First drop for #703: detect the broadcaster

Atmosphere · Jun 6, 2013 · ceb3fdc · ceb3fdc
1 parent 22c792e
commit ceb3fdc
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/modules/cpr/src/main/java/org/atmosphere/cpr/AtmosphereFramework.java b/modules/cpr/src/main/java/org/atmosphere/cpr/AtmosphereFramework.java
@@ -116,6 +116,7 @@
 import static org.atmosphere.cpr.FrameworkConfig.JERSEY_CONTAINER;
 import static org.atmosphere.cpr.FrameworkConfig.JGROUPS_BROADCASTER;
 import static org.atmosphere.cpr.FrameworkConfig.RMI_BROADCASTER;
+import static org.atmosphere.cpr.FrameworkConfig.RABBITMQ_BROADCASTER;
 import static org.atmosphere.cpr.FrameworkConfig.JMS_BROADCASTER;
 import static org.atmosphere.cpr.FrameworkConfig.REDIS_BROADCASTER;
 import static org.atmosphere.cpr.FrameworkConfig.XMPP_BROADCASTER;
@@ -261,6 +262,7 @@ private void populateBroadcasterType() {
         broadcasterTypes.add(JGROUPS_BROADCASTER);
         broadcasterTypes.add(JMS_BROADCASTER);
         broadcasterTypes.add(RMI_BROADCASTER);
+        broadcasterTypes.add(RABBITMQ_BROADCASTER);
     }
 
     /**

diff --git a/modules/cpr/src/main/java/org/atmosphere/cpr/FrameworkConfig.java b/modules/cpr/src/main/java/org/atmosphere/cpr/FrameworkConfig.java
@@ -47,6 +47,10 @@ public interface FrameworkConfig {
      * The default RMI Broadcaster class
      */
     String RMI_BROADCASTER = "org.atmosphere.plugin.rmi.RMIBroadcaster";
+    /**
+     * The default RabbitMQ Broadcaster class
+     */
+    String RABBITMQ_BROADCASTER = "org.atmosphere.plugin.rabbitmq.RabbitMQBroadcaster";
     /**
      * The default XMPP Broadcaster class
      */