Re: [zeromq-dev] Question about reliability in ZeroMQ

2016-10-18 Thread Joshua Foster
, Joshua Foster <jhaw...@gmail.com> wrote: Lets see if I can explain it. Each socket has its own queue/buffer. This is what is used to track how many messages. PUB/SUB uses a drop approach when its queue gets full. If a subscriber is slow (has a full queue), the publisher continues publishing an

Re: [zeromq-dev] Question about reliability in ZeroMQ

2016-10-18 Thread Joshua Foster
Lets see if I can explain it. Each socket has its own queue/buffer. This is what is used to track how many messages. PUB/SUB uses a drop approach when its queue gets full. If a subscriber is slow (has a full queue), the publisher continues publishing and does not block. The slow subscriber

Re: [zeromq-dev] Looking for C++ and Java APIs for sending large messages around 15 MB

2016-06-01 Thread Joshua Foster
Multipart messages won’t help because they are sent atomically, ZeroMQ sees them as a single message. Joshua > On Jun 1, 2016, at 2:14 AM, yogesh fulsunge wrote: > > Dear Team, > > I am looking for zeromq apis in C++ and java for sending large message sizes >

Re: [zeromq-dev] JeroMQ - Add logging

2013-12-30 Thread Joshua Foster
What sort of debugging are you trying to solve? Logging statements can be done well and poorly.This also depends on what sort of debugging is needed. slf4j is an external library, have you considered using java.util.logging? Joshua On Dec 30, 2013, at 8:11 AM, pablo fernandez

Re: [zeromq-dev] libzmq issues disabled

2013-11-16 Thread Joshua Foster
Issues repository can be found here: https://zeromq.jira.com/browse/LIBZMQ Joshua On 11/16/2013 12:15 PM, shancat wrote: Hey, can anyone explain why the libzmq repo has issues disabled? Thanks ___ zeromq-dev mailing list

Re: [zeromq-dev] Queue manager

2013-08-21 Thread Joshua Foster
1. ZeroMQ stores the messages in the memory of the process that is using it (ZeroMQ is a library). 2. Short answer - have high and low priority socket and poll between the two favoring the high priority socket. Long answer - it really depends on the problem. Sometimes its better to solve it

Re: [zeromq-dev] zmq questions

2013-06-07 Thread Joshua Foster
You problem is that the network is closing the connection without ZMQ knowing. If you unplug your network cable and replug it back in, it will reconnect and continue receiving data. If the network is closed without ZMQ knowing, ZMQ will not know to reconnect. This usually happens on large

Re: [zeromq-dev] zmq questions

2013-06-07 Thread Joshua Foster
7, 2013 8:38 PM Thranks your help! Doyoumeantosaythatthenetworkremainsconnectedstate,ZMQinternalinitiativecallsforadditiontothenetwork,whichisnottheirownre-connectwiththeserver,sotheclientisunabletomaintainlong-SUBconnection,is right ? 2013-06-08 linjson Joshua Foster 2013-06-08

Re: [zeromq-dev] Enabling log

2013-06-03 Thread Joshua Foster
Historically, this has been seen as something layered on top of zeromq instead of part of zeromq. No, there is not trace/debugging built into zeromq. Joshua Rodolfo Damas Sunday, June 02, 2013 2:13 PM I'm a bit confused here.. Did anyone answer the post

Re: [zeromq-dev] Is it possible to add message priority on top of ZeroMQ?

2013-05-31 Thread Joshua Foster
I usually implement this with multiple sockets. You can then use the poller to priorities the messages from another socket. Joshua crocket Friday, May 31, 2013 10:09 PM Imagine a situation where some messages are urgent and need to be delivered faster than low

Re: [zeromq-dev] Help on the PUB/SUB socket reconnection.

2013-05-16 Thread Joshua Foster
You may also be able to use the "ZMQ_TCP_KEEPALIVE" option to help with observation 2. Joshua 许海玲 May 15, 2013 11:05 PM Hello zmq guys,I am writing this letter to confirm whether zmq PUB/SUB socket tcp connection have no timeout mechanism.Recently, I am coding with

Re: [zeromq-dev] SUB connected early in PUB

2013-05-06 Thread Joshua Foster
ZMQ does reconnects in the background so you can connect or bind in any order. What transport are you using? Joshua Absynt Technologies May 6, 2013 1:21 AM Hi all!I'm developing against ZMQ on a distributed service architechture.architecture is as follows:- I first

Re: [zeromq-dev] Several Context object per JVM

2013-04-30 Thread Joshua Foster
You can just create one context and share between threads. You want to share the context between threads so that it can use inproc connections between threads. The '1' is used to tell ZeroMQ to only use one io thread in the background. You generally don't need more than one unless you have

Re: [zeromq-dev] DEALER -- ROUTER -- Double Read() is so slow. Please have a look at the codes.

