Re: [zeromq-dev] Forwarding ROUTER to PUB

I think this may be achieved by the following arch: 1. Establish 2 ROUTER sockets, router #1 is responsible for receiving incoming requests, and router #2 is connected to router #1; 2. Establish a DEALER socket per thread, and connect to router #2. And upon connected, tell router #2 its inter

Re: [zeromq-dev] Native error

On 2013?11?05? 21:01, Manuel Irribarra wrote: Hi everyone, I wrote a simple web application: Context context = ZMQ.context(workers); Socket backend = context.socket(ZMQ.DEALER); backend.bind(Constants.SOCKET); Worker worker = null; for (int i = 0; i < workers; i++) { worker = new Worker

Re: [zeromq-dev] How to send/receive a custom C++ object via zeromq sockets?

I strongly recommend Google's Protocol Buffer as the serialization/deserialization tool. It's fast, convenient and robust. It directly transform an object to the bytes formation(and vice-versa), so can be send/recv through zeromq sockets. We are using it in our online game, and it works well so

Re: [zeromq-dev] ZeroMQ 3.2.3 and jeromq 0.30 SNAPSHOT

It's ok that server using Jeromq and client using 0mq(c++). In fact, that's how our app communicates with the server. 2013/9/11 St. Aubin, Albert (US SSA) > Is jeroMQ compatible with ZeroMQ 3.2.3? I am attempting to create a > server that is a subscriber with publishers that connect to it. I

Re: [zeromq-dev] What am I doing wrong?

REQ socket is implemented like an FSM, it transforms between "send" and "recv"(basicly). Thus the IllegalStateException occurred if you tried to use "send" twice. It's not use to only "invalidate" and "return" the socket(since you have set the socket's state). You can resent the data through it onl

Re: [zeromq-dev] Questions about erlzmq

IF-resources-tt3171272.html#none > > > On Wed, Sep 4, 2013 at 4:36 AM, Michael Scofield wrote: > >> OH...I should have definitely checked the syntax. >> But, why is >> {ok, Context} = erlzmq:context(). >> the Context is empty? Shouldn't it be some zeromq c

Re: [zeromq-dev] Questions about erlzmq

> > On Wed, Sep 4, 2013 at 8:37 AM, Michael Scofield > wrote: > > Hi: > > I've just install the erlzmq2 on my laptop(Ubuntu 12.04 32bit). > > I decided to try it. So I opened the erl shell, and tried this: > > {ok, Context} = erlzmq:context(). > > It return

[zeromq-dev] Questions about erlzmq

Hi: I've just install the erlzmq2 on my laptop(Ubuntu 12.04 32bit). I decided to try it. So I opened the erl shell, and tried this: {ok, Context} = erlzmq:context(). It returned {ok,<<>>} Something was not right here: the Context were just empty bits! Then I cont

Re: [zeromq-dev] Publisher side filter question

filtering happens at the publisher side means when SUB1.subscribe("C") and SUB2.subscribe("D"), the publisher won't send "D" to SUB1, nor "C" to SUB2 2013/8/22 Roy Liu > Hi, Luke > > In ZMQ 3.x, if publisher filter the message first and sent the filtered > message to the subscriber or not? > i

[zeromq-dev] Does anyone ever success compiled erlang binding zeromq in Windows?

I'm trying to use erlzmq2 . The OS is Windows 7 64 bit, and I have already installed MinGW. ___ zeromq-dev mailing list zeromq-dev@lists.zeromq.org http://lists.zeromq.org/mailman/listinfo/zeromq-dev

[zeromq-dev] How will a crashing subscriber affected the publisher?

How will a crashing subscriber affected the publisher? The two are connected between tcp. The subscriber do nothing but simple straightforward connect, subscribe, receive and unsubscribe, and might be crashed unexpected due to other reason(has nothing to do with the subscriber). ___

Re: [zeromq-dev] How to do a load/stress test on a router socket?

y wrapped as an API > you can build test clients more easily. > > For any larger scale testing you will want multiple machines. > > -Pieter > > > > On Wed, Jun 19, 2013 at 5:44 AM, Michael Scofield > wrote: > > Say I have a router socket on a server. The ser

[zeromq-dev] How to do a load/stress test on a router socket?

Say I have a router socket on a server. The server can reply to its clients through the router socket. Each client is using a dealer socket to connect to the server.(Yes, this is an online-game architecture.) Now I want to do a load/stress test on this server. So I created lots of client in