diff options
| author | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-13 14:45:23 +0100 |
|---|---|---|
| committer | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-13 14:45:23 +0100 |
| commit | fa6bf24d8030b0e54fd25b167064482e4cf08a36 (patch) | |
| tree | 9f8f833da9607c9ba3376b45aa5cfafa4305e59c /bindings | |
| parent | c43aded531014895973c283fdd82bb2e5e85c789 (diff) | |
XREP & XREQ socket types added; zmq_queue device added
Diffstat (limited to 'bindings')
| -rw-r--r-- | bindings/c/zmq.h | 6 | ||||
| -rw-r--r-- | bindings/cl/zeromq.lisp | 6 | ||||
| -rw-r--r-- | bindings/java/org/zmq/Socket.java | 6 | ||||
| -rw-r--r-- | bindings/python/pyzmq.cpp | 6 | ||||
| -rw-r--r-- | bindings/ruby/rbzmq.cpp | 2 |
5 files changed, 20 insertions, 6 deletions
diff --git a/bindings/c/zmq.h b/bindings/c/zmq.h index f0d59b1..37bad52 100644 --- a/bindings/c/zmq.h +++ b/bindings/c/zmq.h @@ -149,8 +149,10 @@ ZMQ_EXPORT int zmq_term (void *context); #define ZMQ_SUB 2 #define ZMQ_REQ 3 #define ZMQ_REP 4 -#define ZMQ_UPSTREAM 5 -#define ZMQ_DOWNSTREAM 6 +#define ZMQ_XREQ 5 +#define ZMQ_XREP 6 +#define ZMQ_UPSTREAM 7 +#define ZMQ_DOWNSTREAM 8 #define ZMQ_HWM 1 #define ZMQ_LWM 2 diff --git a/bindings/cl/zeromq.lisp b/bindings/cl/zeromq.lisp index 03befd5..a8b9c5c 100644 --- a/bindings/cl/zeromq.lisp +++ b/bindings/cl/zeromq.lisp @@ -130,8 +130,10 @@ (defconstant sub 2) (defconstant req 3) (defconstant rep 4) -(defconstant upstream 5) -(defconstant downstream 6) +(defconstant xreq 5) +(defconstant xrep 6) +(defconstant upstream 7) +(defconstant downstream 8) (defcfun* ("zmq_socket" socket) :pointer (context :pointer) diff --git a/bindings/java/org/zmq/Socket.java b/bindings/java/org/zmq/Socket.java index 935fade..075e322 100644 --- a/bindings/java/org/zmq/Socket.java +++ b/bindings/java/org/zmq/Socket.java @@ -34,8 +34,10 @@ public class Socket public static final int SUB = 2; public static final int REQ = 3; public static final int REP = 4; - public static final int UPSTREAM = 4; - public static final int DOWNSTREAM = 4; + public static final int XREQ = 5; + public static final int XREP = 6; + public static final int UPSTREAM = 7; + public static final int DOWNSTREAM = 8; public static final int HWM = 1; public static final int LWM = 2; diff --git a/bindings/python/pyzmq.cpp b/bindings/python/pyzmq.cpp index f171eab..75f872d 100644 --- a/bindings/python/pyzmq.cpp +++ b/bindings/python/pyzmq.cpp @@ -498,6 +498,12 @@ PyMODINIT_FUNC initlibpyzmq () t = PyInt_FromLong (ZMQ_REP); PyDict_SetItemString (dict, "REP", t); Py_DECREF (t); + t = PyInt_FromLong (ZMQ_XREQ); + PyDict_SetItemString (dict, "XREQ", t); + Py_DECREF (t); + t = PyInt_FromLong (ZMQ_XREP); + PyDict_SetItemString (dict, "XREP", t); + Py_DECREF (t); t = PyInt_FromLong (ZMQ_UPSTREAM); PyDict_SetItemString (dict, "UPSTREAM", t); Py_DECREF (t); diff --git a/bindings/ruby/rbzmq.cpp b/bindings/ruby/rbzmq.cpp index 43baeef..10ff55f 100644 --- a/bindings/ruby/rbzmq.cpp +++ b/bindings/ruby/rbzmq.cpp @@ -277,6 +277,8 @@ extern "C" void Init_librbzmq () rb_define_global_const ("PUB", INT2NUM (ZMQ_PUB)); rb_define_global_const ("REQ", INT2NUM (ZMQ_REQ)); rb_define_global_const ("REP", INT2NUM (ZMQ_REP)); + rb_define_global_const ("XREQ", INT2NUM (ZMQ_XREQ)); + rb_define_global_const ("XREP", INT2NUM (ZMQ_XREP)); rb_define_global_const ("UPSTREAM", INT2NUM (ZMQ_UPSTREAM)); rb_define_global_const ("DOWNSTREAM", INT2NUM (ZMQ_DOWNSTREAM)); |