2013-04-15 Thread Joshua Foster
JeroMQ is going to be slower than the JZMQ. Joshua crocket April 15, 2013 8:22 PM I'd try more messages, see if the time is proportional (10K, 100K, 1M). I'd then replace the LabView piece with null code (doing no work) so you can see which side the time is being

Re: [zeromq-dev] Sniffing connections

2013-04-10 Thread Joshua Foster
Best place to start is the MTP: http://rfc.zeromq.org/spec:23 Joshua Garrett Smith wrote: It's come to the point that I want to become very intimate with 0MQ connections. I'd usually use tcpdump and watch port traffic but at the TCP level, I'm guessing I won't learn much. Does anyone have

Re: [zeromq-dev] Cross compile for ArchLinux ARM

2013-04-06 Thread Joshua Foster
It should be possible. I've used it on Raspberry PI (Debian) so it should compile under ArchLinux. Others have cross-compiled for Android. ZeroMQ doesn't have many external dependencies. When I did a linux cross-compile for an embedded system for ZMQ 2.2.0, it only required libuuid. If you

Re: [zeromq-dev] Problems cross compiling for ARM

2013-04-06 Thread Joshua Foster
I would suggest looking at http://www.zeromq.org/build:android for ideas. Joshua Michael Powell wrote: Hello, I want to build ZMQ for ARM but have problems. If I just build with the plain old i386 arch, no problems. I do get a .a library I can statically link against, BTW. Good. Now if I

Re: [zeromq-dev] Which language binding/API to use such that the process uses least RAM

2013-04-05 Thread Joshua Foster
On Thu, Apr 4, 2013 at 3:50 PM, Joshua Foster jhaw...@gmail.com mailto:jhaw...@gmail.com wrote: You can use something like ZMQC. Here is a python version: https://github.com/zacharyvoase/zmqc Here is my go port of it: https://github.com/jhawk28/zmqc Joshua Arvind Creatrix IT Soft mailto:arv

Re: [zeromq-dev] Not a valid DLL error

2013-04-05 Thread Joshua Foster
I usually just put the libzmq.dll in a directory on the PATH. Joshua Nishant Mittal wrote: Eric, also I could not add it as a reference to my project in Visual studio. so I just put it in the bin/Debug folder and it worked during development.. but now when its time to deploy my application..

Re: [zeromq-dev] Which language binding/API to use such that the process uses least RAM

2013-04-04 Thread Joshua Foster
You can use something like ZMQC. Here is a python version: https://github.com/zacharyvoase/zmqc Here is my go "port" of it: https://github.com/jhawk28/zmqc Joshua Arvind Creatrix IT Soft Thursday, April 04, 2013 5:52 PM Hello,   Thank you for your helpful

Re: [zeromq-dev] How do I couple ZeroMQ with encryption?

