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; + } +}