[jbosstools-commits] JBoss Tools SVN: r42672 - trunk/forge/plugins/org.jboss.tools.forge.core/src/org/jboss/tools/forge/core/process.

[jbosstools-commits at lists.jboss.org]

Author: koen.aers at jboss.com
Date: 2012-07-23 07:57:37 -0400 (Mon, 23 Jul 2012)
New Revision: 42672

Modified:
   trunk/forge/plugins/org.jboss.tools.forge.core/src/org/jboss/tools/forge/core/process/ForgeAbstractRuntime.java
Log:
JBIDE-11217: present verbose mode functionality in Forge JBT/JBDS Tooling

Modified: trunk/forge/plugins/org.jboss.tools.forge.core/src/org/jboss/tools/forge/core/process/ForgeAbstractRuntime.java
===================================================================
--- trunk/forge/plugins/org.jboss.tools.forge.core/src/org/jboss/tools/forge/core/process/ForgeAbstractRuntime.java	2012-07-23 11:45:31 UTC (rev 42671)
+++ trunk/forge/plugins/org.jboss.tools.forge.core/src/org/jboss/tools/forge/core/process/ForgeAbstractRuntime.java	2012-07-23 11:57:37 UTC (rev 42672)
@@ -25,7 +25,7 @@
 	private IProcess process = null;
 	private String state = STATE_NOT_RUNNING;	
 	private final TerminateListener terminateListener = new TerminateListener();	
-	private MasterOutputListener masterOutputListener = new MasterOutputListener();
+	private MasterStreamListener masterStreamListener = new MasterStreamListener();
 	private CommandResultListener commandResultListener = new CommandResultListener();
 	private PropertyChangeSupport propertyChangeSupport = new PropertyChangeSupport(this);
 	private List<ForgeOutputListener> outputListeners = new ArrayList<ForgeOutputListener>();
@@ -53,11 +53,15 @@
 				DebugPlugin.getDefault().addDebugEventListener(terminateListener);
 				IStreamsProxy streamsProxy = getStreamsProxy();
 				if (streamsProxy != null) {
-					IStreamMonitor streamMonitor = streamsProxy.getOutputStreamMonitor();
-					if (streamMonitor != null) {
-						streamMonitor.addListener(startupListener);
-						streamMonitor.addListener(masterOutputListener);
+					IStreamMonitor outputStreamMonitor = streamsProxy.getOutputStreamMonitor();
+					if (outputStreamMonitor != null) {
+						outputStreamMonitor.addListener(startupListener);
+						outputStreamMonitor.addListener(masterStreamListener);
 					}
+					IStreamMonitor errorStreamMonitor = streamsProxy.getErrorStreamMonitor();
+					if (errorStreamMonitor != null) {
+						errorStreamMonitor.addListener(masterStreamListener);
+					}
 				}
 			}
 			progressMonitor.worked(1);
@@ -96,7 +100,7 @@
 				IStreamMonitor streamMonitor = streamsProxy.getOutputStreamMonitor();
 				if (streamMonitor != null) {
 					commandResultListener.command = str + '\n';
-					streamMonitor.removeListener(masterOutputListener);
+					streamMonitor.removeListener(masterStreamListener);
 					streamMonitor.addListener(commandResultListener);
 					try {
 						streamsProxy.write(new Character((char)31).toString() + str + '\n');
@@ -113,7 +117,7 @@
 					commandResultListener.result = null;
 					commandResultListener.command = null;
 					streamMonitor.removeListener(commandResultListener);
-					streamMonitor.addListener(masterOutputListener);
+					streamMonitor.addListener(masterStreamListener);
 				}
 			}
 		}
@@ -150,10 +154,14 @@
 			if (process != null) {
 				IStreamsProxy streamsProxy = getStreamsProxy();
 				if (streamsProxy != null) {
-					IStreamMonitor streamMonitor = streamsProxy.getOutputStreamMonitor();
-					if (streamMonitor != null) {
-						streamMonitor.removeListener(masterOutputListener);
+					IStreamMonitor outputStreamMonitor = streamsProxy.getOutputStreamMonitor();
+					if (outputStreamMonitor != null) {
+						outputStreamMonitor.removeListener(masterStreamListener);
 					}
+					IStreamMonitor errorStreamMonitor = streamsProxy.getErrorStreamMonitor();
+					if (errorStreamMonitor != null) {
+						errorStreamMonitor.removeListener(masterStreamListener);
+					}
 				}
 				process.terminate();
 				ForgeCorePlugin.removeForgeProcess(process);
@@ -200,7 +208,7 @@
 		}		
 	}
 	
-	private class MasterOutputListener implements IStreamListener {
+	private class MasterStreamListener implements IStreamListener {
 		@Override
 		public void streamAppended(String text, IStreamMonitor monitor) {
 			for (ForgeOutputListener listener : outputListeners) {