Recent Forum Posts
From categories:
page 1123...next »

Number 21, big grey door (it's open), walk into the parking lot and in the opposite corner climb up 4 steps of stairs and you will see a big blue door, a cargo elevator. It's floor 4.

How to get there by Luca BoccassiLuca Boccassi, 02 Feb 2017 08:10
kalki70kalki70 16 Jan 2017 19:03
in discussion Hidden / Per page discussions » ØMQ is just Sockets!

¿You can achieve the same using plain sockets?

Can you take a plain socket, and call bind() for several addresses/ports on it ? Can you take a plain socket and call connect() simultaneously to different destinations? And then, can you call send() and distribute load over all those destinations, using a plain old socket? If those destinations disconnect, your plain socket reconnects automatically? The list here is really very long…

by kalki70kalki70, 16 Jan 2017 19:03

Hello,

I have a problem using ZMQ_PUB. I have a producer which connects to different processes that bind on ZMQ_SUB sockets.
When producer starts it creates s ZMQ_PUB socket and connects it to different processes. It then immediately start sending messages at a regular period.
As expected, if there are no connected subscribers, it drops all messages, until a subscriber starts. The flow works normal then, the subscriber start receives the messages. Now, the problem is :

  • I disconnect the subscriber (stopping the process).
  • There are no active subscriber at this point, as I stopped the only one.
  • The producer continues sending messages, which should be dropped, as there are no connected subscribers anymore…
  • I restart the original subscriber… and it receives all messages produced in the meantime !!

So what I see is that the producer enqueued all messages while the subscriber was down. As soon as the socket reconnected, because the subscriber process restarted, it sends all queued messages.

As I understood from here, a publisher should drop all sent messages when there are no connected subscribers:

As I am a "low-karma" user I can't publish a link to the documentation, which states :

"A publisher has no connected subscribers, then it will simply drop all messages."

Why is this happening?

By the way, I am using C++ over linux for these tests.

Thanks in advance,

Luis

ZMQ_PUB enqueuing messages? by kalki70kalki70, 16 Jan 2017 16:04

The NuGet package manager in visual studio currently offers the ZeroMQ C# binding versioned 4.1.0.21 (for the clr namespace). Installing this package provides the libzmq.dll with a version of 4.1.5. The application I am working on utilizes a binding in another language which is most stable using an older 3.x version of the libzmq.dll. What are my options for the C# binding that will be compatible with a 3.x version of the libzmq.dll?

Can I run the latest binding on the C# side using the 4.1.5 version of libzmq.dll and use the legacy version of zmq from the other component of the application? In general, do all components using zeroMQ to communicate need to use the same libzmq.dll version?

Can I run the latest binding on the C# side with a 3.x version of the libzmq.dll?

Is there a good option for downgrading the binding and libzmq.dll on the C# side, for example the clrzmq package on NuGet?

Gopi (guest) 13 Dec 2016 12:23
in discussion Hidden / Per page discussions » ØMQ is just Sockets!

It is just sockets. I can achieve the same using plain sockets. How it is different from other JMS implementations

by Gopi (guest), 13 Dec 2016 12:23
Kgothatso (guest) 21 Nov 2016 14:03
in discussion Hidden / Per page discussions » NORM Transport Notes

Hi. I built ZeroMQ manually as prescribed above. I point it to the norm source tree path, and on the make steps it shows that it builds the norm_file. However, I still get a "protocol not supported" issue when trying to run my app. Am I missing something? Also, in the Qt Creator .pro file, how do I add the NORM library? (e.g. LIBS += -lzmq for ZeroMQ)

by Kgothatso (guest), 21 Nov 2016 14:03
kumar (guest) 10 Nov 2016 08:58
in discussion Hidden / Per page discussions » High-speed message matching

the article explains this ..
u build a table for all the criteria say sub1 is orange.#.yellow and sub2 is apple.custard.*

0 orange
1 yellow
2 apple
3 custard

so sub1 bitmap will be 1100 and sub2 will be 0011
and then for each message u create a bitmap

msg apple.red.green
0 1 2 3
msg1 0 0 1 0
sub1 1 1 0 0
---
0 0 0 0 ->its not 1100 so message doesnt match, also no matching fields

msg1 0 0 1 0
sub2 0 0 1 1
---
0 0 1 0 ->its not 0011 so message doesnt match, but has one matching fields

msg orange.color.yellow
0 1 2 3
msg1 1 1 0 0
sub1 1 1 0 0
---
1 1 0 0 ->its 1100 so message matches, chk for order though

by kumar (guest), 10 Nov 2016 08:58
Daniel Cadenas (guest) 14 Oct 2016 22:37
in discussion Hidden / Per page discussions » Broker vs. Brokerless

Ankush notice in the pseudocode that each function returns the value of the inner function to the caller. That's what those arrows represent. We are popping a stack.

by Daniel Cadenas (guest), 14 Oct 2016 22:37

Hi,

I am using a GUI (client) with req socket in it and beaglebone (server)with rep socket. I use lazy pirate pattern in request reply format.
I am able to commnicate with one client and one server.
When I use multiple GUI(clients) to a single beaglebone(server) there are communication breakups after few hours of running.
How to handle multiple client request at the server side?

Regards
jo

Multiple clients by jojitjojit, 24 Aug 2016 13:02

Hi there,

Working on a proof of concept on reading a queue from zeromq (pub/sub) and displaying data on a browser using node,socket,jquery.

Its a monitoring application running from crontab that starts every 5 minutes and feed arbitrary data to a zeromq queue.

My problem is how to signalize the end of that "iteraction" or the start of the next one (5 minutes period)?

I am using

<script> var skt = io(); skt.on('event', (x) => $('#msg').append($('<li>').text(x.fail))); </script>

and it gives me an appending list.

My intention is only have the latest iteration. Any way to mark the last check?

regards,

Hi, I'm new to the idea of distributed systems, so please pardon if the question appears silly. In the first diagram I don't understand the existence of arrows #9 to #12. From the function pipeline, it'd appear that the processing finishes when App D is done. As per me, after #8, we have the output, which should take at most two more network hops.

I suppose this has to do something with SOA architecture, but I'll be happy if someone could explain.

Help explain diagram 1 by Ankush ThakurAnkush Thakur, 20 Aug 2016 13:07

Forget it guys, I don't think he's around…

Re: Small correction by rohitggargrohitggarg, 31 May 2016 09:21

pull request => s33.postimg.org fcstyp8v3/broker2.png

Re: Small correction by rohitggargrohitggarg, 25 May 2016 09:20
Jason Baik (guest) 03 May 2016 15:36
in discussion Hidden / Per page discussions » Measuring messaging performance

Wow, this article is an absolute jewel. I am doing a performance test with ActiveMQ, and this has helped me alot so far. Thanks!

by Jason Baik (guest), 03 May 2016 15:36
Ivan (guest) 10 Apr 2016 15:46
in discussion Hidden / Per page discussions » NORM Transport Notes

Hey, you need to build zeromq manually with ./configure —with-norm=<norm source tree path>

by Ivan (guest), 10 Apr 2016 15:46
pratik inamdar (guest) 26 Mar 2016 20:44
in discussion Hidden / Per page discussions » Traffic Monitoring

I am not able to execute the above monosender.c file itself. Please help.I am getting error /usr/include/zmq.hpp:30:21: fatal error: algorithm: No such file or directory
#include <algorithm>
^

Please help

by pratik inamdar (guest), 26 Mar 2016 20:44
pratik inamdar (guest) 25 Mar 2016 21:18
in discussion Hidden / Per page discussions » Traffic Monitoring

Quick questions:

Is ZeroMQ a transport layer protocol? (I think yes)

And using the procedure above will I be able to generate a pcap file for the ZeroMQ protocol?

by pratik inamdar (guest), 25 Mar 2016 21:18
Shane (guest) 01 Mar 2016 08:25
in discussion Hidden / Per page discussions » Internal Architecture of libzmq

I would like to know how the IO thread pool size setting in zmq_init() will affect the performance in different situations. Thank you.

by Shane (guest), 01 Mar 2016 08:25

Hi,

I am trying out ZeroMQ to see if it can be used for my application. However, I have problem getting it to work.

OS: Windows 10
Programming Language: C#
SDK: VS 2015 Enterprise

From what I read in order to use it in c#, I will need clrmq (which contains clr namspace for .NET) and zmq.

I gotten the "ZeroMQ.Release.zip" from "{https}://github{dot}com/zeromq/clrzmq4/releases" and within it, it contains libzmq.dll, libsodium.dll (both from i386 folder in bin) and ZeroMQ.dll (from bin).

When I try to add references (of the mentioned 3 dlls) to my testing project, I got an error stating
"A reference to libsodium.dll and libzmq.dll could not be added. Please make sure that the file is accessible, and that it is a valid assembly or COM component."

In the end, I only manage to reference ZeroMQ.dll.

Any help would be appreciated to help me start using ZeroMQ in my testing.

Thanks.

Using ZeroMQ In c# by eva2002eva2002, 18 Feb 2016 09:14
Misha (guest) 17 Feb 2016 20:43
in discussion Hidden / Per page discussions » NORM Transport Notes

Cannot get this work. Always the following error when using norm or pgm:
zmq.error.ZMQError: Protocol not supported

by Misha (guest), 17 Feb 2016 20:43
page 1123...next »