package javaclient;

import java.io.ByteArrayInputStream;
import java.io.InputStream;
import java.lang.*;
import java.io.*;
import java.net.*;
import org.apache.axis.client.Call;
import org.apache.axis.client.Service;
import org.apache.axis.message.SOAPEnvelope;

public class getresv {

  public boolean execute() {
    boolean retBool = true;
    String xmlinput;
    String endpoint;
    try
    {
      System.out.print("\n\nStarted");
      ServerSocket welcomeSocket = new ServerSocket(5510);
      Socket connectionSocket = welcomeSocket.accept();
      System.out.print("\n\nServer has connected!");

      BufferedReader inFromClient = new BufferedReader(new InputStreamReader(connectionSocket.getInputStream()));
      DataOutputStream outToClient = new DataOutputStream(connectionSocket.getOutputStream());

      xmlinput = inFromClient.readLine();

      System.out.print("\n\nxml in: " + xmlinput);

      endpoint = inFromClient.readLine();

      System.out.print("\n\nendpoint: " + endpoint);

      StringBuffer xmlBuffer = new StringBuffer();
      xmlBuffer.append(xmlinput);
      
      ByteArrayInputStream byteIn = new ByteArrayInputStream(xmlBuffer.toString().getBytes());
      InputStream input = byteIn;

      SOAPEnvelope reqMsg = new SOAPEnvelope(input);
      String websrvendpt = endpoint;
      Service webService = new Service();
      Call call = (Call)webService.createCall();
      call.setTargetEndpointAddress(websrvendpt);
      call.setTimeout(new Integer(1000000));

      System.out.println("\n\nOutgoing:\n" + reqMsg);

      SOAPEnvelope xmlin = (SOAPEnvelope)call.invoke(reqMsg);
      String respMsg = xmlin.toString();

      System.out.println("\n\nIncoming:\n" + respMsg + "\n");
      
      outToClient.writeBytes(respMsg + '\n');

      Thread.sleep(1000);

      System.out.println("\n\nSent response to PMS...\n");

      connectionSocket.close();
      welcomeSocket.close();
    }
    catch (UnknownHostException ex) {
      System.out.println("\n\nUnknown Ssytem Error: " + ex.getMessage());
    }
    catch (Exception ex) {
      System.out.println("\n\nError: " + ex.getMessage());
    }
    return retBool;
  }

   public static void main(String[] args) throws Exception {
   boolean retBool = (new getresv()).execute();
  }
}