|
||||||||||
| PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES | |||||||||
See:
Description
| Interface Summary | |
|---|---|
| IoServiceManagerMBean | |
| IoSessionManagerMBean | MBean interface for the session manager, it's used for instrumenting IoSession |
| Class Summary | |
|---|---|
| IoServiceManager | |
| IoSessionManager | |
JMX (Java Management eXtension) integration.
acceptor = new SocketAcceptor();
try
{
IoServiceManager iosm = new IoServiceManager(acceptor);
MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
ObjectName name = new ObjectName( "com.acme.test:type=IoServiceManager,name=MyMINAServer" );
mbs.registerMBean( iosm, name );
}
catch( JMException e )
{
logger.error( "JMX Exception: ", e );
}
acceptor.addListener( new IoServiceListener()
{
public void serviceActivated( IoService service, SocketAddress serviceAddress, IoHandler handler, IoServiceConfig config )
{
}
public void serviceDeactivated( IoService service, SocketAddress serviceAddress, IoHandler handler, IoServiceConfig config )
{
}
public void sessionCreated( IoSession session )
{
try
{
IoSessionManager sessMgr = new IoSessionManager( session );
MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
ObjectName name = new ObjectName( "com.acme.test.session:type=IoSessionManager,name=" + session.getRemoteAddress().toString().replace( ':', '/' ) );
mbs.registerMBean( sessMgr, name );
}
catch( JMException e )
{
logger.error( "JMX Exception: ", e );
}
}
public void sessionDestroyed( IoSession session )
{
try
{
ObjectName name = new ObjectName( "com.acme.test.session:type=IoSessionManager,name=" + session.getRemoteAddress().toString().replace( ':', '/' ) );
ManagementFactory.getPlatformMBeanServer().unregisterMBean( name );
}
catch( JMException e )
{
logger.error( "JMX Exception: ", e );
}
}
});
|
||||||||||
| PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES | |||||||||