summaryrefslogtreecommitdiffstats
path: root/sca-java-2.x/contrib/modules/binding-comet-runtime-alternate/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometBindingHandler.java
diff options
context:
space:
mode:
Diffstat (limited to 'sca-java-2.x/contrib/modules/binding-comet-runtime-alternate/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometBindingHandler.java')
-rw-r--r--sca-java-2.x/contrib/modules/binding-comet-runtime-alternate/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometBindingHandler.java49
1 files changed, 0 insertions, 49 deletions
diff --git a/sca-java-2.x/contrib/modules/binding-comet-runtime-alternate/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometBindingHandler.java b/sca-java-2.x/contrib/modules/binding-comet-runtime-alternate/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometBindingHandler.java
deleted file mode 100644
index d31b1332a7..0000000000
--- a/sca-java-2.x/contrib/modules/binding-comet-runtime-alternate/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometBindingHandler.java
+++ /dev/null
@@ -1,49 +0,0 @@
-package org.apache.tuscany.sca.binding.comet.runtime;
-
-import java.lang.reflect.InvocationTargetException;
-
-import javax.servlet.ServletContext;
-import javax.ws.rs.GET;
-import javax.ws.rs.POST;
-import javax.ws.rs.Produces;
-import javax.ws.rs.core.Context;
-
-import org.apache.tuscany.sca.interfacedef.Operation;
-import org.apache.tuscany.sca.runtime.RuntimeEndpoint;
-import org.atmosphere.annotation.Broadcast;
-import org.atmosphere.cpr.Broadcaster;
-import org.atmosphere.cpr.DefaultBroadcaster;
-import org.atmosphere.jersey.Broadcastable;
-import org.atmosphere.jersey.SuspendResponse;
-
-import com.sun.jersey.spi.container.servlet.PerSession;
-
-@Produces("text/html;charset=ISO-8859-1")
-@PerSession
-public class CometBindingHandler {
-
- private Broadcaster broadcaster = new DefaultBroadcaster();
- public static final String ENDPOINT_KEY = "org.apache.tuscany.sca.binding.comet.endpoint";
- public static final String OPERATION_KEY = "org.apache.tuscany.sca.binding.comet.operation";
-
- @Context
- private ServletContext sc;
-
- @GET
- public SuspendResponse<String> register() {
- System.out.println("Register method: " + sc);
- return new SuspendResponse.SuspendResponseBuilder<String>().broadcaster(broadcaster).outputComments(true)
- .addListener(new EventsLogger()).build();
- }
-
- @POST
- @Broadcast
- public Broadcastable publish() throws InvocationTargetException {
- System.out.println("Publish method: " + sc);
- RuntimeEndpoint wire = (RuntimeEndpoint)sc.getAttribute(ENDPOINT_KEY);
- Operation operation = (Operation)sc.getAttribute(OPERATION_KEY);
- Object response = wire.invoke(operation, new Object[] {});
- return new Broadcastable(response.toString(), "", broadcaster);
- }
-
-}