mirrors/bitcoin-s
1
0
Fork 0
mirror of https://github.com/bitcoin-s/bitcoin-s.git synced 2025-01-19 05:43:51 +01:00
Code Issues Packages Projects Releases Wiki Activity

Make it compile

Browse Source
This commit is contained in:
Noah Cornwell 2018-04-30 15:47:42 -04:00 committed by Chris Stewart
parent 294ed10361
commit 4665f0543e
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
zmq/src/main/scala/org/bitcoins/zmq/ZMQSubscriber.scala
View File

@ -30,13 +30,13 @@ class ZMQSubscriber(
rawBlockListener: Option[Seq[Byte] => Unit]) {
private val logger = BitcoinSLogger.logger
private var run = true
private var running = true
private val context = ZMQ.context(1)
private val subscriber = context.socket(ZMQ.SUB)
private val uri = socket.getHostString + ":" + socket.getPort
private case object SubscriberRunnable = new Runnable {
private case object SubscriberRunnable extends Runnable {
override def run(): Unit = {
val connected = subscriber.connect(uri)
@ -61,8 +61,8 @@ class ZMQSubscriber(
logger.debug("subscribed to raw block stream from zmq")
}
while (run) {
val zmsg = ZMsg.recvMsg(subscriber, , ZMQ.NOBLOCK)
while (running) {
val zmsg = ZMsg.recvMsg(subscriber, ZMQ.NOBLOCK)
if (zmsg != null) {
val notificationTypeStr = zmsg.pop().getString(ZMQ.CHARSET)
val body = zmsg.pop().getData
@ -91,7 +91,7 @@ class ZMQSubscriber(
//i think this could technically not work, because currently we are blocking
//on Zmsg.recvMsg in our while loop. If we don't get another message we won't
//be able toe evaluate the while loop again. Moving forward with this for now.
run = false
running = false
subscriber.close()
context.term()
}