Skip to content
This repository was archived by the owner on Feb 14, 2024. It is now read-only.

Commit 92c9aff

Browse files
author
Trevor Bernard
committed
Fix issue #17 - Add send and receive buffer size functions
1 parent 5d17fb8 commit 92c9aff

File tree

1 file changed

+12
-1
lines changed

1 file changed

+12
-1
lines changed

src/zeromq/zmq.clj

+12-1
Original file line numberDiff line numberDiff line change
@@ -247,7 +247,18 @@
247247
all other values, it will wait for a message for that amount of time before
248248
returning with an EAGAIN error."
249249
[^ZMQ$Socket socket timeout]
250-
(.setReceiveTimeOut socket timeout))
250+
(.setReceiveTimeOut socket timeout)
251+
socket)
252+
253+
(defn ^ZMQ$Socket set-receive-buffer
254+
[^ZMQ$Socket socket size]
255+
(.setReceiveBufferSize socket size)
256+
socket)
257+
258+
(defn ^ZMQ$Socket set-send-buffer
259+
[^ZMQ$Socket socket size]
260+
(.setSendBufferSize socket size)
261+
socket)
251262

252263
(defmulti subscribe
253264
"The subscribe option shall establish a new message filter on a SUB

0 commit comments

Comments
 (0)