2013-03-27 Thread Joshua Foster
You could use something like CurveCP (http://curvecp.org/) or you could use a VPN. Joshua crocket wrote: ZeroMQ doesn't support encryption by design. How do I best add encryption to ZeroMQ messages sent over the internet? ___ zeromq-dev mailing

Re: [zeromq-dev] Basic server.c example

2013-03-15 Thread Joshua Foster
You can also use something like zmqc (https://github.com/jhawk28/zmqc) to send from the command line. Joshua Alexandre Fromage March 15, 2013 6:18 AM Hi,You might want to read that http://rfc.zeromq.org/spec:13 . You need to use the correct protocol to communicate with

Re: [zeromq-dev] Looking for a multicast example in C# or java

2013-02-23 Thread Joshua Foster
You can use the pgm/epgm transports for this. The example would be the same as the this: http://zguide.zeromq.org/cs:wuproxy but with a connect/bind string of: epgm://eth0;239.192.1.1: or pgm://192.168.1.1;239.192.1.1: NOTE: you need zeromq compiled with openpgm. Joshua

Re: [zeromq-dev] How to send binary and text massage in one massage

2013-01-10 Thread Joshua Foster
It is much cleaner and faster to just send a multipart message using zeromq. The multipart is still considered a single ZMQ message and will be delivered atomically. The guide has some more examples. Joshua It would look something like this: import org.zeromq.ZMQ; String xml = "somexml/"

Re: [zeromq-dev] zmq_socket and threads

2013-01-02 Thread Joshua Foster
The mutex is "required" because it guarantees that it is only used by a single thread at a time. ZMQ has assertions that will cause your application to crash if you access a socket between two threads concurrently. Joshua Nishant Mittal January 2, 2013 6:58 PM

Re: [zeromq-dev] zmq_socket and threads

2013-01-02 Thread Joshua Foster
It should be fine if you create a socket to pass to the thread for the exclusive access by the thread. Joshua Nishant Mittal Wednesday, January 02, 2013 7:08 PM Joshua, if you read my first msg in this thread you'll see that its guaranteed by application logic.. 5

Re: [zeromq-dev] ZeroMQ for a Real Time API

2012-12-31 Thread Joshua Foster
I suspect that its because most of queuing technologies are asynchronous. For realtime, you need guarantees. Queuing products rarely provide any such guarantees. At best, you could get pseudo real-time since zeromq is fast/lightweight. Joshua Marinho Brandao December 30,

Re: [zeromq-dev] test email

2012-12-27 Thread Joshua Foster
Confirmed Nishant Mittal December 27, 2012 10:26 AM testing if my emails are going through to the list.. can someone pls confirm.thanks-- Nishant Mittal Director, Product DevelopmentRosenblatt Securities Inc.20 Broad StreetNew York, NY 10005 Direct:

Re: [zeromq-dev] fun with Java API

2012-11-15 Thread Joshua Foster
The bindings have JavaDoc. You can generate it with the maven build. I don't use the Z* objects. I usually use the ZMQ.* ZMQ.Context context = ZMQ.context(1); etc... Joshua Peter Friend Thursday, November 15, 2012 5:13 PM Perhaps I have missed it, but as far as I can

Re: [zeromq-dev] Broadcasting with a Router ?

2012-07-12 Thread Joshua Foster
You technically could if you kept track of all the addresses that you received. The main downside is that you don't know when someone connects/disconnects. You only know what requests were received. Joshua Grgoire Passault Thursday, July 12, 2012 9:43 AM Hi,Since I'm

Re: [zeromq-dev] Broadcasting with a Router ?

2012-07-12 Thread Joshua Foster
Anything is possible :) There was some experimentation going on the 3.0 version that created a Generic socket. Your hybrid socket could be developed with it because you would get the Connect/Disconnect information. Joshua Grgoire Passault Thursday, July 12, 2012 6:57 PM

Re: [zeromq-dev] Jzmq

2012-07-10 Thread Joshua Foster
If you don't do a socket.recv(0), then it will return null if there is nothing in the queue. Joshua xaviermillie...@eaton.com July 10, 2012 11:48 AM Hi,   I try to use the java binding for zeromq on win seven 64:   Configuration: I downloaded the

Re: [zeromq-dev] Asymmetrical PUB-SUB problem

2012-07-07 Thread Joshua Foster
Try binding to * on box b when publishing. Joshua Mark Sutheran July 7, 2012 9:42 AM I'm having a strangeasymmetricalproblem with tcp PUB/SUB between two boxes - it appears to fail one way.Details:* zeromq version: 3.2, using the Java wrapper.* Scenario has two

Re: [zeromq-dev] Design Suggestion for simple app using zmq

2012-07-05 Thread Joshua Foster
Are the ACK's async? If they are not, you can use the REQ socket instead. Are you using multiple threads? Joshua On Jul 5, 2012, at 7:58 PM, Diffuser78 wrote: Anyone ? On Thu, Jul 5, 2012 at 8:23 AM, Diffuser78 diffuse...@gmail.com wrote: I have a client and a server app. Client needs to

Re: [zeromq-dev] embedding zeromq question

2012-06-04 Thread Joshua Foster
The low-latency nature of ZeroMQ makes it ideal for embedded platforms. As of 3.x, ZeroMQ has no external dependencies (2.1 needs libuuid). My Windows version is 180KB, and my OSX version is 380KB. Your runtime needs will depend on how large the messages are and the number of messages expected

Re: [zeromq-dev] req-rep with max delay, in Ruby

2012-04-20 Thread Joshua Foster
If the binding is able to use 2.2.0, you can set the recvTimeOut socket option instead of using the poller. Joshua On Apr 20, 2012, at 3:53 AM, Raphael Bauduin wrote: Hi, I need a process to send a request to a server, and wait a maximum of (let's say) 300 milliseconds. If no reply comes

Re: [zeromq-dev] help

2012-04-12 Thread Joshua Foster
I would recommend reading the guide. You will want to start out just using PUSH/PULL, REQ/REP, and PUB/SUB for learning ZeroMQ. Dealer and Router sockets are a little more advanced (and have their place). It looks like you have the back half to a work queue (rrbroker is the work distributer and

Re: [zeromq-dev] [ANNOUNCE] ZeroMQ/2.2.0 stable released

2012-04-04 Thread Joshua Foster
I submitted a push request for the timeouts to the JZMQ repo and it was pulled (today). We should probably recommend doing another release of the Java bindings to be able to take advantage of the new libzmq 2.x feature. Joshua On Apr 4, 2012, at 9:39 AM, William Brown wrote: Pieter,

Re: [zeromq-dev] Backport of ZMQ_RCVTIMEO/ZMQ_SNDTIMEO to 2.1.x

2012-04-03 Thread Joshua Foster
I back ported the fix in https://github.com/zeromq/zeromq2-1/pull/45 The issue is logged in https://zeromq.jira.com/browse/LIBZMQ-349 Joshua ___ zeromq-dev mailing list zeromq-dev@lists.zeromq.org http://lists.zeromq.org/mailman/listinfo/zeromq-dev

Re: [zeromq-dev] Backport of ZMQ_RCVTIMEO/ZMQ_SNDTIMEO to 2.1.x

2012-04-03 Thread Joshua Foster
timeouts missing, makes REQ sockets less useful. -Pieter On Tue, Apr 3, 2012 at 1:20 PM, Joshua Foster jhaw...@gmail.com wrote: I back ported the fix in https://github.com/zeromq/zeromq2-1/pull/45 The issue is logged in https://zeromq.jira.com/browse/LIBZMQ-349 Joshua

[zeromq-dev] Backport of ZMQ_RCVTIMEO/ZMQ_SNDTIMEO to 2.1.x

2012-03-30 Thread Joshua Foster
Does anyone have any problem if I back port the send/recv time out socket options to 2.1.x? Joshua ___ zeromq-dev mailing list zeromq-dev@lists.zeromq.org http://lists.zeromq.org/mailman/listinfo/zeromq-dev

Re: [zeromq-dev] Backport of ZMQ_RCVTIMEO/ZMQ_SNDTIMEO to 2.1.x

2012-03-30 Thread Joshua Foster
Looking through the code, much of it has already been back ported as part of issue 231. Are we still using the https://github.com/zeromq/zeromq2-1 repository for the 2.1.x development? Joshua On Mar 30, 2012, at 11:55 AM, Pieter Hintjens wrote: On Fri, Mar 30, 2012 at 10:26 AM, Joshua Foster

Re: [zeromq-dev] PUB SUB in zmq 2.1.11

2012-03-21 Thread Joshua Foster
I suspect this is caused by the time required to try reconnecting (it gets progressively longer). Don't put a sleep between the connect and bind, just before the sending first message. Joshua On Mar 21, 2012, at 6:56 AM, Doherty, Kevin wrote: Folks, I’m new to the mail list. Has

Re: [zeromq-dev] PUB SUB in zmq 2.1.11

2012-03-21 Thread Joshua Foster
to the entire first message when there is an actual subscription filter string. tx From: zeromq-dev-boun...@lists.zeromq.org [mailto:zeromq-dev-boun...@lists.zeromq.org] On Behalf Of Joshua Foster Sent: Wednesday, March 21, 2012 9:29 AM To: ZeroMQ development list Subject: Re

Re: [zeromq-dev] Using 0mq in a Web application

2012-03-14 Thread Joshua Foster
check out http://mongrel2.org/ Joshua On Mar 13, 2012, at 10:41 PM, David Mitchell wrote: Is is possible when running a PHP script under mod_php or CGI and an Apache Web server to bind or connect to a TCP or IPC socket? I can bind and connect when using the PHP CLI, but the connection

Re: [zeromq-dev] v3.1 publisher filtering

2012-03-14 Thread Joshua Foster
that it is performing a subscriber side filtering. Not with 3.1 though. On Wed, Mar 14, 2012 at 1:05 PM, Ian Barber ian.bar...@gmail.com mailto:ian.bar...@gmail.com wrote: On Wed, Mar 14, 2012 at 1:31 AM, Joshua Foster jhaw...@gmail.com

Re: [zeromq-dev] v3.1 publisher filtering

2012-03-13 Thread Joshua Foster
you can use XPUB in order to do more advanced subscription management, it is not a requirement to have publisher side filtering. In Steve's example, Subscriber A would not receive every message, only messages matching its filter. On Mon, Mar 12, 2012 at 7:43 PM, Joshua Foster

Re: [zeromq-dev] v3.1 publisher filtering

2012-03-13 Thread Joshua Foster
subscription management, it is not a requirement to have publisher side filtering. In Steve's example, Subscriber A would not receive every message, only messages matching its filter. On Mon, Mar 12, 2012 at 7:43 PM, Joshua Foster jhaw...@gmail.com mailto:jhaw...@gmail.com wrote: 3.1

Re: [zeromq-dev] v3.1 publisher filtering

2012-03-12 Thread Joshua Foster
3.1 works the same way as 2.1 in your example. The changes in 3.1 is that the subscription is forwarded to the PUB socket. This allows you to create a publisher device. It would sit between the parent publisher and the subscriber. The XPUB keeps track of the subscriptions and allows them to

Re: [zeromq-dev] Can I use a zmq socket with the inproc transport under Windows XP?

2012-03-05 Thread Joshua Foster
Yes, inproc works on Windows. You can use inproc between threads. The ipc transport does not work under Windows. ipc is between processes. It is recommended to use tcp://127.0.0.1 between processes on Windows. Joshua On 3/5/2012 9:14 PM, yy l wrote: Hello ereryone! Can I use a zmq socket

Re: [zeromq-dev] Can I use a zmq socket with the inproc transport under Windows XP?

2012-03-05 Thread Joshua Foster
world!)+1); memcpy(zmq_msg_data (msg), hello world!, strlen(hello world!)+1); rc = zmq_send(pub_server, msg, 0); Sleep(1000); } return 0; } 2012/3/6 Joshua Foster jhaw...@gmail.com mailto:jhaw...@gmail.com Yes, inproc works on Windows. You can use inproc between threads

