Switch to DuckDuckGo Search
   January 9, 2019
< | 1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9 | 10 | 11 | 12 | 13 | 14 | 15 | 16 | 17 | 18 | 19 | 20 | 21 | 22 | 23 | 24 | 25 | 26 | 27 | 28 | 29 | 30 | 31

Toggle Join/Part | bottom
[00:09:18] *** dbmikus_ <dbmikus_!~dbmikus@rrcs-50-74-152-162.nyc.biz.rr.com> has quit IRC (Ping timeout: 268 seconds)
[00:14:59] *** dbmikus_ <dbmikus_!~dbmikus@172.93.11.58> has joined #zeromq
[00:21:27] *** veegee <veegee!~veegee@ipagstaticip-3d3f7614-22f3-5b69-be13-7ab4b2c585d9.sdsl.bell.ca> has joined #zeromq
[00:34:03] *** dbmikus_ <dbmikus_!~dbmikus@172.93.11.58> has quit IRC (Ping timeout: 246 seconds)
[00:35:33] *** dbmikus_ <dbmikus_!~dbmikus@rrcs-50-74-152-162.nyc.biz.rr.com> has joined #zeromq
[00:50:01] *** aleph- <aleph-!~hatter@lobsters/Auditor/Church-> has joined #zeromq
[00:56:34] *** aleph- <aleph-!~hatter@lobsters/Auditor/Church-> has quit IRC (Ping timeout: 250 seconds)
[01:11:28] *** aleph- <aleph-!~hatter@lobsters/Auditor/Church-> has joined #zeromq
[01:16:11] *** dbmikus_ <dbmikus_!~dbmikus@rrcs-50-74-152-162.nyc.biz.rr.com> has quit IRC (Ping timeout: 258 seconds)
[02:23:24] *** dbmikus_ <dbmikus_!~dbmikus@2604:2000:81cb:1000:587a:b01e:f305:15ca> has joined #zeromq
[03:08:12] *** cognifloyd <cognifloyd!~cognifloy@072-191-249-006.res.spectrum.com> has joined #zeromq
[04:07:44] <Flash> ok, no ZPL experts ... different question
[04:08:13] <Flash> If I have a SUB socket and I connect to multiple publishers, is my subscription sent to all of them?
[04:08:31] <Flash> and if so, does order matter (e.g., connect, connect, then setsockopt)
[04:24:47] *** aleph- <aleph-!~hatter@lobsters/Auditor/Church-> has quit IRC (Ping timeout: 258 seconds)
[04:37:50] *** krychu <krychu!~krychu@2a02:1205:505c:2ab0:cdf7:6cdb:981f:1305> has quit IRC (Read error: Connection reset by peer)
[05:22:12] *** dbmikus_ <dbmikus_!~dbmikus@2604:2000:81cb:1000:587a:b01e:f305:15ca> has quit IRC (Ping timeout: 250 seconds)
[07:23:56] <russell--> Flash: based on my just-today experiment, the answer is yes
[07:24:38] * russell-- has multiple publishers pushing data at an individual subscriber, the messages all seem to arrive
[07:25:32] <svm_invictvs> Flash I'm pretty sure that SUB filters on the receiving end
[07:28:35] *** aleph- <aleph-!~hatter@lobsters/Auditor/Church-> has joined #zeromq
[07:31:33] <russell--> svm_invictvs:
[07:31:39] <russell--> "There are some exceptions, e.g., SUB sockets will send subscriptions to PUB sockets, but it's anonymous and infrequent."
[07:31:59] <svm_invictvs> russell-- Oh, I thought that was done through XSUB
[07:37:28] <svm_invictvs> russell-- yeah, I've noticed it takes a little time before you start receiving messages on pub
[07:37:32] <svm_invictvs> er, on sub from pub
[07:37:41] <russell--> "Pub-sub filtering is now done at the publisher side instead of subscriber side. This improves performance significantly in many pub-sub use cases. You can mix v3.2 and v2.1/v2.2 publishers and subscribers safely."
[07:38:08] <svm_invictvs> russell-- They don't ever advertise it has any sort of persistent queuing. If you need actual persistent queuing you're better off doing what I did and wrapping up some push/pull sockets
[07:38:25] <russell--> under "Upgrading from ZeroMQ v2.2 to ZeroMQ v3.2" in http://zguide.zeromq.org/page:all
[07:39:24] <svm_invictvs> russell-- The guide is really dense
[07:39:59] <svm_invictvs> russell-- And I love ZMQ and I love that they put a lot of thought into it, but the guide kind of irks me from time to time.
[07:40:08] * russell-- is a total zeromq newbie, but remembered that i'd read that
[07:52:13] <Flash> russell--: thanks for the confirmation. What about order? If I create a socket, connect to pub1, then set the subscription, then connect to pub2, will both publishers be subscribed?
[07:52:25] <Flash> (I would hope so, since it's a SOCKET option)
[08:04:21] <russell--> Flash: i'm binding on the SUB and connecting from the PUB, setting an empty "" subscription filter gets data from each PUB as they connect (though my reading of the guide suggests that missing some initial messages is not unexpected)
[08:06:56] <russell--> my application is sensor end points forwarding data to a centralized log, i have one log (the SUB process) which binds a well known address. I only set the subscription once at the SUB end.
[08:16:36] <svm_invictvs> Flash eg pub1.bind("foo"); sub1.connect("foo") ?
[08:17:27] *** cognifloyd <cognifloyd!~cognifloy@072-191-249-006.res.spectrum.com> has quit IRC (Ping timeout: 246 seconds)
[08:18:16] <svm_invictvs> Flash I believe you are correct in your assumption. Each ZMQ socket is really flexible in that it is designed to connect to multiple destinations.
[08:19:19] <svm_invictvs> Flash in the case of sub, it basically says that it will receive all messages from sockets to which is connected. Internally, it's opening multiple sockets and then doing a bucch of internal message passing and filtering, but the expected behavior is that you can connect them any which way you desire.
[08:20:00] <svm_invictvs> Flash Though practically you usually want to have one backend/frontend and a dispatch thread. Each internal process connects through inproc and then routes through xpub/xsub
[08:23:11] *** jimklimov <jimklimov!~jimklimov@ip-86-49-245-80.net.upcbroadband.cz> has joined #zeromq
[08:24:39] *** jimklimov <jimklimov!~jimklimov@ip-86-49-245-80.net.upcbroadband.cz> has quit IRC (Read error: Connection reset by peer)
[08:26:11] *** jimklimov <jimklimov!~jimklimov@ip-86-49-245-80.net.upcbroadband.cz> has joined #zeromq
[08:42:19] *** guido_g <guido_g!~guido_g@nexus.a-nugget.org> has joined #zeromq
[08:58:18] <Flash> do most people spin threads for sockets? Right now I'm trying to handle everything in a polling loop
[09:27:04] *** FabriceB <FabriceB!~FabriceB@lfbn-1-1047-122.w86-247.abo.wanadoo.fr> has quit IRC (Ping timeout: 264 seconds)
[09:57:25] *** FabriceB <FabriceB!~FabriceB@mhx-outbound.3ds.com> has joined #zeromq
[10:26:43] *** aleph- <aleph-!~hatter@lobsters/Auditor/Church-> has quit IRC (Ping timeout: 246 seconds)
[10:41:11] *** __alex <__alex!~alex@195.49.156.9> has joined #zeromq
[10:55:22] *** drbobbeaty <drbobbeaty!~drbob@2601:249:1000:71d0:9c59:c617:b18:c9a0> has joined #zeromq
[11:02:17] *** bluca <bluca!~bluca@2001:1be0:110d:fcfe:132c:a71a:1896:1395> has joined #zeromq
[11:10:00] *** diorcety <diorcety!~diorcet@109.3.155.170> has joined #zeromq
[11:15:05] *** drbobbeaty <drbobbeaty!~drbob@2601:249:1000:71d0:9c59:c617:b18:c9a0> has quit IRC (Quit: My MacBook Pro has gone to sleep. ZZZzzz…)
[11:26:56] *** bluca <bluca!~bluca@2001:1be0:110d:fcfe:132c:a71a:1896:1395> has quit IRC (Ping timeout: 268 seconds)
[11:39:40] *** bluca <bluca!~bluca@2001:1be0:110d:fcff:f19f:e27c:a323:8ad8> has joined #zeromq
[11:53:37] *** kosm <kosm!~orybalch@unaffiliated/kosm> has joined #zeromq
[12:53:18] *** drbobbeaty <drbobbeaty!~drbob@96.74.128.141> has joined #zeromq
[13:50:54] <bv> I don't know about most people, but I use CZMQ zactors to group sockets that needs to interact on the app side and then either zloop or zpoller to service them when messages are ready for receiving. I then service the actor pipes in a top level loop or poller. I use zpoller if things are simple and I don't want to write separate handlers, otherwise zlooper.
[14:45:45] *** veegee <veegee!~veegee@ipagstaticip-3d3f7614-22f3-5b69-be13-7ab4b2c585d9.sdsl.bell.ca> has quit IRC (Quit: veegee)
[14:49:46] *** veegee <veegee!~veegee@ipagstaticip-3d3f7614-22f3-5b69-be13-7ab4b2c585d9.sdsl.bell.ca> has joined #zeromq
[15:07:42] *** jimklimov <jimklimov!~jimklimov@ip-86-49-245-80.net.upcbroadband.cz> has quit IRC (Ping timeout: 268 seconds)
[16:19:27] *** dskwlkr <dskwlkr!~dskwlkr@c-73-222-239-254.hsd1.ca.comcast.net> has joined #zeromq
[16:44:35] *** guido_g <guido_g!~guido_g@nexus.a-nugget.org> has quit IRC (Quit: Leaving.)
[16:45:27] *** dbmikus_ <dbmikus_!~dbmikus@rrcs-50-74-152-162.nyc.biz.rr.com> has joined #zeromq
[16:47:50] *** bluca <bluca!~bluca@2001:1be0:110d:fcff:f19f:e27c:a323:8ad8> has quit IRC (Quit: Leaving.)
[17:06:09] *** cctp <cctp!c0bc789a@gateway/web/freenode/ip.192.188.120.154> has joined #zeromq
[17:09:28] *** cctp <cctp!c0bc789a@gateway/web/freenode/ip.192.188.120.154> has quit IRC (Client Quit)
[17:21:24] *** jimklimov <jimklimov!~jimklimov@ip-86-49-245-80.net.upcbroadband.cz> has joined #zeromq
[17:23:41] *** ginjah <ginjah!~ginjah@unaffiliated/ginjah> has joined #zeromq
[17:27:45] *** bluca <bluca!~bluca@2a01:4b00:f419:6f00:8361:8946:ba2b:d556> has joined #zeromq
[17:40:30] *** __alex <__alex!~alex@195.49.156.9> has quit IRC (Ping timeout: 252 seconds)
[17:56:47] *** ginjah <ginjah!~ginjah@unaffiliated/ginjah> has quit IRC (Ping timeout: 240 seconds)
[18:33:00] *** cognifloyd <cognifloyd!~cognifloy@rrcs-24-173-49-18.sw.biz.rr.com> has joined #zeromq
[18:37:40] *** diorcety <diorcety!~diorcet@109.3.155.170> has quit IRC (Read error: Connection reset by peer)
[19:13:39] *** justLooking <justLooking!188605a9@gateway/web/freenode/ip.24.134.5.169> has joined #zeromq
[19:13:57] *** justLooking <justLooking!188605a9@gateway/web/freenode/ip.24.134.5.169> has quit IRC (Client Quit)
[19:20:50] *** FabriceB <FabriceB!~FabriceB@mhx-outbound.3ds.com> has quit IRC (Quit: FabriceB)
[19:38:29] *** jimklimov1 <jimklimov1!~jimklimov@ip-86-49-245-80.net.upcbroadband.cz> has joined #zeromq
[19:40:03] *** jimklimov <jimklimov!~jimklimov@ip-86-49-245-80.net.upcbroadband.cz> has quit IRC (Ping timeout: 245 seconds)
[19:42:35] *** krychu <krychu!~krychu@2a02:1205:505c:2ab0:a010:831d:b77c:ad4a> has joined #zeromq
[20:21:36] *** nashpa <nashpa!~nashpa@dliviu.plus.com> has quit IRC (Quit: Going away)
[20:22:16] *** nashpa <nashpa!~nashpa@dliviu.plus.com> has joined #zeromq
[21:44:06] *** ginjah <ginjah!~ginjah@unaffiliated/ginjah> has joined #zeromq
[21:47:06] *** bluca <bluca!~bluca@2a01:4b00:f419:6f00:8361:8946:ba2b:d556> has quit IRC (Quit: Leaving.)
[21:57:32] *** cognifloyd <cognifloyd!~cognifloy@rrcs-24-173-49-18.sw.biz.rr.com> has quit IRC (Quit: Leaving.)
[22:02:35] *** FabriceB <FabriceB!~FabriceB@lfbn-1-1047-122.w86-247.abo.wanadoo.fr> has joined #zeromq
[22:05:38] *** FabriceB_ <FabriceB_!~FabriceB@lfbn-1-1047-122.w86-247.abo.wanadoo.fr> has joined #zeromq
[22:08:07] *** FabriceB <FabriceB!~FabriceB@lfbn-1-1047-122.w86-247.abo.wanadoo.fr> has quit IRC (Ping timeout: 246 seconds)
[22:08:07] *** FabriceB_ is now known as FabriceB
[22:47:26] *** cognifloyd <cognifloyd!~cognifloy@072-191-249-006.res.spectrum.com> has joined #zeromq
[22:49:23] *** krychu <krychu!~krychu@2a02:1205:505c:2ab0:a010:831d:b77c:ad4a> has quit IRC (Quit: krychu)
[23:02:26] *** drbobbeaty <drbobbeaty!~drbob@96.74.128.141> has quit IRC (Quit: My MacBook Pro has gone to sleep. ZZZzzz…)
[23:48:35] *** aleph- <aleph-!~hatter@lobsters/Auditor/Church-> has joined #zeromq
top

   January 9, 2019
< | 1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9 | 10 | 11 | 12 | 13 | 14 | 15 | 16 | 17 | 18 | 19 | 20 | 21 | 22 | 23 | 24 | 25 | 26 | 27 | 28 | 29 | 30 | 31