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

Commit 518cb38

Browse files
committed
Merge pull request #18 from trevorbernard/master
Fix issue #17
2 parents eea9667 + 92c9aff commit 518cb38

File tree

2 files changed

+13
-1
lines changed

2 files changed

+13
-1
lines changed

.gitignore

+1
Original file line numberDiff line numberDiff line change
@@ -10,3 +10,4 @@ pom.xml.asc
1010
.lein-failures
1111
.lein-plugins
1212
.lein-repl-history
13+
.nrepl-port

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)