Re: [zeromq-dev] Send files

2012-02-19 Thread Joshua Foster
The best size depends on your algorithm and environment. Leave it variable and run some tests. Try 256, 512, 1024 bytes. Joshua On Feb 19, 2012, at 8:04 AM, Marco Trapanese wrote: Hello, I have a LAN with one server (ROUTER) and 25 clients (DEALER) that exchange small bit of data

Re: [zeromq-dev] SUB socket: parts of multipart message getting reversed

2012-02-17 Thread Joshua Foster
I would check to make sure that you are not actually wrapping messages between the loop. try using a socket.hasReceiveMore() before pulling the next part and then using draining the rest of the message parts if it doesn't match your expectation. A typical drain call that you can use could be

Re: [zeromq-dev] On windows uses select() ?

2012-02-09 Thread Joshua Foster
Correct. IOCP has been looked at a number of times, but no impl yet. 0MQ just uses select() on Windows. It is why there is no IPC on the Windows version. Joshua On Feb 9, 2012, at 10:28 AM, niXman wrote: Hi, I read the ØMQ sources and could not find IOCP implementation for Windows. Is it

Re: [zeromq-dev] Thread Safe sockets

2012-02-06 Thread Joshua Foster
I would like to put forth the motion that the sockets should not be thread safe. The multipart messages do not facilitate the ability for thread safety without some major complexity. This would involve the complexity of changing the API that breaks backwards compatibility or adding locks which

