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) {