1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109
| package com.sungard.irims;
import java.util.ArrayList;
import java.util.Date;
import java.util.EventListener;
import java.util.EventObject;
import java.util.List;
import javax.faces.context.FacesContext;
import org.ajax4jsf.event.PushEventListener;
public class MessageBean implements Runnable {
private String result;
private boolean running = true;
private PushEventListener listener;
private List messages = new ArrayList(10);
private int counter = 0;
public MessageBean() {
// TODO Auto-generated constructor stub
}
/**
* @return the result
*/
public String getResult() {
return result;
}
/**
* @param result
* the result to set
*/
public void setResult(String result) {
this.result = result;
}
public void addListener(EventListener listener) {
synchronized (listener) {
if (this.listener != listener) {
this.listener = (PushEventListener) listener;
Thread th = new Thread(this);
th.start();
}
}
}
public void run() {
try {
while (isRunning()) {
Thread.sleep(10000);
Date current = new Date(System.currentTimeMillis());
if (messages.size() >= 10) {
messages.remove(0);
}
messages.add(messages.size(), String.valueOf(counter++)
+ " at " + current.toString());
System.out.println("event occurs");
if (FacesContext.getCurrentInstance()==null){
System.out.println("Pas de Faces Context");
}
synchronized (listener) {
listener.onEvent(new EventObject(this));
}
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
/**
* @return the running
*/
public synchronized boolean isRunning() {
return running;
}
/**
* @param running
* the running to set
*/
public synchronized void setRunning(boolean running) {
this.running = running;
}
/**
* @return the messages
*/
public List getMessages() {
return messages;
}
/**
* @param messages
* the messages to set
*/
public void setMessages(List messages) {
this.messages = messages;
}
} |
Partager