Re: [zeromq-dev] Thread Safe sockets

2012-02-06 Thread Joshua Foster
I'm not sure if other languages have the same mechanism, but Java has a ThreadLocal object. It allows the developer to create and store objects local for each thread. In the ZMQ case, it would be an inproc socket for each thread so that we can hide the complexity of thread safety under the

Re: [zeromq-dev] CPU load while polling 0mq sockets

2012-02-03 Thread Joshua Foster
Polling is supposed to be a non-busy wait so there should not be any CPU usage while waiting on the sockets. I know this works on the Java version. Joshua On 2/3/2012 4:25 PM, Sergey Malov wrote: I've checked it with different version of Scala 0mq binding, and it behaves as expected: setting

Re: [zeromq-dev] does 0mq keep-alive for connections?

2012-01-23 Thread Joshua Foster
This would have solved our problems in a recent demo. We would publish data and it would work fine until we paused for a little while. I thought about putting heartbeats in, but we don't really need to guarantee data (using PUB) or the complexity (adding the heartbeat handling to all

Re: [zeromq-dev] detecting disconnections

2012-01-09 Thread Joshua Foster
There has been talk of the Router socket able to provide disconnect notifications. I'm not sure its in 3.x yet though. Joshua On Jan 9, 2012, at 12:38 AM, Kasicass Tang wrote: No. ZMQ doesn't provide connecting/disconnecting notification. It's just a message-queue, and possibly got data lost

Re: [zeromq-dev] publish/subscribe hangs in libzmq

2011-12-30 Thread Joshua Foster
Try adding a sleep after the pub.connect(). pub/sub throws away data if it has not finished connecting. Joshua On Dec 30, 2011, at 9:15 AM, Toralf Wittner wrote: Please consider the following program: #include zmq.hpp #include iostream int main() { zmq::context_t ctx(0);

Re: [zeromq-dev] multiple publisher synchronization

2011-12-29 Thread Joshua Foster
in there. Thanks, Yi On Wed, Dec 28, 2011 at 5:50 PM, Joshua Foster jhaw...@gmail.com wrote: I'm wondering if you could use an XPUB and XSUB socket. You know when to start sending when you receive a subscription. Joshua On Dec 28, 2011, at 5:42 PM, Yi Ding wrote: Hi everyone, I've been

Re: [zeromq-dev] multiple publisher synchronization

