Hi,
sorry for reviving this very old email thread.
Are there any updates or workarounds for this issue?
The bug in the tracker has been marked as "not reproducible", but we're
seeing the error quite often (I would guess in 10% of our automated tests).
On Tuesday, November 26, 2013 at 8:07:02 AM UTC+1, Björn Antonsson wrote:
>
> Hi Greg,
>
> On Tuesday, 26 November 2013 at 03:06, tigerfoot wrote:
>
> Hello,
>
> I've got two Akka ActorSystems (using Cluster for test cases). Config
> below. I know--cluster is way overkill here, but I'm testing the mechanism
> for a much larger use.
>
> My test looks like this:
>
> val s1 = Server1() // initiates an ActorSystem inside the Server1 class
>
> // Establish a second ActorSystem to simulate another remote client on the
> network sending messages to the first.
> val host = s1.context.myHostname // my local IP address (not localhost)
> val sys2 = ActorSystem("foobar",
> ConfigFactory.parseString(ServerConfigs.svr2Cfg) )
> val selection =
> sys2.actorSelection(
> s"""akka.tcp://MyCluster@$host:9021/user/awe.server.ServerModule"""
> )
> selection ! ServerEvent( "acme", "hello", None )
>
> // Simulate doing work
> Thread.sleep(500)
>
> // Shut things down cleanly
> s1.shutdown
> s1.system.awaitTermination
> sys2.shutdown
> sys2.awaitTermination
> assert( s1.system.isTerminated )
> assert( sys2.isTerminated )
>
> Now this functions just fine, but I'm getting the noisy exception at the
> bottom of my post. Any idea what's causing that?
> I saw this post here and wondered if this is the same thing:
> https://www.assembla.com/spaces/akka/tickets/3096#/activity/ticket:
>
>
> Thanks for looking at the tickets. You are right that your exception log
> is the one in the ticket. It’s not an error in your application. It’s a
> known issue and it looks bad in the logs.
>
> B/
>
>
> Thanks for any ideas!
> Greg
>
> Config:
> val svr1Cfg = s"""
> akka {
> loglevel = "ERROR"
> stdout-loglevel = "ERROR"
> loggers = ["akka.event.slf4j.Slf4jLogger"]
> actor {
> provider = "akka.cluster.ClusterActorRefProvider"
> }
> remote {
> enabled-transports = ["akka.remote.netty.tcp"]
> netty.tcp {
> port = 9021
> }
> }
> cluster {
> seed-nodes = [ "akka.tcp://MyCluster@$myHost:9021" ]
> auto-down = on
> log-info = off
> }
> }
> """
>
> val svr2Cfg = s"""
> akka {
> loglevel = "ERROR"
> stdout-loglevel = "ERROR"
> loggers = ["akka.event.slf4j.Slf4jLogger"]
> actor {
> provider = "akka.cluster.ClusterActorRefProvider"
> }
> remote {
> enabled-transports = ["akka.remote.netty.tcp"]
> netty.tcp {
> port = 9022
> }
> }
> cluster {
> seed-nodes = [ "akka.tcp://MyCluster@$myHost:9021" ]
> auto-down = on
> log-info = off
> }
> }
> """
>
> Nov 25, 2013 8:00:59 PM org.jboss.netty.channel.DefaultChannelPipeline
> WARNING: An exception was thrown by an exception handler.
> java.util.concurrent.RejectedExecutionException: Worker has already been
> shutdown
> at
> org.jboss.netty.channel.socket.nio.AbstractNioSelector.registerTask(AbstractNioSelector.java:115)
> at
> org.jboss.netty.channel.socket.nio.AbstractNioWorker.executeInIoThread(AbstractNioWorker.java:73)
> at
> org.jboss.netty.channel.socket.nio.NioWorker.executeInIoThread(NioWorker.java:36)
> at
> org.jboss.netty.channel.socket.nio.AbstractNioWorker.executeInIoThread(AbstractNioWorker.java:57)
> at
> org.jboss.netty.channel.socket.nio.NioWorker.executeInIoThread(NioWorker.java:36)
> at
> org.jboss.netty.channel.socket.nio.AbstractNioChannelSink.execute(AbstractNioChannelSink.java:34)
> at
> org.jboss.netty.channel.Channels.fireExceptionCaughtLater(Channels.java:496)
> at
> org.jboss.netty.channel.AbstractChannelSink.exceptionCaught(AbstractChannelSink.java:46)
> at
> org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
> at org.jboss.netty.channel.Channels.disconnect(Channels.java:781)
> at
> org.jboss.netty.channel.AbstractChannel.disconnect(AbstractChannel.java:211)
> at
> akka.remote.transport.netty.NettyTransport$$anonfun$gracefulClose$1.apply(NettyTransport.scala:222)
> at
> akka.remote.transport.netty.NettyTransport$$anonfun$gracefulClose$1.apply(NettyTransport.scala:221)
> at scala.util.Success.foreach(Try.scala:205)
> at scala.concurrent.Future$$anonfun$foreach$1.apply(Future.scala:204)
> at scala.concurrent.Future$$anonfun$foreach$1.apply(Future.scala:204)
> at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32)
> at
> akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.processBatch$1(BatchingExecutor.scala:67)
> at
> akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:82)
> at
> akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59)
> at
> akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59)
> at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72)
> at akka.dispatch.BatchingExecutor$Batch.run(BatchingExecutor.scala:58)
> at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:42)
> at
> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:386)
> at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> at
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
>
> --
> >>>>>>>>>> Read the docs: http://akka.io/docs/
> >>>>>>>>>> Check the FAQ: http://akka.io/faq/
> >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
> ---
> You received this message because you are subscribed to the Google Groups
> "Akka User List" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to [email protected] <javascript:>.
> To post to this group, send email to [email protected]
> <javascript:>.
> Visit this group at http://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/groups/opt_out.
>
>
> --
> Björn Antonsson
> Typesafe <http://typesafe.com/> – Reactive Apps on the JVM
> twitter: @bantonsson <http://twitter.com/#!/bantonsson>
>
>
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
