I see, does it matter which one I chose? On Wed, Sep 24, 2014 at 12:35 PM, Trevor Bernard <trevor.bern...@gmail.com> wrote:
> You shouldn't include both as a dependency -- the results would not be > deterministic. I would choose either jeromq or jzmq. > > On Wed, Sep 24, 2014 at 4:32 PM, Mohit Anchlia <mohitanch...@gmail.com> > wrote: > > This is my java dependency: > > > > <!-- JeroMQ Pure Java implementation of libzmq > > (https://github.com/zeromq/jeromq) --> > > > > <dependency> > > > > <groupId>org.zeromq</groupId> > > > > <artifactId>jeromq</artifactId> > > > > <version>0.3.4</version> > > > > <!-- More recent <version>0.3.4</version> --> > > > > </dependency> > > > > <!-- Java binding for 0MQ (http://www.zeromq.org) --> > > > > <dependency> > > > > <groupId>org.zeromq</groupId> > > > > <artifactId>jzmq</artifactId> > > > > <version>3.1.0</version> > > > > <!-- More recent <version>3.0.1</version> --> > > > > </dependency> > > > > > > On Wed, Sep 24, 2014 at 12:12 PM, Pieter Hintjens <p...@imatix.com> wrote: > >> > >> What version of ZeroMQ are you using? > >> > >> On Wed, Sep 24, 2014 at 8:17 PM, Mohit Anchlia <mohitanch...@gmail.com> > >> wrote: > >> > When I change from inproc:// to tcp:// everything seem to work. Not > sure > >> > why > >> > it's not working, perhaps order in which things are started? I am > >> > starting > >> > in this order: > >> > > >> > 1) Bring up router/dealer -> This also connects router to dealer > through > >> > ZMQQueue. Router is tcp and dealer is inproc > >> > 2) Bring up workter and connect to inproc > >> > > >> > When I change everything to tcp:// it works with exact same code and > >> > sequence of operations > >> > > >> > On Tue, Sep 23, 2014 at 11:16 AM, Mohit Anchlia < > mohitanch...@gmail.com> > >> > wrote: > >> >> > >> >> I am trying to use router/dealer with dealer using inproc://, when I > >> >> run > >> >> my program the router seems to bind to the port (netstat), client > seem > >> >> to > >> >> connect successfully but the recv after send hangs. Worker on the > other > >> >> hand > >> >> doesn't see the request come in from router/dealer. Here is the > snippet > >> >> of > >> >> my code, not sure what is wrong here: > >> >> > >> >> Router/Dealer: > >> >> > >> >> log.info("Starting ZeroMQ Router on port=" + port); > >> >> // Prepare our context and socket > >> >> ZMQ.Context context = ZMQ.context(1); > >> >> // Socket to talk to clients > >> >> ZMQ.Socket clients = context.socket(ZMQ.ROUTER); > >> >> clients.bind("tcp://*:" + port); > >> >> > >> >> // Socket to talk to workers > >> >> ZMQ.Socket workers = context.socket(ZMQ.DEALER); > >> >> workers.bind("inproc://workers"); > >> >> > >> >> // Connect work threads to client threads via a queue > >> >> ZMQQueue queue = new ZMQQueue(context, clients, workers); > >> >> new Thread(queue).start(); > >> >> > >> >> log.info("Exiting ZeroMQ"); > >> >> > >> >> Worker: > >> >> > >> >> public JMSZMQRepServer() { > >> >> this.context = ZMQ.context(1); > >> >> socket = context.socket(ZMQ.REP); > >> >> socket.connect("inproc://workers"); > >> >> > >> >> log.info("Server bind inproc"); > >> >> } > >> >> > >> >> @Override > >> >> public void run() { > >> >> while (true) { > >> >> // Wait for next request from client (C string) > >> >> try { > >> >> log.info("Start"); > >> >> String request = socket.recvStr(0); > >> >> // String request = new String(GZIPUtils.gunzip(socket.recv())); > >> >> // Do some 'work' > >> >> String response = null; > >> >> response = doWork(request); > >> >> // Send reply back to client (C string) > >> >> socket.send(response, 0); > >> >> } catch (ZMQException e) { > >> >> if (e.getErrorCode() == ZMQ.Error.ETERM.getCode()) { > >> >> log.warn("Exiting ", e.getMessage()); > >> >> break; > >> >> } else { > >> >> log.error("Unable to send request", e); > >> >> } > >> >> } catch (Exception e) { > >> >> // TODO Auto-generated catch block > >> >> log.error("Error in gunzip", e); > >> >> } > >> >> } > >> >> if (null != socket) { > >> >> log.info("Socket closed"); > >> >> socket.close(); > >> >> } > >> >> } > >> >> > >> >> Client: > >> >> > >> >> public JMSZMQClient() { > >> >> context = ZMQ.context(1); > >> >> requester = context.socket(ZMQ.REQ); > >> >> requester.connect("inproc://workers"); > >> >> log.info("Connected to in proc workers"); > >> >> } > >> >> public String processRequest(String json) throws DataStoreException > { > >> >> String result = null; > >> >> long latency = System.currentTimeMillis(); > >> >> // byte [] bJson = GZIPUtils.gzip(json.getBytes()); > >> >> log.info("Send request to zMQ server"); > >> >> // requester.send(bJson); > >> >> requester.send(json, 0); > >> >> result = requester.recvStr(0); > >> >> log.info("ZeroMQ client took=" > >> >> + (System.currentTimeMillis() - latency)); > >> >> MessageUtil.validateZMQMessage(result); > >> >> return result; > >> >> } > >> >> > >> >> > >> >> > >> > > >> > > >> > _______________________________________________ > >> > zeromq-dev mailing list > >> > zeromq-dev@lists.zeromq.org > >> > http://lists.zeromq.org/mailman/listinfo/zeromq-dev > >> > > >> _______________________________________________ > >> zeromq-dev mailing list > >> zeromq-dev@lists.zeromq.org > >> http://lists.zeromq.org/mailman/listinfo/zeromq-dev > > > > > > > > _______________________________________________ > > zeromq-dev mailing list > > zeromq-dev@lists.zeromq.org > > http://lists.zeromq.org/mailman/listinfo/zeromq-dev > > > _______________________________________________ > zeromq-dev mailing list > zeromq-dev@lists.zeromq.org > http://lists.zeromq.org/mailman/listinfo/zeromq-dev >
_______________________________________________ zeromq-dev mailing list zeromq-dev@lists.zeromq.org http://lists.zeromq.org/mailman/listinfo/zeromq-dev
