En utilisant le wrapper jzmq:
scala> import org.zeromq.ZMQ import 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
Cela semble être déçu dans la version 3:
Tout le monde sait pourquoi? et quelle est l'alternative pour définir un HWM utilisant jzqm + zmq3?
Réponses:
5 pour la réponse № 1Jettes un coup d'oeil à: http://zeromq.org/docs:3-1-upgrade
En zeromq 3.2 HWM a été divisé en envoi et réception de la marque des hautes eaux: ZMQ_SNDHWM
et ZMQ_RCVHWM
.
Les fonctions que vous recherchez dans jzmq sont les suivantes:
long getRcvHWM()
long getSndHWM()
void setRcvHWM(long rcvHWM)
void setSndHWM(long sndHWM)
2 pour la réponse № 2
La liaison CZMQ simule l'ancienne option HWM, et d'autres liaisons peuvent en faire de même.