[zeromq-dev] Pattern for two clients and one server
Hello everyone! I am new to zmq and I would like to use it in my implementation for IPC. I have two processes that must send commands to another process. This one performs the actual work for the commands. The commands may occur at any time and I cannot use a continuous loop to send them. How should I pair the request/reply calls? The architecture looks like in the attachment. I was thinking of designing the two *client *processes using REQ sockets and the *server *process using ROUTER socket. I need the communication to be asynchronous, without doing busy waiting. Also, each request must be followed by a response, either an acknowledgement or a data message. What are your impressions on this? I do not want to start from scratch with a bad design. I went through the ZMQ guide but still I am not pretty sure whether this is the right approach. Thank you, Adrianne ___ zeromq-dev mailing list zeromq-dev@lists.zeromq.org https://lists.zeromq.org/mailman/listinfo/zeromq-dev
Re: [zeromq-dev] Moving list to Google groups?
Jim Idlewrites: I'm a nay on Google Groups. As seen with SourceForge, sometimes the priorities of companies change. This is especially true for a publically traded company. The price points of https://www.mailmanhost.com/pricing/ seem better than http://www.mailmanlists.net/ but I have no personal experience with either. > You just add your email address to the google list - you don't > actually need a Google account. Thre is really no difference to now. In my experience list maintainers end up needing to enable the Google Account requirement on their groups to combat spam. ___ zeromq-dev mailing list zeromq-dev@lists.zeromq.org http://lists.zeromq.org/mailman/listinfo/zeromq-dev
Re: [zeromq-dev] some correction on java samples
Le 11/03/2011 20:57, chuntz a écrit : hello, i push some corrections about the java sample, and i implement some not already written sample; I hope that will be usefull for you, regards, Christophe Huntzinger ___ zeromq-dev mailing list zeromq-dev@lists.zeromq.org http://lists.zeromq.org/mailman/listinfo/zeromq-dev Hello, I have no answer to mail first e-mail, so may I make some mistakes on the way of working with ZMQ dev team. If it is, can you explain me what I makes wrong. I apologize whatever. The patch pushed is for sure under license LGPL and contains some new implementations of the java samples: / examples/Java/msgqueue.java examples/Java/mtserver.java examples/Java/rrbroker.java examples/Java/rrclient.java examples/Java/rrserver.java examples/Java/syncpub.java examples/Java/syncsub.java examples/Java/wuproxy.java/ and a correction of /MultiThreadedHelloWorldServer /sample. I focus on the fact that a lot of java samples classes names doesn't follow the java naming rules, and may they shall be renamed: /msgqueue.java//- /at least///MsgQueue.java/ and the class it contains shall be named as well. Regards, Christophe Huntzinger From d2e7113f37a6ce57b44c6c6b31bebc51f9324dd2 Mon Sep 17 00:00:00 2001 From: unknown chuntzin@.(none) Date: Fri, 11 Mar 2011 20:42:11 +0100 Subject: [PATCH] Signed-off-by: C. Huntzinger chu...@laposte.net Correction of some issue in MultiThreadedHelloWorldServer. New implementation of missing ZMQ java samples. --- examples/Java/msgqueue.java | 42 ++-- examples/Java/mtserver.java | 51 - examples/Java/rrbroker.java | 75 +-- examples/Java/rrclient.java | 40 +-- examples/Java/rrserver.java | 50 +++-- examples/Java/syncpub.java | 66 -- examples/Java/syncsub.java | 53 -- examples/Java/wuproxy.java | 56 ++-- 8 files changed, 312 insertions(+), 121 deletions(-) delete mode 100644 examples/Java/mtserver.java diff --git a/examples/Java/msgqueue.java b/examples/Java/msgqueue.java index 16bdba5..4535491 100644 --- a/examples/Java/msgqueue.java +++ b/examples/Java/msgqueue.java @@ -1,13 +1,35 @@ -No-one has translated the msgqueue example into Java yet. Be the first to create -msgqueue in Java and get one free Internet! If you're the author of the Java -binding, this is a great way to get people to use 0MQ in Java. +import org.zeromq.ZMQ; +import org.zeromq.ZMQ.Context; +import org.zeromq.ZMQ.Socket; +import org.zeromq.ZMQQueue; -To submit a new translation email it to zeromq-dev@lists.zeromq.org. Please: +/** + * Simple message queuing broker + * Same as request-reply broker but using QUEUE device. + * + * Christophe Huntzinger chu...@laposte.net + */ +public class MsgQueue{ -* Stick to identical functionality and naming used in examples so that readers - can easily compare languages. -* You MUST place your name as author in the examples so readers can contact you. -* You MUST state in the email that you license your code under the MIT/X11 - license. + public static void main (String[] args) { + // Prepare our context and sockets + Context context = ZMQ.context(1); -Subscribe to this list at http://lists.zeromq.org/mailman/listinfo/zeromq-dev. + // Socket facing clients + Socket frontend = context.socket(ZMQ.XREP); + frontend.bind(tcp://*:5559); + + // Socket facing services + Socket backend = context.socket(ZMQ.XREQ); + backend.bind(tcp://*:5560); + + // Start built-in device + ZMQQueue queue = new ZMQQueue(context, frontend, backend); + // have fun! + + // We never get here but clean up anyhow + frontend.close(); + backend.close(); + context.term(); + } +} diff --git a/examples/Java/mtserver.java b/examples/Java/mtserver.java deleted file mode 100644 index 206160f..000 --- a/examples/Java/mtserver.java +++ /dev/null @@ -1,51 +0,0 @@ -/* -Multithreaded Hello World server in Java - -Naveen Chawla naveen.c...@gmail.com -*/ -import org.zeromq.ZMQ; - -public class MultiThreadedHelloWorldServer { -public static void main(String[] args) { -// Prepare our context and sockets -final ZMQ.Context context = ZMQ.context(1); -ZMQ.Socket clients = context.socket(ZMQ.XREP); -clients.bind (tcp://*:); -ZMQ.Socket workers = context.socket(ZMQ.XREQ); -workers.bind (inproc://workers); - -// Launch pool of worker threads -for (int thread_nbr = 0; thread_nbr != 5; thread_nbr++) { -Thread worker_routine = new Thread
Re: [zeromq-dev] JZMQ: Problems building on win32 (MS Visual Studio)
Le 15/03/2011 21:00, Michael Compton a écrit : Hi, I am having problems building jzmq on Win32. I built libzmq to output a lib file (libzmq.lib), but when I try building jmzq I get around 20 errors of unresolved external symbols for what seems like all the functions in libzmq. Any suggestions? Cheers, Michael ___ zeromq-dev mailing list zeromq-dev@lists.zeromq.org http://lists.zeromq.org/mailman/listinfo/zeromq-dev Hi, I use MS visual Xpress 2008 to do the same stuff without any issue, 2 weeks ago. May it comes from your MSV version, Christophe ___ zeromq-dev mailing list zeromq-dev@lists.zeromq.org http://lists.zeromq.org/mailman/listinfo/zeromq-dev
[zeromq-dev] Python / Java interoperability
Is there an example showing Java / Python interoperability using tcp ? -- This message w/attachments (message) is intended solely for the use of the intended recipient(s) and may contain information that is privileged, confidential or proprietary. If you are not an intended recipient, please notify the sender, and then please delete and destroy all copies and attachments, and be advised that any review or dissemination of, or the taking of any action in reliance on, the information contained in or attached to this message is prohibited. Unless specifically indicated, this message is not an offer to sell or a solicitation of any investment products or other financial product or service, an official confirmation of any transaction, or an official statement of Sender. Subject to applicable law, Sender may intercept, monitor, review and retain e-communications (EC) traveling through its networks/systems and may produce any such EC to regulators, law enforcement, in litigation and as required by law. The laws of the country of each sender/recipient may impact the handling of EC, and EC may be archived, supervised and produced in countries other than the country in which you are located. This message cannot be guaranteed to be secure or free of errors or viruses. References to Sender are references to any subsidiary of Bank of America Corporation. Securities and Insurance Products: * Are Not FDIC Insured * Are Not Bank Guaranteed * May Lose Value * Are Not a Bank Deposit * Are Not a Condition to Any Banking Service or Activity * Are Not Insured by Any Federal Government Agency. Attachments that are part of this EC may have additional important disclosures and disclaimers, which you should read. This message is subject to terms available at the following link: http://www.bankofamerica.com/emaildisclaimer. By messaging with Sender you consent to the foregoing. ___ zeromq-dev mailing list zeromq-dev@lists.zeromq.org http://lists.zeromq.org/mailman/listinfo/zeromq-dev