mirrors/eclair
1
0
Fork 0
mirror of https://github.com/ACINQ/eclair.git synced 2025-02-22 22:25:26 +01:00
Code Issues Projects Releases Wiki Activity

Update jeromq dependency (#852)

Browse source 
* jeromq 0.4.0->0.5.0
This commit is contained in:
Pierre-Marie Padiou 2019-02-21 16:02:39 +01:00 • committed by GitHub
parent 34e51c19cc
commit 3db7b176d3
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
eclair-core/pom.xml
View file

@ -175,7 +175,7 @@
<dependency> <dependency>
<groupId>org.zeromq</groupId> <groupId>org.zeromq</groupId>
<artifactId>jeromq</artifactId> <artifactId>jeromq</artifactId>
<version>0.4.0</version> <version>0.5.0</version>
</dependency> </dependency>
<!-- SERIALIZATION --> <!-- SERIALIZATION -->
<dependency> <dependency>

6
eclair-core/src/main/scala/fr/acinq/eclair/blockchain/bitcoind/zmq/ZMQActor.scala
View file

@ -21,7 +21,7 @@ import akka.actor.{Actor, ActorLogging}
import fr.acinq.bitcoin.{Block, Transaction} import fr.acinq.bitcoin.{Block, Transaction}
import fr.acinq.eclair.blockchain.{NewBlock, NewTransaction} import fr.acinq.eclair.blockchain.{NewBlock, NewTransaction}
import org.zeromq.ZMQ.Event import org.zeromq.ZMQ.Event
import org.zeromq.{ZContext, ZMQ, ZMsg} import org.zeromq.{SocketType, ZContext, ZMQ, ZMsg}
import scala.annotation.tailrec import scala.annotation.tailrec
import scala.concurrent.{ExecutionContext, Promise} import scala.concurrent.{ExecutionContext, Promise}
@ -37,13 +37,13 @@ class ZMQActor(address: String, connected: Option[Promise[Done]] = None) extends
val ctx = new ZContext val ctx = new ZContext
val subscriber = ctx.createSocket(ZMQ.SUB) val subscriber = ctx.createSocket(SocketType.SUB)
subscriber.monitor("inproc://events", ZMQ.EVENT_CONNECTED | ZMQ.EVENT_DISCONNECTED) subscriber.monitor("inproc://events", ZMQ.EVENT_CONNECTED | ZMQ.EVENT_DISCONNECTED)
subscriber.connect(address) subscriber.connect(address)
subscriber.subscribe("rawblock".getBytes(ZMQ.CHARSET)) subscriber.subscribe("rawblock".getBytes(ZMQ.CHARSET))
subscriber.subscribe("rawtx".getBytes(ZMQ.CHARSET)) subscriber.subscribe("rawtx".getBytes(ZMQ.CHARSET))
val monitor = ctx.createSocket(ZMQ.PAIR) val monitor = ctx.createSocket(SocketType.PAIR)
monitor.connect("inproc://events") monitor.connect("inproc://events")
implicit val ec: ExecutionContext = context.system.dispatcher implicit val ec: ExecutionContext = context.system.dispatcher