mresponsesender.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.MDoorman;

import java.io.*;
import net.jumperz.util.*;

public class MResponseSender
implements MCommand, MSubject1, Runnable
{
private OutputStream outputStream;
private byte[] buffer;
private int state;

public static final int SUCCESS	= 0;
public static final int DISCONNECTED	= 1;

private MSubject1 subject = new MSubject1Impl();
//----------------------------------------------------------------
public MResponseSender( OutputStream os, byte[] buf )
{
outputStream = os;
buffer = buf;
state = SUCCESS;
}
// --------------------------------------------------------------------------------
public void run()
{
execute();
}
//----------------------------------------------------------------
public void execute()
{
try
	{
	outputStream.write( buffer );
	}
catch( IOException e )
	{
	e.printStackTrace();
	state = DISCONNECTED;
	}
notify1();
}
//----------------------------------------------------------------
public void breakCommand()
{
try
	{
	outputStream.close();
	}
catch( IOException e )
	{
	}	
}
//----------------------------------------------------------------
public int getState()
{
return state;
}
//----------------------------------------------------------------
public void notify1()
{
subject.notify1();
}
//----------------------------------------------------------------
public void register1( MObserver1 observer )
{
subject.register1( observer );
}
//----------------------------------------------------------------
public void removeObservers1()
{
subject.removeObservers1();
}
//----------------------------------------------------------------
public void removeObserver1( MObserver1 observer )
{
subject.removeObserver1( observer );
}
//----------------------------------------------------------------
}