Author: nbelaevski Date: 2010-10-14 20:26:15 -0400 (Thu, 14 Oct 2010) New Revision: 19576 Modified: branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/Message.java branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/PublisherContext.java branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/Request.java branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/RequestLifecycleListener.java branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/TopicKey.java Log: https://jira.jboss.org/browse/RF-7817 Modified: branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/Message.java =================================================================== --- branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/Message.java 2010-10-15 00:24:16 UTC (rev 19575) +++ branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/Message.java 2010-10-15 00:26:15 UTC (rev 19576) @@ -21,6 +21,7 @@ */ package org.richfaces.application.push; +import java.io.Serializable; import java.util.HashMap; import java.util.Map; @@ -28,8 +29,10 @@ * @author Nick Belaevski * */ -public class Message { +public class Message implements Serializable { + private static final long serialVersionUID = -2241242510684986230L; + private final TopicKey topicKey; private Map<String, Object> attributes = null; Modified: branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/PublisherContext.java =================================================================== --- branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/PublisherContext.java 2010-10-15 00:24:16 UTC (rev 19575) +++ branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/PublisherContext.java 2010-10-15 00:26:15 UTC (rev 19576) @@ -29,13 +29,11 @@ */ public interface PublisherContext { + public static final String ATTRIBUTE_NAME = "__publisherContxt"; + //TODO - return Future? //TODO - use topic key? - public void publish(TopicKey topic, Object data); - - //TODO - return Future? - //TODO - use topic key? //TODO - priority? - public void publish(Message message); + public void publish(TopicKey topicKey, Object data); } Modified: branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/Request.java =================================================================== --- branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/Request.java 2010-10-15 00:24:16 UTC (rev 19575) +++ branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/Request.java 2010-10-15 00:26:15 UTC (rev 19576) @@ -32,8 +32,11 @@ //TODO expose request/session/application maps - public void write(Message message) throws IOException; + public void flushMessages() throws IOException; + public void postMessage(Message message); + + //TODO suspend with timeout? public void suspend() throws IOException; public void resume() throws IOException; @@ -43,5 +46,9 @@ public void removeListener(RequestLifecycleListener listener); public boolean isSuspended(); + + public boolean isPolling(); + public Session getSession(); + } Modified: branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/RequestLifecycleListener.java =================================================================== --- branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/RequestLifecycleListener.java 2010-10-15 00:24:16 UTC (rev 19575) +++ branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/RequestLifecycleListener.java 2010-10-15 00:26:15 UTC (rev 19576) @@ -28,6 +28,8 @@ */ public interface RequestLifecycleListener { + public void onFlush(Request request); + public void onSuspend(Request request); public void onDisconnect(Request request); Modified: branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/TopicKey.java =================================================================== --- branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/TopicKey.java 2010-10-15 00:24:16 UTC (rev 19575) +++ branches/RF-7817/core/api/src/main/java/org/richfaces/application/push/TopicKey.java 2010-10-15 00:26:15 UTC (rev 19576) @@ -21,12 +21,18 @@ */ package org.richfaces.application.push; +import java.io.Serializable; + /** * @author Nick Belaevski * */ -public class TopicKey { +public class TopicKey implements Serializable { + /** + * + */ + private static final long serialVersionUID = -6967010810728932698L; private final String topicName; public TopicKey(String topicName) {