import edu.ucsb.eucalyptus.msgs.EucalyptusMessage;
import edu.ucsb.eucalyptus.msgs.EventRecord;
import edu.ucsb.eucalyptus.msgs.PutObjectType;
import edu.ucsb.eucalyptus.msgs.WalrusDataGetResponseType;
import edu.ucsb.eucalyptus.msgs.WalrusDeleteResponseType;
<BUG>@ChannelPipelineCoverage("one")

public class ServiceSinkHandler implements ChannelDownstreamHandler, ChannelUpstreamHandler{

private static Logger LOG = Logger.getLogger( ServiceSinkHandler.class );
@Override
public void handleDownstream( final ChannelHandlerContext ctx, final ChannelEvent e ) throws Exception {
ctx.sendDownstream( e );
}</BUG>
@Override

import edu.ucsb.eucalyptus.msgs.EucalyptusMessage;
import edu.ucsb.eucalyptus.msgs.EventRecord;
import edu.ucsb.eucalyptus.msgs.PutObjectType;
import edu.ucsb.eucalyptus.msgs.WalrusDataGetResponseType;
import edu.ucsb.eucalyptus.msgs.WalrusDeleteResponseType;
@ChannelPipelineCoverage( "one" )
public class ServiceSinkHandler implements ChannelDownstreamHandler, ChannelUpstreamHandler {
private static Logger LOG = Logger.getLogger( ServiceSinkHandler.class );
private long QUEUE_TIMEOUT_MS = 2; //TODO: measure me
private long               startTime;
private ChannelLocal<MappingHttpMessage> requestLocal = new ChannelLocal<MappingHttpMessage>();
@Override
