parallel/event/SimpleConsoleMonitor.java

package appl.parallel.event;

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