From 62028f0042868af9211e188d0f2fc7cc06edc08f Mon Sep 17 00:00:00 2001 From: norman Date: Wed, 7 Mar 2012 14:15:42 +0100 Subject: [PATCH] execute the wrapped Runnable --- .../java/io/netty/channel/sctp/AbstractSctpChannelSink.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 {