X-Git-Url: https://git.argeo.org/?a=blobdiff_plain;f=org.argeo.cms.ee%2Fsrc%2Forg%2Fargeo%2Fcms%2Fwebsocket%2Fserver%2FEventEndpoint.java;h=c71c862d65c1cf195a8d0a7399a1ecfbd9a33f43;hb=8c6e16aa43d9523e1ec57a41a06b3ceba7d23fdb;hp=a6b2a4df75c87a03c501f034f11f84de8243706e;hpb=79c14508549e1af042485b4f888a3c54f5a68833;p=lgpl%2Fargeo-commons.git diff --git a/org.argeo.cms.ee/src/org/argeo/cms/websocket/server/EventEndpoint.java b/org.argeo.cms.ee/src/org/argeo/cms/websocket/server/EventEndpoint.java index a6b2a4df7..c71c862d6 100644 --- a/org.argeo.cms.ee/src/org/argeo/cms/websocket/server/EventEndpoint.java +++ b/org.argeo.cms.ee/src/org/argeo/cms/websocket/server/EventEndpoint.java @@ -10,7 +10,7 @@ import javax.websocket.Session; import javax.websocket.server.PathParam; import javax.websocket.server.ServerEndpoint; -import org.argeo.api.cms.CmsContext; +import org.argeo.api.cms.CmsEventBus; import org.argeo.api.cms.CmsEventSubscriber; import org.osgi.framework.BundleContext; import org.osgi.framework.FrameworkUtil; @@ -20,15 +20,15 @@ public class EventEndpoint implements CmsEventSubscriber { private BundleContext bc = FrameworkUtil.getBundle(TestEndpoint.class).getBundleContext(); private RemoteEndpoint.Basic remote; - private CmsContext cmsContext; + private CmsEventBus cmsEventBus; // private String topic = "cms"; @OnOpen public void onOpen(Session session, @PathParam("topic") String topic) { if (bc != null) { - cmsContext = bc.getService(bc.getServiceReference(CmsContext.class)); - cmsContext.addEventSubscriber(topic, this); + cmsEventBus = bc.getService(bc.getServiceReference(CmsEventBus.class)); + cmsEventBus.addEventSubscriber(topic, this); } remote = session.getBasicRemote(); @@ -36,7 +36,7 @@ public class EventEndpoint implements CmsEventSubscriber { @OnClose public void onClose(@PathParam("topic") String topic) { - cmsContext.removeEventSubscriber(topic, this); + cmsEventBus.removeEventSubscriber(topic, this); } @Override