Java Reference
In-Depth Information
import java.lang.reflect.*;
import java.util.*;
public class TCPAdapter implements Runnable
{
private MBeanServer server = null;
private Socket socket = null;
private BufferedReader in = null;
private PrintWriter out = null;
public static String SHUTDOWN = "shutdown";
public static String CREATE_MBEAN = "create mbean";
public static String GET_ATTRIBUTE = "get_attribute";
public static String SET_ATTRIBUTE = "set_attribute";
public static String INVOKE = "invoke";
public static String ARGS = "args";
public TCPAdapter( Socket socket, MBeanServer server )
{
this.socket = socket;
this.server = server;
try
{
this.out = new PrintWriter( socket.getOutputStream() );
this.in = new BufferedReader(
new InputStreamReader( socket.getInputStream() ) );
System.out.println( "TCP Adapter CREATED" );
}
catch( Exception e )
{
e.printStackTrace();
}
}
public void run()
{
try
{
System.out.println( "TCP adapter starting..." );
String line = in.readLine();
B
Read until
shutdown
while( !line.equals( SHUTDOWN ) )
{
if( line.equals( CREATE_MBEAN ) )
{
try
{
createMBean( );
out.println( "SUCCESS" );
out.flush();
}
catch( Exception e )
{
