From fa6bf24d8030b0e54fd25b167064482e4cf08a36 Mon Sep 17 00:00:00 2001
From: Martin Sustrik <sustrik@fastmq.commkdir>
Date: Sun, 13 Dec 2009 14:45:23 +0100
Subject: XREP & XREQ socket types added; zmq_queue device added
---
bindings/c/zmq.h | 6 ++++--
bindings/cl/zeromq.lisp | 6 ++++--
bindings/java/org/zmq/Socket.java | 6 ++++--
bindings/python/pyzmq.cpp | 6 ++++++
bindings/ruby/rbzmq.cpp | 2 ++
5 files changed, 20 insertions(+), 6 deletions(-)
(limited to 'bindings')
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));
--
cgit v1.2.3