Remove the ContextTask since we can use Runnable in practice instead

src/main/java/io/vertx/core/datagram/impl/DatagramServerHandler.java

@@ -35,7 +35,7 @@ public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
   }
 
   @Override
-  protected void handleMessage(final DatagramSocketImpl.Connection server, final Object msg) throws Exception {
+  protected void handleMessage(final DatagramSocketImpl.Connection server, final Object msg) {
     server.handlePacket((io.vertx.core.datagram.DatagramPacket) msg);
   }
 

src/main/java/io/vertx/core/http/impl/Http1xClientConnection.java

@@ -321,7 +321,7 @@ public void channelRead(ChannelHandlerContext chctx, Object msg) throws Exceptio
             super.channelRead(chctx, msg);
           }
           @Override
-          protected void handleMessage(NetSocketImpl connection, Object msg) throws Exception {
+          protected void handleMessage(NetSocketImpl connection, Object msg) {
             ByteBuf buf = (ByteBuf) msg;
             connection.handleMessageReceived(buf);
           }

src/main/java/io/vertx/core/http/impl/Http1xClientHandler.java

@@ -89,7 +89,7 @@ public void channelInactive(ChannelHandlerContext chctx) throws Exception {
   }
 
   @Override
-  protected void handleMessage(Http1xClientConnection conn, Object msg) throws Exception {
+  protected void handleMessage(Http1xClientConnection conn, Object msg) {
     if (msg instanceof HttpObject) {
       HttpObject obj = (HttpObject) msg;
       DecoderResult result = obj.decoderResult();

src/main/java/io/vertx/core/http/impl/Http1xServerConnection.java

@@ -267,7 +267,7 @@ public void channelRead(ChannelHandlerContext chctx, Object msg) throws Exceptio
       }
 
       @Override
-      protected void handleMessage(NetSocketImpl connection, Object msg) throws Exception {
+      protected void handleMessage(NetSocketImpl connection, Object msg) {
         ByteBuf buf = (ByteBuf) msg;
         connection.handleMessageReceived(buf);
       }

src/main/java/io/vertx/core/http/impl/Http1xServerHandler.java

@@ -75,7 +75,7 @@ public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
   }
 
   @Override
-  protected void handleMessage(Http1xServerConnection conn, Object msg) throws Exception {
+  protected void handleMessage(Http1xServerConnection conn, Object msg) {
     conn.handleMessage(msg);
   }
 

src/main/java/io/vertx/core/http/impl/Http2ClientConnection.java

@@ -151,7 +151,7 @@ static class Http2ClientStream extends VertxHttp2Stream<Http2ClientConnection> i
     private boolean requestEnded;
     private boolean responseEnded;
 
-    public Http2ClientStream(Http2ClientConnection conn, HttpClientRequestBase request, Http2Stream stream, boolean writable) throws Http2Exception {
+    public Http2ClientStream(Http2ClientConnection conn, HttpClientRequestBase request, Http2Stream stream, boolean writable) {
       super(conn, stream, writable);
       this.request = request;
     }

src/main/java/io/vertx/core/http/impl/HttpClientRequestPushPromise.java

@@ -11,7 +11,6 @@
 
 package io.vertx.core.http.impl;
 
-import io.netty.handler.codec.http2.Http2Exception;
 import io.netty.handler.codec.http2.Http2Stream;
 import io.vertx.codegen.annotations.Nullable;
 import io.vertx.core.Handler;
@@ -44,7 +43,7 @@ public HttpClientRequestPushPromise(
       String uri,
       String host,
       int port,
-      MultiMap headers) throws Http2Exception {
+      MultiMap headers) {
     super(client, ssl, method, host, port, uri);
     this.conn = conn;
     this.stream = new Http2ClientConnection.Http2ClientStream(conn, this, stream, false);

src/main/java/io/vertx/core/http/impl/HttpServerImpl.java

@@ -645,7 +645,7 @@ public ServerHandlerWithWebSockets(SSLHelper sslHelper, HttpServerOptions option
     }
 
     @Override
-    protected void handleMessage(Http1xServerConnection conn, Object msg) throws Exception {
+    protected void handleMessage(Http1xServerConnection conn, Object msg) {
       Channel ch = conn.channel();
       if (msg instanceof HttpRequest) {
         final HttpRequest request = (HttpRequest) msg;

src/main/java/io/vertx/core/impl/ContextImpl.java

@@ -174,7 +174,7 @@ static boolean isOnVertxThread(boolean worker) {
   // This is called to execute code where the origin is IO (from Netty probably).
   // In such a case we should already be on an event loop thread (as Netty manages the event loops)
   // but check this anyway, then execute directly
-  public void executeFromIO(ContextTask task) {
+  public void executeFromIO(Runnable task) {
     if (THREAD_CHECKS) {
       checkCorrectThread();
     }
@@ -298,7 +298,7 @@ public synchronized ConcurrentMap<Object, Object> contextData() {
     return contextData;
   }
 
-  protected Runnable wrapTask(ContextTask cTask, Handler<Void> hTask, boolean checkThread, PoolMetrics metrics) {
+  protected Runnable wrapTask(Runnable cTask, Handler<Void> hTask, boolean checkThread, PoolMetrics metrics) {
     Object metric = metrics != null ? metrics.submitted() : null;
     return () -> {
       Thread th = Thread.currentThread();

src/main/java/io/vertx/core/impl/ContextInternal.java

@@ -79,7 +79,7 @@ static boolean isOnVertxThread() {
    *
    * @param task the task to execute
    */
-  void executeFromIO(ContextTask task);
+  void executeFromIO(Runnable task);
 
   /**
    * @return the {@link ConcurrentMap} used to store context data

src/main/java/io/vertx/core/impl/WorkerContext.java

@@ -47,7 +47,7 @@ protected void checkCorrectThread() {
   // In the case of a worker context, the IO will always be provided on an event loop thread, not a worker thread
   // so we need to execute it on the worker thread
   @Override
-  public void executeFromIO(ContextTask task) {
+  public void executeFromIO(Runnable task) {
     orderedTasks.execute(wrapTask(task, null, true, workerPool.metrics()), workerPool.executor());
   }
 

src/main/java/io/vertx/core/net/impl/NetClientImpl.java

@@ -235,7 +235,7 @@ private void connected(ContextInternal context, Channel ch, Handler<AsyncResult<
 
     VertxNetHandler handler = new VertxNetHandler(ctx -> new NetSocketImpl(vertx, ctx, remoteAddress, context, sslHelper, metrics)) {
       @Override
-      protected void handleMessage(NetSocketImpl connection, Object msg) throws Exception {
+      protected void handleMessage(NetSocketImpl connection, Object msg) {
         connection.handleMessageReceived(msg);;
       }
     };

src/main/java/io/vertx/core/net/impl/NetServerImpl.java

@@ -436,7 +436,7 @@ private void connected(HandlerHolder<Handlers> handler, Channel ch) {
 
     VertxNetHandler nh = new VertxNetHandler(ctx -> new NetSocketImpl(vertx, ctx, handler.context, sslHelper, metrics)) {
       @Override
-      protected void handleMessage(NetSocketImpl connection, Object msg) throws Exception {
+      protected void handleMessage(NetSocketImpl connection, Object msg) {
         connection.handleMessageReceived(msg);
       }
     };

src/main/java/io/vertx/core/net/impl/VertxHandler.java

@@ -22,15 +22,14 @@
 import io.netty.handler.timeout.IdleStateEvent;
 import io.vertx.core.Handler;
 import io.vertx.core.impl.ContextInternal;
-import io.vertx.core.impl.ContextTask;
 
 /**
  * @author <a href="mailto:nmaurer@redhat.com">Norman Maurer</a>
  */
 public abstract class   VertxHandler<C extends ConnectionBase> extends ChannelDuplexHandler {
 
   private C conn;
-  private ContextTask endReadAndFlush;
+  private Runnable endReadAndFlush;
   private Handler<C> addHandler;
   private Handler<C> removeHandler;
 
@@ -155,7 +154,7 @@ public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exc
     ctx.fireUserEventTriggered(evt);
   }
 
-  protected abstract void handleMessage(C connection, Object msg) throws Exception;
+  protected abstract void handleMessage(C connection, Object msg);
 
   /**
    * Decode the message before passing it to the channel