[jboss-svn-commits] JBL Code SVN: r19890 - labs/jbossbuild/maven-plugins/trunk/maven-jdocbook-plugin/src/main/java/org/jboss/maven/shared/process.

[jboss-svn-commits at lists.jboss.org]

Author: steve.ebersole at jboss.com
Date: 2008-05-07 15:14:06 -0400 (Wed, 07 May 2008)
New Revision: 19890

Modified:
   labs/jbossbuild/maven-plugins/trunk/maven-jdocbook-plugin/src/main/java/org/jboss/maven/shared/process/ProcessOutputManager.java
Log:
MPJDOCBOOK-10 : po2xml output truncation

Modified: labs/jbossbuild/maven-plugins/trunk/maven-jdocbook-plugin/src/main/java/org/jboss/maven/shared/process/ProcessOutputManager.java
===================================================================
--- labs/jbossbuild/maven-plugins/trunk/maven-jdocbook-plugin/src/main/java/org/jboss/maven/shared/process/ProcessOutputManager.java	2008-05-07 19:12:50 UTC (rev 19889)
+++ labs/jbossbuild/maven-plugins/trunk/maven-jdocbook-plugin/src/main/java/org/jboss/maven/shared/process/ProcessOutputManager.java	2008-05-07 19:14:06 UTC (rev 19890)
@@ -22,7 +22,6 @@
  * Boston, MA  02110-1301  USA
  *
  */
-
 package org.jboss.maven.shared.process;
 
 import java.io.OutputStream;
@@ -34,22 +33,37 @@
  */
 public class ProcessOutputManager {
 	private final StreamBridge outputBridge;
-	private StreamBridge errorBridge;
+	private final StreamBridge errorBridge;
 
+	private final Thread outputStreamThread;
+	private final Thread errorStreamThread;
+
 	public ProcessOutputManager(Process process, OutputStream out, OutputStream err) {
 		outputBridge = new StreamBridge( process.getInputStream(), out );
 		errorBridge = new StreamBridge( process.getErrorStream(), err );
 
-		Thread outputStreamThread = new Thread( outputBridge );
+		outputStreamThread = new Thread( outputBridge );
 		outputStreamThread.setDaemon( true );
 		outputStreamThread.start();
 
-		Thread errorStreamThread = new Thread( errorBridge );
+		errorStreamThread = new Thread( errorBridge );
 		errorStreamThread.setDaemon( true );
 		errorStreamThread.start();
 	}
 
 	public void stop() {
+		try {
+			outputStreamThread.join();
+		}
+		catch ( InterruptedException e ) {
+			// ignore
+		}
+		try {
+			errorStreamThread.join();
+		}
+		catch ( InterruptedException e ) {
+			// ignore
+		}
 		outputBridge.stop();
 		errorBridge.stop();
 	}