Verwenden des JZMQ-Wrappers:
scala> import org.zeromq.ZMQ Importieren Sie org.zeromq.ZMQ
scala> val context = ZMQ.context(1)
context: org.zeromq.ZMQ.Context = org.zeromq.ZMQ$Context@56d58984
scala> val socket = context.socket(ZMQ.REP)
socket: org.zeromq.ZMQ.Socket = org.zeromq.ZMQ$Socket@2a5a0f9
scala> socket.getHWM()
res6: Long = -1
scala> socket.setHWM(200)
scala> socket.getHWM()
res8: Long = -1
Dies scheint in der Version 3 zu propagieren:
Wer weiß warum? und was ist die Alternative, ein HWM mit jzqm + zmq3 zu setzen?
Antworten:
5 für die Antwort № 1Schau dir an: http://zeromq.org/docs:3-1-upgrade
In zeromq 3.2 wurde HWM in Sende- und Empfangs-Hochwasserzeichen aufgeteilt: ZMQ_SNDHWM
und ZMQ_RCVHWM
.
Die Funktionen, die Sie in jzmq suchen, sind:
long getRcvHWM()
long getSndHWM()
void setRcvHWM(long rcvHWM)
void setSndHWM(long sndHWM)
2 für die Antwort № 2
Die CZMQ-Bindung simuliert die alte HWM-Option und andere Bindungen können das gleiche tun.