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