//Title:        Java/ECLiPSe interface
//Version:      $Id: QueueExample1.java,v 1.9 2001/08/29 13:50:06 josh Exp $
//Copyright:    Copyright (c) 2001
//Author:       Josh Singer
//Company:      Parc Technologies
//Description:  Java/ECLiPSe Interface example Java program
import com.parctechnologies.eclipse.*;
import java.io.*;
import java.util.*;

public class QueueExample1
{
  public static void main(String[] args) throws Exception
  {
    // Create some default Eclipse options
    EclipseEngineOptions eclipseEngineOptions = new EclipseEngineOptions();

    // Object representing the Eclipse process
    EclipseEngine eclipse;

    // Path of the Eclipse program
    File eclipseProgram;

    // Data going out from java
    ToEclipseQueue java_to_eclipse;

    // Data coming in from eclipse
    FromEclipseQueue eclipse_to_java;

    // EXDR translation of data going out from Java
    EXDROutputStream java_to_eclipse_formatted;

    // EXDR translation of data coming in from eclipse
    EXDRInputStream eclipse_to_java_formatted;

    // Connect the Eclipse's standard streams to the JVM's
    eclipseEngineOptions.setUseQueues(false);

    // Initialise Eclipse
    eclipse = EmbeddedEclipse.getInstance(eclipseEngineOptions);

    String sep = System.getProperty("file.separator");

    // Set up the path of the example Eclipse program to be used.
    eclipseProgram = new File(System.getProperty("eclipse.directory") +
				   sep + "doc" + sep + "examples" + sep +
                                   "JavaInterface" + sep +
				   "queue_example_1.pl");

    // Compile the eclipse program.
    eclipse.compile(eclipseProgram);

    // Create the two queues
    java_to_eclipse = eclipse.getToEclipseQueue("java_to_eclipse");
    eclipse_to_java = eclipse.getFromEclipseQueue("eclipse_to_java");

    // Set up the two formatting streams
    java_to_eclipse_formatted = new EXDROutputStream(java_to_eclipse);
    eclipse_to_java_formatted = new EXDRInputStream(eclipse_to_java);

    java_to_eclipse_formatted.write(new Atom("a"));
    java_to_eclipse_formatted.write(new Atom("b"));
    java_to_eclipse_formatted.flush();

    eclipse.rpc("read_2_write_1");

    System.out.println(eclipse_to_java_formatted.readTerm());

    // Destroy the Eclipse process
    ((EmbeddedEclipse) eclipse).destroy();

  }

   /**
   * QueueListener which just writes everything to standard out.
   */
  static class OutputQL implements QueueListener
  {
    String name;
    EXDRInputStream eis;

    public OutputQL(String name, EXDRInputStream eis)
    {
      this.name = name;
      this.eis = eis;
    }

    public void dataAvailable(Object source)
    {
      try
      {
        while(((InputStream) source).available() > 0)
        {
          System.out.println(name + ": "+eis.readTerm());
        }
      }
      catch(IOException e)
      {
        System.err.println("IOException: "+e);
      }
    }

    public void dataRequest(Object source){};
  }

}