[richfaces-svn-commits] JBoss Rich Faces SVN: r8668 - trunk/samples/richfaces-demo/src/main/webapp/richfaces/push/snippets.
Author: ilya_shaikovsky
Date: 2008-05-21 06:59:58 -0400 (Wed, 21 May 2008)
New Revision: 8668
Added:
trunk/samples/richfaces-demo/src/main/webapp/richfaces/push/snippets/PushBean.java
Log:
source bean snippet added
Added: trunk/samples/richfaces-demo/src/main/webapp/richfaces/push/snippets/PushBean.java
===================================================================
--- trunk/samples/richfaces-demo/src/main/webapp/richfaces/push/snippets/PushBean.java
(rev 0)
+++
trunk/samples/richfaces-demo/src/main/webapp/richfaces/push/snippets/PushBean.java 2008-05-21
10:59:58 UTC (rev 8668)
@@ -0,0 +1,104 @@
+/**
+ *
+ */
+package org.richfaces.demo.push;
+
+import java.util.Date;
+import java.util.EventListener;
+import java.util.EventObject;
+import java.util.UUID;
+
+import org.ajax4jsf.event.PushEventListener;
+
+/**
+ * @author Ilya Shaikovsky
+ *
+ */
+
+public class PushBean implements Runnable {
+
+ private String uuid = "";
+
+ private boolean enabled = false;
+
+ private Date startDate;
+
+ PushEventListener listener;
+
+ private Thread thread;
+
+ // private int eventsFired counter;
+
+ public void addListener(EventListener listener) {
+ synchronized (listener) {
+ System.out.println("PushBean.addListener()");
+ if (this.listener != listener) {
+ this.listener = (PushEventListener) listener;
+ }
+ }
+ }
+
+ public void run() {
+ System.out.println("PushBean.run() executed");
+ while (thread != null) {
+ try {
+ System.out.println(((new Date()).getTime()-startDate.getTime())>=60000);
+ if (((new Date()).getTime()-startDate.getTime())>=20000) {
+ stop();
+ }
+ uuid = UUID.randomUUID().toString();
+ listener.onEvent(new EventObject(this));
+ Thread.sleep(10000);
+ } catch (InterruptedException e) {
+ // TODO Auto-generated catch block
+ // e.printStackTrace();
+ }
+ }
+ }
+
+ public String getUuid() {
+ System.out.println(uuid + "returned");
+ return uuid;
+ }
+
+ public void start() {
+ if (thread == null) {
+ thread = new Thread(this);
+ thread.setDaemon(true);
+ thread.start();
+ System.out.println("PushBean.start()");
+ setStartDate(new Date());
+ setEnabled(true);
+ System.out.println("thread started");
+ }
+ }
+
+ public void stop() {
+ if (thread != null) {
+ //thread.stop();
+ setStartDate(null);
+ setEnabled(false);
+ thread = null;
+ }
+ }
+
+ public Thread getThread() {
+ return thread;
+ }
+
+ public boolean isEnabled() {
+ return enabled;
+ }
+
+ public void setEnabled(boolean enabled) {
+ this.enabled = enabled;
+ }
+
+ public Date getStartDate() {
+ return startDate;
+ }
+
+ public void setStartDate(Date startDate) {
+ this.startDate = startDate;
+ }
+}