Hello Martin,
I even tried with Edge-Triggered semantics.
Still nothing happens. I have written test code to reproduce the problem.
Kindly take a look.
The FileService class in the test code is used to watch descriptors using
libevent. Its tested to be working fine separately. I am also attachi
Thanks all,
I later re-re-read the documentation and realised I was misunderstanding
ZMQ; - you can't bind multiple listen sockets to the same physical address
with any protocol (by design) and there is Another Way To Do It.
This re-binding failure is masked with IPC sockets (only last bind works
Martin,
On Fri, Dec 17, 2010 at 3:31 AM, Martin Sustrik wrote:
> Hi,
>
>> 1) Using one zmq context, I bind four separate zmq sockets (in java) to
>> the same ipc port; e.g. "ipc://tmp/test"
>
> Hm, you should be able to bind at most one socket to a particular
> endpoint. Are you sure all the four
Hi,
I have also added psenvpub.py and psenvsub.py in the github fork
https://github.com/gaubert/zguide.
The code is licensed under the MIT/X11 license.
More should come.
Cheers Guillaume
On Thu, Dec 16, 2010 at 8:56 AM, Guillaume Aubert
wrote:
> Morning Martin,
>
> I forked the zguide project a
Hi Dhammika,
> Thanks for pointing this out.
> I've fixed asymmetric calls in following patch.
> Both read and write call finalize_initialization(), and flush()
> dispatches engine, if it's already finalized.
I've peer reviewed the patch thoroughly and applied it to the master.
Thanks and sorry
I'll try
again, but the system ist already rather complex and it will be much
effort to strip it down (maybe impossible). So I'd have to build the
testcase from scratch.
Current Scenario is the following:normal devices:- a
modified queue device, implemented as LRU queue (not exactly as
described in
Andreas,
> hi there, in my cluster i want to have my queuing system based on zeromq
> however i want to use as persistent storage of the messages the hdfs. do
> you have any ideas how to start with?
0MQ is a messaging fabric, not a storage. Thus you should build you
persistence layer on top of 0
Hi,
> 1) Using one zmq context, I bind four separate zmq sockets (in java) to
> the same ipc port; e.g. "ipc://tmp/test"
Hm, you should be able to bind at most one socket to a particular
endpoint. Are you sure all the four binds succeed?
Martin
___
z
On 12/16/2010 10:39 PM, Oliver Smith wrote:
> I'm not actually looking for the sender's address so much as who */I/*
> got the message from, IE the previous hop. While the address and port
> would be nice for diagnosing sources of bad data within a fabric (I
> spent 2 days this week tracking down
Hi Sven,
> the main issue is, that poll(... ,-1) does not at all return despite
> the fact that there is a message available!
> The usage of timeout value is a current workaround, because the second
> call to poll (the first returned zero) successfully returns a number
> greater one.
Can you prov
Hi all,
Feeling my way around this most excellent (and lean!) middleware.
I'm using both Java and c zmq libraries in different parts of my system.
I may be misunderstanding or have a code bug but my assumption is that;
1) Using one zmq context, I bind four separate zmq sockets (in java) to the
sa
hi there, in my cluster i want to have my queuing system based on zeromq
however i want to use as persistent storage of the messages the hdfs. do you
have any ideas how to start with?
thanks in advance
___
zer
12 matches
Mail list logo
