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	mojays	2	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			}