parallel/event/SimpleConsoleMonitor.java

package appl.parallel.event;

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;

import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;

import appl.parallel.client.RemoteEventHandler;
import appl.parallel.client.RemoteExecutionController;
import edu.bonn.xulu.XuluModellingPlatform;
import edu.bonn.xulu.appl.AbstractXuluPlugin;
import edu.bonn.xulu.appl.XuluPlugin;

/**
 * A simple {@link XuluPlugin} that outputs received {@link TimeEvent}s 
 * and {@link TransferEvent}s to the console.
 * 
 * @author Dominik Appl
 */
public class SimpleConsoleMonitor extends AbstractXuluPlugin implements
                TimeMonitor, TransferMonitor {

        protected final Logger LOG = LogManager
                        .getLogger(this.getClass().getName());

        RemoteEventHandler eventProxy;

        public SimpleConsoleMonitor() {
                super(false);

        }

        /*
         * (non-Javadoc)
         * 
         * @see appl.parallel.event.TimeMonitor#receiveTimeEvent(appl.parallel.event.TimeEvent)
         */
        public void receiveTimeEvent(TimeEvent t) {
                System.out.println(t);

        }

        /*
         * (non-Javadoc)
         * 
         * @see appl.parallel.event.TransferMonitor#receiveTransferEvent(appl.parallel.event.TransferEvent)
         */
        public void receiveTransferEvent(TransferEvent t) {
                System.out.println(t);
        }

        /*
         * (non-Javadoc)
         * 
         * @see edu.bonn.xulu.appl.XuluPlugin#execute(edu.bonn.xulu.XuluModellingPlatform)
         */
        public void execute(XuluModellingPlatform appl) {
                super.execute(appl);
                RemoteExecutionController controller = RemoteExecutionController
                                .getRemoteExecutionController(appl);
                if (controller == null) {
                        LOG
                                        .error("Could not find RemoteExecutionController! -> Could not start SimpleConsoleMonitor");
                        return;
                }
                eventProxy = controller.getEventProxy();
                eventProxy.addTimeEventListener(this);
                eventProxy.addTransferEventListener(this);
                started = true;
        }

        @Override
        public void stop() {
                eventProxy.removeTimeMonitor(this);
                eventProxy.removeTransferMonitor(this);
                // TODO Auto-generated method stub
                super.stop();
        }
}
1	package appl.parallel.event;
2
3	import java.awt.event.ActionEvent;
4	import java.awt.event.ActionListener;
5
6	import org.apache.log4j.LogManager;
7	import org.apache.log4j.Logger;
8
9	import appl.parallel.client.RemoteEventHandler;
10	import appl.parallel.client.RemoteExecutionController;
11	import edu.bonn.xulu.XuluModellingPlatform;
12	import edu.bonn.xulu.appl.AbstractXuluPlugin;
13	import edu.bonn.xulu.appl.XuluPlugin;
14
15	/**
16	* A simple {@link XuluPlugin} that outputs received {@link TimeEvent}s
17	* and {@link TransferEvent}s to the console.
18	*
19	* @author Dominik Appl
20	*/
21	public class SimpleConsoleMonitor extends AbstractXuluPlugin implements
22	TimeMonitor, TransferMonitor {
23
24	protected final Logger LOG = LogManager
25	.getLogger(this.getClass().getName());
26
27	RemoteEventHandler eventProxy;
28
29	public SimpleConsoleMonitor() {
30	super(false);
31
32	}
33
34	/*
35	* (non-Javadoc)
36	*
37	* @see appl.parallel.event.TimeMonitor#receiveTimeEvent(appl.parallel.event.TimeEvent)
38	*/
39	public void receiveTimeEvent(TimeEvent t) {
40	System.out.println(t);
41
42	}
43
44	/*
45	* (non-Javadoc)
46	*
47	* @see appl.parallel.event.TransferMonitor#receiveTransferEvent(appl.parallel.event.TransferEvent)
48	*/
49	public void receiveTransferEvent(TransferEvent t) {
50	System.out.println(t);
51	}
52
53	/*
54	* (non-Javadoc)
55	*
56	* @see edu.bonn.xulu.appl.XuluPlugin#execute(edu.bonn.xulu.XuluModellingPlatform)
57	*/
58	public void execute(XuluModellingPlatform appl) {
59	super.execute(appl);
60	RemoteExecutionController controller = RemoteExecutionController
61	.getRemoteExecutionController(appl);
62	if (controller == null) {
63	LOG
64	.error("Could not find RemoteExecutionController! -> Could not start SimpleConsoleMonitor");
65	return;
66	}
67	eventProxy = controller.getEventProxy();
68	eventProxy.addTimeEventListener(this);
69	eventProxy.addTransferEventListener(this);
70	started = true;
71	}
72
73	@Override
74	public void stop() {
75	eventProxy.removeTimeMonitor(this);
76	eventProxy.removeTransferMonitor(this);
77	// TODO Auto-generated method stub
78	super.stop();
79	}
80	}