diff --git a/transport-sctp/src/main/java/io/netty/channel/sctp/AbstractSctpChannelSink.java b/transport-sctp/src/main/java/io/netty/channel/sctp/AbstractSctpChannelSink.java
index 35403acb18..906fc35c99 100644
--- a/transport-sctp/src/main/java/io/netty/channel/sctp/AbstractSctpChannelSink.java
+++ b/transport-sctp/src/main/java/io/netty/channel/sctp/AbstractSctpChannelSink.java
@@ -30,7 +30,7 @@ public abstract class AbstractSctpChannelSink extends AbstractChannelSink {
         if (ch instanceof SctpChannelImpl) {
             SctpChannelImpl channel = (SctpChannelImpl) ch;
             ChannelRunnableWrapper wrapper = new ChannelRunnableWrapper(channel, task);
-            channel.worker.executeInIoThread(task);
+            channel.worker.executeInIoThread(wrapper);
             return wrapper;
              
         } else {