[zeromq-dev] Using zmq_proxy with ZMQ_STREAM socket

[Pieter Hintjens]

You can use a stream socket to talk to the clients, yes, though you
must manage the clients yourself, mapping incoming SUB traffic to
whatever TCP protocol the clients speak, and sending each message to
all clients.

On Mon, Apr 6, 2015 at 12:20 PM, Kil Tuy <kiltuy1 at gmail.com> wrote:
> I am trying to replace existing adhoc pub/sub mechanism with zeromq.
> Unfortunately clients are not in my control so I cannot plugin SUB sockets.
> I thought I could bridge the gap using STREAM socket.
>
> 2015-04-06 12:56 GMT+03:00 Pieter Hintjens <ph at imatix.com>:
>>
>> This won't work, no. The STREAM socket will accept many client
>> connections. You have to manage these in some way. There's not even a
>> sane meaning to bridging a SUB socket to a STREAM socket afaict, it's
>> like connecting a radio loudspeaker to a garden hose. What are you
>> actually trying to do?
>>
>> -Pieter
>>
>> On Mon, Apr 6, 2015 at 10:29 AM, Kil Tuy <kiltuy1 at gmail.com> wrote:
>> > Hi,
>> > Is it possible to use ZMQ_STREAM with proxy? The idea is to have proxy a
>> > SUB
>> > socket with a STREAM one. Following is what's working for me currently
>> > but I
>> > am looking forward to replace it with proxy. Sorry that the code is
>> > written
>> > using CLR binding.
>> >
>> >                 // Create subscriber
>> >                 ZSocket sub = new ZSocket(ctx, ZSocketType.SUB);
>> >                 sub.Connect("tcp://127.0.0.1:5564");
>> >                 sub.SubscribeAll();
>> >
>> >                 // Create streamer
>> >                 ZSocket stream = new ZSocket(ctx, ZSocketType.STREAM);
>> >                 stream.Bind("tcp://127.0.0.1:5565");
>> >
>> >                 // Read client connect message
>> >                 ZMessage msg = stream.ReceiveMessage();
>> >
>> >                 while (true)
>> >                 {
>> >                     // Forward message with a replaced id frame
>> >                     ZMessage zm = sub.ReceiveMessage();
>> >                     zm.ReplaceAt(0, msg[0]);
>> >                     stream.Send(zm);
>> >                 }
>> >
>> >                 /*ZContext.Proxy(stream, sub);*/
>> >
>> >    I tried using proxy method but it didn't work. Possible to replace
>> > the
>> > above code with proxy?
>> >
>> >
>> > _______________________________________________
>> > zeromq-dev mailing list
>> > zeromq-dev at lists.zeromq.org
>> > http://lists.zeromq.org/mailman/listinfo/zeromq-dev
>> >
>> _______________________________________________
>> zeromq-dev mailing list
>> zeromq-dev at lists.zeromq.org
>> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
>
>
>
> _______________________________________________
> zeromq-dev mailing list
> zeromq-dev at lists.zeromq.org
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
>