public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception
{
if (_stopping)
return;
Channel session = ctx.getChannel();
Message msg = (Message) e.getMessage();
if (msg.getCode() == Constants.WRAPPER_MSG_STOP)
try
{
System.out.println("wrapper manager received stop command");
_stopping = true;
if (session != null)
session.close();
// Thread.sleep(100);
if (msg.getMessage() != null && msg.getMessage().length() > 0)
try
{
_exitCode = Integer.parseInt(msg.getMessage());
}
catch (Exception ex)
{
// DO NOTHING
}
if (!_externalStop)
System.exit(_exitCode);
}
catch (Exception ex)
{
ex.printStackTrace();
}
else if (msg.getCode() == Constants.WRAPPER_MSG_OKKEY)
{
_session = session;
try
{
_myPid = Integer.parseInt(msg.getMessage());
}
catch (Exception ex)
{
ex.printStackTrace();
}
}
else if (msg.getCode() == Constants.WRAPPER_MSG_THREAD_DUMP)
{
threadDump();
}
}