2011-12-28 Thread Joshua Foster
I'm wondering if you could use an XPUB and XSUB socket. You know when to start sending when you receive a subscription. Joshua On Dec 28, 2011, at 5:42 PM, Yi Ding wrote: Hi everyone, I've been trying to build this program where I have multiple publishers (where each publisher represents

Re: [zeromq-dev] Issue with maven commands and running java programs form zmq.jav

2011-12-02 Thread Joshua Foster
Try this: java -Djava.library.path=/usr/local/lib -cp jzmq-1.0.0.jar:. hwclient You need to include the local directory if you are running your code. If you are running within eclipse, you need to add -Djava.library.path=/usr/local/lib to the vm parameters and the jzmq-1.0.0.jar as a dependent

Re: [zeromq-dev] 0MQ/3.1

2011-11-07 Thread Joshua Foster
Option 2. I never really got far enough with 3.0 since I couldn't see a forward path from 2.1 to 3.0 to 4.0. Joshua On Nov 7, 2011, at 6:17 PM, Pieter Hintjens wrote: On Tue, Nov 8, 2011 at 1:51 AM, Martin Sustrik sust...@250bpm.com wrote: It's up to Pieter whether he wants to maintain 3-0

Re: [zeromq-dev] Cannot build a working JZMQ on Windows: which git branch to take?

2011-10-26 Thread Joshua Foster
The simplest way to get jzmq working on windows is to put the libzmq.dll and the jzmq.dll in a directory on the PATH environment variable. Joshua On 10/26/2011 1:20 PM, Steven McCoy wrote: 2011/10/26 Igor 'Lo' (?.L.) bombsiteunres...@gmail.com mailto:bombsiteunres...@gmail.com Hi all.

Re: [zeromq-dev] Java binding configure fails

2011-10-15 Thread Joshua Foster
See: http://stackoverflow.com/questions/3522248/how-do-i-compile-jzmq-for-zeromq-on-osx Joshua On Oct 14, 2011, at 5:06 PM, Mark Libucha wrote: Just did a git clone, autogen works, but configure ends like this: checking how to hardcode library paths into programs... immediate ./configure:

Re: [zeromq-dev] UnsatisfiedLinkError

2011-10-08 Thread Joshua Foster
No, it is not a bug. It means that you don't have the jzmq on the java.library.path Joshua On Oct 8, 2011, at 10:08 AM, ravi wrote: Now the program is blocked @ byte [] data = s.recv (0); is this a bug? ___ zeromq-dev mailing list

Re: [zeromq-dev] What ZMQ will do when I use the multipart message

2011-09-22 Thread Joshua Foster
Yes, my examples were in Java. Joshua On Sep 21, 2011, at 11:22 PM, jjmilk13 wrote: As your words I can do the same work in java? Does the code is similarity? From: Joshua Foster Sent: Thursday, September 22, 2011 11:15 AM To: ZeroMQ development list Subject: Re: [zeromq-dev] What

Re: [zeromq-dev] What ZMQ will do when I use the multipart message

2011-09-21 Thread Joshua Foster
A multipart message is just a message of many parts. You create a multipart message by sending with the ZMQ.SNDMORE flag like this: socket.send(myfirstbytes, ZMQ.SNDMORE); socket.send(mysecondbytes, 0); That would create a 2 part message. Its usually helpful for adding flags for context

Re: [zeromq-dev] setting socket option in jzmq

2011-09-10 Thread Joshua Foster
The constant value for ZMQ_SNDTIMEO in zmq.h is 28. Someone just needs to add it to jzmq since setLongSocketopt is protected. Joshua On 9/10/2011 6:25 PM, Di Ly wrote: Is it possible to set the socket option (ZMQ_SNDTIMEO) in Java with jzmq? ___

Re: [zeromq-dev] security model recommendation

2011-09-07 Thread Joshua Foster
VPN is also available for more advanced security such as encryption and endpoint verification. Joshua On Sep 7, 2011, at 7:41 PM, chr...@techspecs.com wrote: Hi, Suppose 0mq is used in a commercial product and is released and is used by the community. Now, a hacker discovers that 0mq is

Re: [zeromq-dev] Embedded Systems

2011-09-04 Thread Joshua Foster
Depending on what version of ZeroMQ you want to interface with, you would need to implement ZMTP 1.0 or 1.1: http://rfc.zeromq.org/spec:13 http://rfc.zeromq.org/spec:15 Joshua On 9/4/2011 7:41 AM, Ilya Dmitrichenko wrote: Hi, Here is another question that bothers me quite a bit. I had been

Re: [zeromq-dev] Issues with Java bindings on Mac OS X 10.6.8

2011-08-29 Thread Joshua Foster
You need to subscribe to the data. You don't receive any messages until a filter pattern is applied. listener.subscribe(.getBytes()); Be aware that the Pub/Sub sockets are non durable and that they often lose the first set of messages send due to the time to connect and subscribe. You will

Re: [zeromq-dev] recovering from an unanswered reply

2011-08-20 Thread Joshua Foster
The best way I have found is to use a Poller in addition to the REQ socket. It lets you set a timeout on the recv. If you don't recv in an expected time, do a resend (you may need to close and reconnect). Joshua On Aug 20, 2011, at 6:44 AM, Mathijs Kwik wrote: Hi all, If process1 uses a

Re: [zeromq-dev] NoClassDefFoundError: Could not initialize class org.zeromq.ZMQ

2011-08-08 Thread Joshua Foster
If you want 0MQ dll's to be available to all Java applications on Windows, you add the directory containing them to the PATH environment variable. Joshua On 8/8/2011 5:42 AM, Rugemalila Jeremiah Ngemera wrote: To who it may concern, I have very new to ZeroMQ. My colleague wrote a web

Re: [zeromq-dev] data sync across multiple machines

2011-08-05 Thread Joshua Foster
You could make a distributed discovery service that all daemons know about (use DNS and a common port). When clients come up, they register with the service. the discovery service would need to know about the other discovery service nodes to be able to replicate the data. Joshua On 8/5/2011

Re: [zeromq-dev] Pub/Sub questions

2011-07-18 Thread Joshua Foster
If you use a payload encryption, you could pass out shared decryption keys using a req/rep. If the filtering needed to change, you could detect it (decryption fails) and the clients would then request a new decryption key. The ones that are not allowed to see that data would be rejected.

Re: [zeromq-dev] Question: release policies and v3.x

2011-07-18 Thread Joshua Foster
I don't think the numbering actually matters (unless you really like the number 3). Numbering seems to be more of a marketing/political issue if it ever does matter. I suspect the topic of breaking backwards compatibility and how to handle it is more important. We will have this when we move

Re: [zeromq-dev] multipart message receiving does not work with C++

2011-06-02 Thread Joshua Foster
Here is a recommended way in protobufs - http://code.google.com/apis/protocolbuffers/docs/techniques.html#self-description Joshua On Jun 2, 2011, at 6:53 AM, Martin Sustrik wrote: On 06/02/2011 11:37 AM, Seref Arikan wrote: I'm already using protocol buffers. The thing is, I can be passing

Re: [zeromq-dev] Guide now in PDF

2011-06-01 Thread Joshua Foster
Just did a quick skim and it looks good. Joshua On 6/1/2011 4:16 PM, Pieter Hintjens wrote: Hi folks, I've finally managed to produce a nice version of the Guide (with index, page headers/footers etc.) as PDF, for those with e-readers and others who want this text to go. It's at

Re: [zeromq-dev] Slow subscriber runs out of memory

2011-05-23 Thread Joshua Foster
I ported the code to Java and it does not increase in memory. My guess is that the clrzmq bindings are at fault. http://pastebin.com/nZACLqi1 Joshua On 5/23/2011 11:35 AM, Martin Sustrik wrote: On 05/23/2011 05:17 PM, a frost wrote: I am evaluating ZMQ, doing some initial testing with a

Re: [zeromq-dev] Meetup in Seattle

2011-05-18 Thread Joshua Foster
Sounded like fun up till the beer part. Joshua On 5/18/2011 10:06 AM, Pieter Hintjens wrote: Hi all, I'm going to be in Seattle next week, so propose a meetup on Wednesday evening. I've no idea for suitable locations so if any natives of the area have suggestions, please give a shout. The

Re: [zeromq-dev] Inconsistent behavior during tests

2011-05-11 Thread Joshua Foster
I'm not sure what you are seeing here are my test runs... E:\zmqwin32remote_thr.exe tcp://127.0.0.1: 120 1000 E:\zmqwin32remote_thr.exe tcp://127.0.0.1: 120 1000 E:\zmqwin32local_thr.exe tcp://127.0.0.1: 120 1000 message size: 120 [B] message count: 1000 mean

Re: [zeromq-dev] Inconsistent behavior during tests

2011-05-11 Thread Joshua Foster
Memory 26.3 GB Page File Space 15.9 GB Page File C:\pagefile.sys --CM From: zeromq-dev-boun...@lists.zeromq.org [mailto:zeromq-dev-boun...@lists.zeromq.org] On Behalf Of Joshua Foster Sent: Wednesday, May 11, 2011 2:06 PM To: ZeroMQ development list Subject: Re

Re: [zeromq-dev] HWM default

2011-05-08 Thread Joshua Foster
I would prefer that the HWM stay as the default. The application needs to be built with the HWM in mind. If they don't explicitly set the value, they are probably not considering it. There is also the challenge of knowing the proper size that the HWM needs to be set based on the size of the

Re: [zeromq-dev] Basic forwarder question

2011-05-02 Thread Joshua Foster
add: publishers.setsockopt(zmq.SUBSCRIBE, ) Joshua On 5/2/2011 6:11 PM, Dan Gould wrote: Hi, I'm a ZeroMQ newbie, but couldn't find an answer to this via the docs or list archives (sorry if I missed it). I've been using a pub/sub connection. It works fine. I was using: Sender:

Re: [zeromq-dev] Basic forwarder question

2011-05-02 Thread Joshua Foster
Here is the full code... You should be connecting to the sender and then subscribing to all the messages. Sender: sender.bind(tcp://127.0.0.1:5559) ... sender.send_json(message) Device: context = zmq.Context(1) incoming = context.socket(zmq.SUB)

Re: [zeromq-dev] PDF version of the Guide

2011-04-30 Thread Joshua Foster
The table of contents should be expanded and maybe clickable. Joshua On 4/30/2011 9:55 AM, Pieter Hintjens wrote: Hi All, I've uploaded an experimental PDF version of the Guide, available at http://zguide.zeromq.org/main:_start. Please let me know if this works for you and I'll add this to

Re: [zeromq-dev] windows easy_install error

2011-04-17 Thread Joshua Foster
You need to match the VC++ redistrib libraries to the build environment. Joshua On Apr 17, 2011, at 9:53 PM, 机械唯物主义 : linjunhalida wrote: OK, install official python.org MSI + easy_install + pyzmq works, still don't know why pythonxy + pyzmq fails, digging.. 2011/4/15 MinRK

Re: [zeromq-dev] ZeroMQ, jzmq, and J2EE

2011-04-14 Thread Joshua Foster
wrote: On 14 April 2011 05:33, Joshua Foster jhaw...@gmail.com mailto:jhaw...@gmail.com wrote: Has anyone had success using zeromq in a J2EE application? Yes, I used it to quickly (1 day work) bypass a scalability issue on by java stack (jetty-cxf-solr) and reach 800 query-per-sec rate using

[zeromq-dev] ZeroMQ, jzmq, and J2EE

2011-04-13 Thread Joshua Foster
Has anyone had success using zeromq in a J2EE application? Joshua ___ zeromq-dev mailing list zeromq-dev@lists.zeromq.org http://lists.zeromq.org/mailman/listinfo/zeromq-dev

Re: [zeromq-dev] [ZeroMQ] Advises using 0MQ

2011-03-11 Thread Joshua Foster
In addition to reading the ZMQ manual, I would recommend looking into some projects that provide document sync: http://code.google.com/p/etherpad/ http://code.google.com/p/google-diff-match-patch/ http://code.google.com/p/google-mobwrite/ Joshua On Mar 11, 2011, at 5:52 AM, Eloi Du Bois wrote:

Re: [zeromq-dev] Exception in thread main java.lang.UnsatisfiedLinkError: no jzmq in java.library.path (Windows)

2011-02-25 Thread Joshua Foster
The UnsatisfiedLinkError is because the the directory containing the dll's needs to be on the PATH Environment variable. Joshua On Feb 25, 2011, at 8:23 PM, Steven Dahlin wrote: The message is occurring when I attempt to initialize a context in Java with: ZMQ.Context context =

Re: [zeromq-dev] Discuss: 0MQ releases and stability

2011-02-15 Thread Joshua Foster
My 2 cents Proposals: 1. Stop using topic branches for new development, use the master for this Normal development (safe features/bug fixes/etc) should be done on master. The master should be mostly stable which means quick, tested patches. Riskier features such as experimental

[zeromq-dev] ZMQ Crash from unknown DNS name

2011-01-25 Thread Joshua Foster
I am trying to setup a service with ZeroMQ that subscribes to a TCP endpoint that doesn't exist when the computer starts up. I am using the computer name as I don't know what the DHCP address will be. ZMQ crashes with the following assertion: Assertion failed: rc == 0

Re: [zeromq-dev] Regarding java binding of 0MQ.

2010-11-24 Thread Joshua Foster
Because the ZMQ bindings are really just a wrapper to provide the full ZMQ functionality, we would need to reimplement all of ZMQ in Java to get a PURE Java implementation. Joshua On 11/24/2010 1:42 PM, Sven Koebnick wrote: talking about Java-bindings, I wonder (expecting you to think about

Re: [zeromq-dev] Help on windows 7

2010-11-12 Thread Joshua Foster
What version of Visual Studio? The VS projects are for 2008. ZMQ builds out of the box for me. I then configure Visual Studio based on: http://www.zeromq.org/bindings:java If you are using the converted VS project in VS2010, just manually copy the libzmq.lib and and libzmq.pdb from the

Re: [zeromq-dev] Question about the PUBSUB design pattern when server restarts.

2010-11-11 Thread Joshua Foster
If you want the subscriber to pick up where it last left off, be sure to set the identity. The publisher is probably creating a new queue with the second subscriber, but leaving the previous queue open. The previous queue is the one that continues to grow (causing memory to increase). Joshua

Re: [zeromq-dev] SUB socket hangs after some time

2010-11-10 Thread Joshua Foster
I'm running it on OS X with 2.0.9 and I haven't seen the issue yet. I'll compile 2.0.10 and see if it happens later tonight. Not sure if this affects it, but numMessages should be volatile since you have multiple threads accessing it. If you want the ability to restart the subscriber without

Re: [zeromq-dev] SUB socket hangs after some time

2010-11-10 Thread Joshua Foster
on one machine but the whole program was used on multiple machines and was showing the same behavior. Oliver On 11/11/10 6:42 AM, Joshua Foster wrote: I'm running it on OS X with 2.0.9 and I haven't seen the issue yet. I'll compile 2.0.10 and see if it happens later tonight. Not sure

  1   2   >