//
// SwitchRMI  Framework
// Copyright (c) 2000-2002 by Michael J. Henderson & Associates.
//
// Michael Henderson
// http://switchrmi.sf.net
// mailto:mikehenderson@dunelm.org.uk
//
// This library is free software.
//
// You may redistribute it and/or modify it under the terms of the GNU
// Lesser General Public License as published by the Free Software Foundation.
//
// Version 2.1 of the license should be included with this distribution in
// the file LICENSE, as well as License.html. If the license is not
// included with this distribution, you may find a copy at the FSF web
// site at 'www.gnu.org' or 'www.fsf.org', or you may write to the
// Free Software Foundation, 675 Mass Ave, Cambridge, MA 02139 USA.
//
// This library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied waranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
// Lesser General Public License for more details.
//
// $Id: TestTransport.java,v 1.1 2002/11/11 22:19:48 mikehenderson Exp $
package com.mjh.switchrmi.transport.test;

import com.mjh.switchrmi.*;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

import org.apache.log4j.Logger;

//
// call getOutputStream from client code to write the request
// call getInputStream from service side to read the request;
// -- here trigger the rpchandler lookup and invocation of the method
// call getOutputStream to write out the response
// call getInputStream on client side to read the
// 
//
//
//
public class TestTransport extends RmiTransportBase
{
    private static final Logger log = 
            Logger.getLogger(TestTransport.class.getName());
    private ByteArrayOutputStream out;
    private ByteArrayInputStream in;
    private int sendCount = 0;

    public TestTransport()
    {
        super.setType(RmiTransport.SYNCHRONOUS);
        super.setName("test");
    }

    public void send(RmiContext context)
              throws Exception
    {
        sendCount++;

        if ((sendCount % 2) == 1)
        {
            try
            {
                RmiHandler handler = new RmiHandler();

                handler.serviceInvoke(context, null);
            }
            catch (Exception ex)
            {
                log.debug("send()", ex);
            }
        }
    }

    public InputStream getInputStream(RmiContext context)
        throws IOException
    {
        in = new ByteArrayInputStream(out.toByteArray());

        return in;
    }

    public OutputStream getOutputStream(RmiContext context)
        throws IOException
    {
        out = new ByteArrayOutputStream();

        return out;
    }

    private void invoke()
    {
    }
}