test fix

Author: mhl-b

modules/transport-netty4/src/test/java/org/elasticsearch/http/netty4/Netty4HttpHeaderThreadContextTests.java

@@ -73,6 +73,7 @@ public void testSuccessfulSyncValidationUntamperedThreadContext() throws Excepti
                 )
             );
         channel.pipeline().addLast(defaultContextAssertingChannelHandler(threadPool.getThreadContext()));
+        channel.pipeline().fireChannelRegistered();
         // send first request through
         sendRequestThrough(isValidationSuccessful.get(), null);
         // send second request through, to check in case the context got stained by the first one through
@@ -93,6 +94,7 @@ public void testFailedSyncValidationUntamperedThreadContext() throws Exception {
                 )
             );
         channel.pipeline().addLast(defaultContextAssertingChannelHandler(threadPool.getThreadContext()));
+        channel.pipeline().fireChannelRegistered();
         // send first request through
         sendRequestThrough(isValidationSuccessful.get(), null);
         // send second request through, to check in case the context got stained by the first one through
@@ -115,6 +117,7 @@ public void testSuccessfulAsyncValidationUntamperedThreadContext() throws Except
                 )
             );
         channel.pipeline().addLast(defaultContextAssertingChannelHandler(threadPool.getThreadContext()));
+        channel.pipeline().fireChannelRegistered();
         // send first request through
         sendRequestThrough(isValidationSuccessful.get(), validationDone);
         // send second request through, to check in case the context got stained by the first one through
@@ -137,6 +140,7 @@ public void testUnsuccessfulAsyncValidationUntamperedThreadContext() throws Exce
                 )
             );
         channel.pipeline().addLast(defaultContextAssertingChannelHandler(threadPool.getThreadContext()));
+        channel.pipeline().fireChannelRegistered();
         // send first request through
         sendRequestThrough(isValidationSuccessful.get(), validationDone);
         // send second request through, to check in case the context got stained by the first one through