java.nio.channels.ClosedChannelException BayeuxRouter (Bayeux4Netty)

["이희승 (Trustin Lee)"]

Hi,

Bayeux4Netty has not been maintained for a long time.  I'm not sure if 
it is bug-free at the moment.  You might want to talk to Dai Jun 
(guiwuu at gmail.com), the author.

HTH

ILACBNIASW wrote:
> Hi, I'm trying to publish messages via BayeuxRouter from a single thread. I
> have a run method which creates a List<DeliverEvent>  messages, then
> BayeuxRouter.getInstance().publish(null, messages), but I get the
> java.nio.channels.ClosedChannelException below. I have a few clients
> connected and subscribed to the channel I am publishing the messages on but
> due to this exception only some of the messages are delivered. This happens
> regardless of whether the connected clients are sending messages.
>
> What am I doing wrong ? There's nearly no information on Bayeux4Netty out
> there!
>
> java.nio.channels.ClosedChannelException
> 	at
> org.jboss.netty.channel.socket.nio.NioWorker.cleanUpWriteBuffer(NioWorker.java:631)
> 	at org.jboss.netty.channel.socket.nio.NioWorker.close(NioWorker.java:590)
> 	at
> org.jboss.netty.channel.socket.nio.NioServerSocketPipelineSink.handleAcceptedSocket(NioServerSocketPipelineSink.java:119)
> 	at
> org.jboss.netty.channel.socket.nio.NioServerSocketPipelineSink.eventSunk(NioServerSocketPipelineSink.java:76)
> 	at
> org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:59)
> 	at
> org.jboss.netty.handler.codec.bayeux.BayeuxEncoder.handleDownstream(BayeuxEncoder.java:52)
> 	at org.jboss.netty.channel.Channels.close(Channels.java:1065)
> 	at org.jboss.netty.channel.AbstractChannel.close(AbstractChannel.java:178)
> 	at
> org.jboss.netty.channel.ChannelFutureListener$1.operationComplete(ChannelFutureListener.java:46)
> 	at
> org.jboss.netty.channel.DefaultChannelFuture.notifyListener(DefaultChannelFuture.java:366)
> 	at
> org.jboss.netty.channel.DefaultChannelFuture.notifyListeners(DefaultChannelFuture.java:352)
> 	at
> org.jboss.netty.channel.DefaultChannelFuture.setSuccess(DefaultChannelFuture.java:303)
> 	at
> org.jboss.netty.channel.socket.nio.NioWorker.writeNow(NioWorker.java:446)
> 	at org.jboss.netty.channel.socket.nio.NioWorker.write(NioWorker.java:357)
> 	at
> org.jboss.netty.channel.socket.nio.NioSocketChannel$WriteTask.run(NioSocketChannel.java:233)
> 	at
> org.jboss.netty.channel.socket.nio.NioWorker.processWriteTaskQueue(NioWorker.java:264)
> 	at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:193)
> 	at
> org.jboss.netty.util.internal.IoWorkerRunnable.run(IoWorkerRunnable.java:46)
> 	at
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> 	at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> 	at java.lang.Thread.run(Thread.java:662)
>
> --
> View this message in context: http://netty-forums-and-mailing-lists.685743.n2.nabble.com/java-nio-channels-ClosedChannelException-BayeuxRouter-Bayeux4Netty-tp6617293p6617293.html
> Sent from the Netty User Group mailing list archive at Nabble.com.
> _______________________________________________
> netty-users mailing list
> netty-users at lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/netty-users

-- 
Trustin Lee, http://gleamynode.net/