import java.io.*;
import java.lang.*;


class ProcessHandler extends Thread {

  InputStream inpStr;
  String strType;

  public ProcessHandler(InputStream inpStr, String strType) {
   this.inpStr = inpStr;
   this.strType = strType;
  }

   public void run() {
    try {
     InputStreamReader inpStrd = new InputStreamReader(inpStr);
     BufferedReader buffRd = new BufferedReader(inpStrd);
     String line = null;
     while((line = buffRd.readLine()) != null) {
      System.out.println(strType + " -> " + line);
     }
     buffRd.close();

    } catch(Exception e) {
    System.out.println(e);
    }
  }

}


public class Ejecuta extends Object
{
    public static void main(String[] args)
    {
        Runtime rt = Runtime.getRuntime();

       String sentencia = "C:\\oracle\\ora92\\bin\\" + "exp " + "un/pw" +
           " file=" + "C:\\xxxx_logs\\fichero.dmp" + 
           " consistent=Y log=" + "C:\\xxxx_logs\\fichero.log" + " owner=<some owner>";


       String rcS = "";
       int rc = -1;
       try                     
       {
           Process p = rt.exec(sentencia);

           /* handling the streams so that dead lock situation never occurs.*/
           ProcessHandler inputStream =
           new ProcessHandler(p.getInputStream(),"INPUT");
           ProcessHandler errorStream =
                  new ProcessHandler(p.getErrorStream(),"ERROR");

          /* start the stream threads */
          inputStream.start();
          errorStream.start();


          int bufSize = 8192;
          BufferedReader stdInput = 
                 new BufferedReader(new InputStreamReader(p.getInputStream()));
          BufferedReader stdError = 
                 new BufferedReader(new InputStreamReader(p.getErrorStream()));


          String salida = stdInput.readLine();
          System.out.println("Leyendo salida");

          while(salida != null)
          {
                salida = stdInput.readLine();
                System.out.println(salida);
          }
          String salidaError = stdError.readLine();
          System.out.println("Leyendo salidaError");
          while(salidaError != null)
          {
                salidaError = stdError.readLine();
                System.out.println(salidaError);
          }
          rc = p.waitFor();
      }
      catch (Exception e)
      {
          e.printStackTrace();
          rcS = e.getMessage();
          System.out.println("Excepcion: "+rcS);
      }
                    
   }
}