mitallast / scala-nsq Goto Github PK

  val client = NSQClient()

  val producer = client.producer()

  val listener: Try[OK] => Unit = {
    case Success(_: OK) => log.info("message pub successfully")
    case Failure(error) => log.info("message pub failed", error)
  }

  // publish one message
  producer.pub(topic="test", data=Array[Byte](1,0,1,1)).onComplete(listener)
  producer.pubStr(topic="test", data="hello").onComplete(listener)

  // By default: http://127.0.0.1:4161
  val consumer: NSQConsumer = client.consumer(topic="test", channel="default") { msg =>
    log.info("received: {}", msg)
    // send `TOUCH msgid` message request
    msg.touch()
    // send `REQ msdid 100` message request
//    msg.req(100 milliseconds)
    // send `FIN msgid` message request
    msg.fin()
  }

nsq {
  lookup-address = [
    "http://127.0.0.1:xxxx"
  ]
}

[error] (run-main-1e) java.lang.IllegalArgumentException: bound must be positive
java.lang.IllegalArgumentException: bound must be positive
	at java.util.Random.nextInt(Random.java:388)
	at scala.util.Random.nextInt(Random.scala:66)
	at com.github.mitallast.nsq.NSQNettyClient$NSQNettyPool$class.connection(NSQNettyClient.scala:532)
	at com.github.mitallast.nsq.NSQNettyClient$NSQNettyProducer.connection(NSQNettyClient.scala:650)
	at com.github.mitallast.nsq.NSQNettyClient$NSQNettyProducer.pub(NSQNettyClient.scala:664)
	at com.github.mitallast.nsq.NSQProducer$class.pubStr(NSQClient.scala:55)
	at com.github.mitallast.nsq.NSQNettyClient$NSQNettyProducer.pubStr(NSQNettyClient.scala:650)
	at com.company.Main$.main(Main.scala:27)
	at com.company.Main.main(Main.scala)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)

private val poolMap = new AbstractChannelPoolMap[SocketAddress, FixedChannelPool]