in auxiliary-builds/jdk14/src/java/org/apache/commons/jcs/auxiliary/lateral/javagroups/LateralJGReceiverConnection.java [64:117]
public void run()
{
Object obj = null;
try
{
obj = mes.getObject();
LateralElementDescriptor led = (LateralElementDescriptor)obj;
if ( led == null )
{
log.warn( "LateralElementDescriptor is null! Can't do anything." );
}
else
{
if ( led.requesterId == LateralCacheInfo.listenerId )
{
log.debug( "from self" );
}
else
{
if ( log.isDebugEnabled() )
{
log.debug( "receiving LateralElementDescriptor from another, led = " + ", led = " + led
+ ", led.command = " + led.command + ", led.ce = " + led.ce + ", ilcl = " + ilcl );
}
if ( led.command == LateralElementDescriptor.UPDATE )
{
ilcl.handlePut( led.ce );
}
else if ( led.command == LateralElementDescriptor.REMOVE )
{
ilcl.handleRemove( led.ce.getCacheName(), led.ce.getKey() );
}
else if ( led.command == LateralElementDescriptor.GET )
{
/* Serializable obj = */getAndRespond( led.ce.getCacheName(), led.ce.getKey() );
}
}
}
}
catch ( java.io.EOFException e )
{
log.info( "Caught java.io.EOFException closing connection." );
}
catch ( java.net.SocketException e )
{
log.info( "Caught java.net.SocketException closing connection." );
}
catch ( Exception e )
{
log.error( "Unexpected exception. obj = " + obj, e );
}
}