norg.walkmod.nsq.exceptions.NSQException: java.net.ConnectException: Connection refused

GitHub | indykish | 5 months ago
  1. 0

    Ignore errors If NSQ is down, but we receive an error in the calling system

    GitHub | 5 months ago | indykish
    norg.walkmod.nsq.exceptions.NSQException: java.net.ConnectException: Connection refused

    Root Cause Analysis

    1. norg.walkmod.nsq.exceptions.NSQException

      java.net.ConnectException: Connection refused

      at org.walkmod.nsq.NSQProducer.put()
    2. org.walkmod.nsq
      NSQProducer.put
      1. org.walkmod.nsq.NSQProducer.put(NSQProducer.java:98)
      1 frame
    3. io.megam.common
      NSQClient$$anonfun$executePublish$1$$anonfun$apply$5$$anonfun$apply$1.apply
      1. io.megam.common.amqp.NSQClient$$anonfun$executePublish$1$$anonfun$apply$5$$anonfun$apply$1.apply$mcV$sp(NSQClient.scala:71)
      2. io.megam.common.amqp.NSQClient$$anonfun$executePublish$1$$anonfun$apply$5$$anonfun$apply$1.apply(NSQClient.scala:71)
      3. io.megam.common.amqp.NSQClient$$anonfun$executePublish$1$$anonfun$apply$5$$anonfun$apply$1.apply(NSQClient.scala:71)
      3 frames
    4. Scalaz
      Validation$.fromTryCatchThrowable
      1. scalaz.ValidationFunctions$class.fromTryCatchThrowable(Validation.scala:529)
      2. scalaz.Validation$.fromTryCatchThrowable(Validation.scala:347)
      2 frames
    5. io.megam.common
      NSQClient$$anonfun$executePublish$1$$anonfun$apply$5.apply
      1. io.megam.common.amqp.NSQClient$$anonfun$executePublish$1$$anonfun$apply$5.apply(NSQClient.scala:70)
      2. io.megam.common.amqp.NSQClient$$anonfun$executePublish$1$$anonfun$apply$5.apply(NSQClient.scala:69)
      2 frames
    6. Scalaz
      ValidationFlatMap.flatMap
      1. scalaz.ValidationFlatMap.flatMap(Validation.scala:433)
      1 frame
    7. io.megam.common
      NSQClient$$anonfun$executePublish$1.apply
      1. io.megam.common.amqp.NSQClient$$anonfun$executePublish$1.apply(NSQClient.scala:69)
      2. io.megam.common.amqp.NSQClient$$anonfun$executePublish$1.apply(NSQClient.scala:69)
      2 frames
    8. Scala
      Future$PromiseCompletingRunnable.run
      1. scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
      2. scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
      2 frames
    9. io.megam.common
      package$$anon$1.execute
      1. io.megam.common.concurrent.package$$anon$1.execute(package.scala:31)
      1 frame
    10. Scala
      Future$.apply
      1. scala.concurrent.impl.Future$.apply(Future.scala:31)
      2. scala.concurrent.Future$.apply(Future.scala:494)
      2 frames
    11. io.megam.common
      PublishRequest$$anon$1.apply
      1. io.megam.common.amqp.NSQClient.executePublish(NSQClient.scala:68)
      2. io.megam.common.amqp.NSQClient$$anonfun$publish$1.apply(NSQClient.scala:84)
      3. io.megam.common.amqp.NSQClient$$anonfun$publish$1.apply(NSQClient.scala:84)
      4. io.megam.common.amqp.request.PublishRequest$$anon$1.apply$lzycompute(AMQPRequest.scala:77)
      5. io.megam.common.amqp.request.PublishRequest$$anon$1.apply(AMQPRequest.scala:77)
      5 frames
    12. wash
      AOneWasher.wash
      1. wash.MessageContext$class.execute(MessageContext.scala:46)
      2. wash.AOneWasher.execute(AOneWasher.scala:33)
      3. wash.AOneWasher.wash(AOneWasher.scala:41)
      3 frames
    13. models.base
      Events$lambda$$createAndPub$2.apply
      1. models.base.Events.models$base$Events$$$anonfun$4(Events.scala:74)
      2. models.base.Events$lambda$$createAndPub$2.apply(Events.scala:72)
      3. models.base.Events$lambda$$createAndPub$2.apply(Events.scala:72)
      3 frames
    14. Scalaz
      ValidationFlatMap.flatMap
      1. scalaz.ValidationFlatMap.flatMap(Validation.scala:433)
      1 frame
    15. models.base
      Accounts$lambda$$$nestedInAnonfun$39$1.apply
      1. models.base.Events.createAndPub(Events.scala:72)
      2. models.base.Accounts$.models$base$Accounts$$$anonfun$40(Accounts.scala:200)
      3. models.base.Accounts$lambda$$$nestedInAnonfun$39$1.apply(Accounts.scala:199)
      4. models.base.Accounts$lambda$$$nestedInAnonfun$39$1.apply(Accounts.scala:199)
      4 frames
    16. Scalaz
      ValidationFlatMap.flatMap
      1. scalaz.ValidationFlatMap.flatMap(Validation.scala:433)
      1 frame
    17. models.base
      Accounts$lambda$$$nestedInAnonfun$38$1.apply
      1. models.base.Accounts$.models$base$Accounts$$$anonfun$39(Accounts.scala:199)
      2. models.base.Accounts$lambda$$$nestedInAnonfun$38$1.apply(Accounts.scala:198)
      3. models.base.Accounts$lambda$$$nestedInAnonfun$38$1.apply(Accounts.scala:198)
      3 frames
    18. Scalaz
      ValidationFlatMap.flatMap
      1. scalaz.ValidationFlatMap.flatMap(Validation.scala:433)
      1 frame
    19. models.base
      Accounts$lambda$$$nestedInAnonfun$37$1.apply
      1. models.base.Accounts$.models$base$Accounts$$$anonfun$38(Accounts.scala:198)
      2. models.base.Accounts$lambda$$$nestedInAnonfun$37$1.apply(Accounts.scala:197)
      3. models.base.Accounts$lambda$$$nestedInAnonfun$37$1.apply(Accounts.scala:197)
      3 frames
    20. Scalaz
      ValidationFlatMap.flatMap
      1. scalaz.ValidationFlatMap.flatMap(Validation.scala:433)
      1 frame
    21. models.base
      Accounts$lambda$$$nestedInAnonfun$36$1.apply
      1. models.base.Accounts$.models$base$Accounts$$$anonfun$37(Accounts.scala:197)
      2. models.base.Accounts$lambda$$$nestedInAnonfun$36$1.apply(Accounts.scala:196)
      3. models.base.Accounts$lambda$$$nestedInAnonfun$36$1.apply(Accounts.scala:196)
      3 frames
    22. Scalaz
      ValidationFlatMap.flatMap
      1. scalaz.ValidationFlatMap.flatMap(Validation.scala:433)
      1 frame
    23. models.base
      Accounts$lambda$$models$base$Accounts$$$nestedInAnonfun$34$2.apply
      1. models.base.Accounts$.models$base$Accounts$$$anonfun$36(Accounts.scala:196)
      2. models.base.Accounts$lambda$$models$base$Accounts$$$nestedInAnonfun$34$2.apply(Accounts.scala:195)
      3. models.base.Accounts$lambda$$models$base$Accounts$$$nestedInAnonfun$34$2.apply(Accounts.scala:195)
      3 frames
    24. Scalaz
      ValidationFlatMap.flatMap
      1. scalaz.ValidationFlatMap.flatMap(Validation.scala:433)
      1 frame
    25. models.base
      Accounts$lambda$$create$1.apply
      1. models.base.Accounts$.models$base$Accounts$$$anonfun$34(Accounts.scala:195)
      2. models.base.Accounts$lambda$$create$1.apply(Accounts.scala:194)
      3. models.base.Accounts$lambda$$create$1.apply(Accounts.scala:194)
      3 frames
    26. Scalaz
      ValidationFlatMap.flatMap
      1. scalaz.ValidationFlatMap.flatMap(Validation.scala:433)
      1 frame
    27. models.base
      Accounts$.create
      1. models.base.Accounts$.create(Accounts.scala:194)
      1 frame
    28. controllers
      Accounts$lambda$$post$1.apply
      1. controllers.Accounts$.controllers$Accounts$$$anonfun$1(Accounts.scala:43)
      2. controllers.Accounts$lambda$$post$1.apply(Accounts.scala:40)
      3. controllers.Accounts$lambda$$post$1.apply(Accounts.scala:40)
      3 frames
    29. Play
      Action$$anonfun$apply$1$$anonfun$apply$4.apply
      1. play.api.mvc.ActionBuilder$$anonfun$apply$16.apply(Action.scala:408)
      2. play.api.mvc.ActionBuilder$$anonfun$apply$16.apply(Action.scala:407)
      3. play.api.mvc.Action$.invokeBlock(Action.scala:533)
      4. play.api.mvc.Action$.invokeBlock(Action.scala:530)
      5. play.api.mvc.ActionBuilder$$anon$1.apply(Action.scala:493)
      6. play.api.mvc.Action$$anonfun$apply$1$$anonfun$apply$4$$anonfun$apply$5.apply(Action.scala:105)
      7. play.api.mvc.Action$$anonfun$apply$1$$anonfun$apply$4$$anonfun$apply$5.apply(Action.scala:105)
      8. play.utils.Threads$.withContextClassLoader(Threads.scala:21)
      9. play.api.mvc.Action$$anonfun$apply$1$$anonfun$apply$4.apply(Action.scala:104)
      10. play.api.mvc.Action$$anonfun$apply$1$$anonfun$apply$4.apply(Action.scala:103)
      10 frames
    30. Scala
      Option.map
      1. scala.Option.map(Option.scala:146)
      1 frame
    31. Play
      Action$$anonfun$apply$1.apply
      1. play.api.mvc.Action$$anonfun$apply$1.apply(Action.scala:103)
      2. play.api.mvc.Action$$anonfun$apply$1.apply(Action.scala:96)
      2 frames
    32. Play Iteratees
      Iteratee$$anonfun$flatMap$1$$anonfun$apply$14.apply
      1. play.api.libs.iteratee.Iteratee$$anonfun$mapM$1.apply(Iteratee.scala:524)
      2. play.api.libs.iteratee.Iteratee$$anonfun$mapM$1.apply(Iteratee.scala:524)
      3. play.api.libs.iteratee.Iteratee$$anonfun$flatMapM$1.apply(Iteratee.scala:560)
      4. play.api.libs.iteratee.Iteratee$$anonfun$flatMapM$1.apply(Iteratee.scala:560)
      5. play.api.libs.iteratee.Iteratee$$anonfun$flatMap$1$$anonfun$apply$14.apply(Iteratee.scala:537)
      6. play.api.libs.iteratee.Iteratee$$anonfun$flatMap$1$$anonfun$apply$14.apply(Iteratee.scala:537)
      6 frames
    33. Scala
      Future$PromiseCompletingRunnable.run
      1. scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
      2. scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
      2 frames
    34. Akka Actor
      ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec
      1. akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39)
      2. akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:399)
      2 frames
    35. Scala
      ForkJoinPool.runWorker
      1. scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
      2. scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
      3. scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
      3 frames