/*
    * Created on 19-Apr-2004
    */
   package ca.uhn.hl7v2.protocol.impl;
   
   import java.io.IOException;
   import java.net.Socket;
   import java.net.SocketAddress;
   
  import ca.uhn.hl7v2.protocol.TransportException;
  
  /**
   * A client-side <code>SocketStreamSource</code>.  
   * 
   * @author <a href="mailto:bryan.tripp@uhn.on.ca">Bryan Tripp</a>
   * @version $Revision: 1.1 $ updated on $Date: 2007-02-19 02:24:26 $ by $Author: jamesagnew $
   */
  public class ClientSocketStreamSource extends SocketStreamSource {
  
      private final SocketAddress myAddress;
      private Socket mySocket;
  
      /**
       * @param theAddress the address at which to connect sockets
       */
      public ClientSocketStreamSource(SocketAddress theAddress) {
          myAddress = theAddress;
      }
  
      /** 
       * @see ca.uhn.hl7v2.protocol.impl.SocketStreamSource#getSocket()
       */
      public Socket getSocket() {
          return mySocket;
      }
  
      /** 
       * Gets fresh instances of sockets.  
       */
      public void connect() throws TransportException {
          mySocket = getSocket(myAddress);
      }
  
      private Socket getSocket(SocketAddress theAddress) throws TransportException {
          Socket s = new Socket();        
          try {
              s.connect(theAddress);
          } catch (IOException e) {
              throw new TransportException(e);
          }
          return s;        
      }
  
  }