Skip to content

Instantly share code, notes, and snippets.

@jfarcand
Created September 3, 2014 22:12
Show Gist options
  • Save jfarcand/74a1a2e45994fd295ece to your computer and use it in GitHub Desktop.
Save jfarcand/74a1a2e45994fd295ece to your computer and use it in GitHub Desktop.
diff --git a/samples/chat/pom.xml b/samples/chat/pom.xml
index 21f105c..328319d 100644
--- a/samples/chat/pom.xml
+++ b/samples/chat/pom.xml
@@ -20,6 +20,11 @@
<type>war</type>
</dependency>
<dependency>
+ <groupId>org.atmosphere</groupId>
+ <artifactId>replicata</artifactId>
+ <version>1.0.0-SNAPSHOT</version>
+ </dependency>
+ <dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>${logback-version}</version>
diff --git a/samples/chat/src/main/java/org/atmosphere/samples/chat/ChatAtmosphereHandler.java b/samples/chat/src/main/java/org/atmosphere/samples/chat/Cindex 0a1eca8..d1bbb5e 100644
--- a/samples/chat/src/main/java/org/atmosphere/samples/chat/ChatAtmosphereHandler.java
+++ b/samples/chat/src/main/java/org/atmosphere/samples/chat/ChatAtmosphereHandler.java
@@ -20,6 +20,8 @@ import org.atmosphere.cpr.AtmosphereResponse;
import org.atmosphere.handler.OnMessage;
import org.atmosphere.interceptor.AtmosphereResourceLifecycleInterceptor;
import org.atmosphere.interceptor.BroadcastOnPostAtmosphereInterceptor;
+import org.atmosphere.replicata.RabbitMQBroadcaster;
+import org.atmosphere.replicata.ReplicataBroadcasterCache;
import java.io.IOException;
import java.util.Date;
@@ -31,7 +33,9 @@ import java.util.Date;
*/
@AtmosphereHandlerService(path="/chat",
interceptors = {AtmosphereResourceLifecycleInterceptor.class,
- BroadcastOnPostAtmosphereInterceptor.class})
+ BroadcastOnPostAtmosphereInterceptor.class},
+ broadcasterCache = ReplicataBroadcasterCache.class,
+ broadcaster = RabbitMQBroadcaster.class)
public class ChatAtmosphereHandler extends OnMessage<String> {
@Override
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment