} );
deadConnectionsPoller = new ScheduledThreadPoolExecutor( 1 );
deadConnectionsPoller.scheduleWithFixedDelay( new Runnable()
{
public void run()
<BUG>{
}</BUG>
}, DEAD_CONNECTIONS_CHECK_INTERVAL, DEAD_CONNECTIONS_CHECK_INTERVAL, TimeUnit.SECONDS );
}
public ChannelPipeline getPipeline() throws Exception

} );
deadConnectionsPoller = new ScheduledThreadPoolExecutor( 1 );
deadConnectionsPoller.scheduleWithFixedDelay( new Runnable()
{
public void run()
{
checkForDeadChannels();
}
}, DEAD_CONNECTIONS_CHECK_INTERVAL, DEAD_CONNECTIONS_CHECK_INTERVAL, TimeUnit.SECONDS );
}
public ChannelPipeline getPipeline() throws Exception
