raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

do not reuse same port in same ømq test, fixes #2022

Browse source
This commit is contained in:
Roland 2012-04-27 17:07:50 +02:00
parent 27a0e533f8
commit 1cfa267b80
1 changed files with 8 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

13
akka-docs/scala/code/akka/docs/zeromq/ZeromqDocSpec.scala
View file

@ -118,12 +118,12 @@ class ZeromqDocSpec extends AkkaSpec("akka.loglevel=INFO") {
//#pub-socket //#pub-socket
import akka.zeromq.ZeroMQExtension import akka.zeromq.ZeroMQExtension
val pubSocket = ZeroMQExtension(system).newSocket(SocketType.Pub, Bind("tcp://127.0.0.1:1234")) val pubSocket = ZeroMQExtension(system).newSocket(SocketType.Pub, Bind("tcp://127.0.0.1:21231"))
//#pub-socket //#pub-socket
//#pub-socket2 //#pub-socket2
import akka.zeromq._ import akka.zeromq._
val pubSocket2 = system.newSocket(SocketType.Pub, Bind("tcp://127.0.0.1:1234")) val pubSocket2 = system.newSocket(SocketType.Pub, Bind("tcp://127.0.0.1:21232"))
//#pub-socket2 //#pub-socket2
//#sub-socket //#sub-socket
@ -135,11 +135,11 @@ class ZeromqDocSpec extends AkkaSpec("akka.loglevel=INFO") {
case _ ⇒ //... case _ ⇒ //...
} }
})) }))
val subSocket = system.newSocket(SocketType.Sub, Listener(listener), Connect("tcp://127.0.0.1:1234"), SubscribeAll) val subSocket = system.newSocket(SocketType.Sub, Listener(listener), Connect("tcp://127.0.0.1:21231"), SubscribeAll)
//#sub-socket //#sub-socket
//#sub-topic-socket //#sub-topic-socket
val subTopicSocket = system.newSocket(SocketType.Sub, Listener(listener), Connect("tcp://127.0.0.1:1234"), Subscribe("foo.bar")) val subTopicSocket = system.newSocket(SocketType.Sub, Listener(listener), Connect("tcp://127.0.0.1:21231"), Subscribe("foo.bar"))
//#sub-topic-socket //#sub-topic-socket
//#unsub-topic-socket //#unsub-topic-socket
@ -151,11 +151,14 @@ class ZeromqDocSpec extends AkkaSpec("akka.loglevel=INFO") {
pubSocket ! ZMQMessage(Seq(Frame("foo.bar"), Frame(payload))) pubSocket ! ZMQMessage(Seq(Frame("foo.bar"), Frame(payload)))
//#pub-topic //#pub-topic
system.stop(subSocket)
system.stop(subTopicSocket)
//#high-watermark //#high-watermark
val highWatermarkSocket = system.newSocket( val highWatermarkSocket = system.newSocket(
SocketType.Router, SocketType.Router,
Listener(listener), Listener(listener),
Bind("tcp://127.0.0.1:1234"), Bind("tcp://127.0.0.1:21233"),
HighWatermark(50000)) HighWatermark(50000))
//#high-watermark //#high-watermark
} }