Re: [zeromq-dev] PUB/SUB appears to be 'missing' first byte 3.2.2

2013-05-21 Thread Mark Sutheran
Mark From: Siam Rafiee To: ZeroMQ development list Sent: Tuesday, 21 May 2013, 16:48 Subject: Re: [zeromq-dev] PUB/SUB appears to be 'missing' first byte 3.2.2 Mark, I've experienced something similar to you before - and in my case it came down t

Re: [zeromq-dev] PUB/SUB appears to be 'missing' first byte 3.2.2

2013-05-21 Thread Siam Rafiee
l); > > System.out.println("Non-blocking pub:\t" + Arrays.toString(TEST_DATA)); > > publisher.send(TEST_DATA,ZMQ.NOBLOCK); > > Thread.sleep(1000l); > > } > > Thread.sleep(500l); > > > > } catch (Exception e) { > > e.printStackTrace(); > > } >

Re: [zeromq-dev] PUB/SUB appears to be 'missing' first byte 3.2.2

2013-05-20 Thread Trevor Bernard
ide > public void run() { > System.out.println("SubscriptionDataHandler thread starting"); > while (true) { > final byte[] rec = subscriber.recv(0); > System.out.println("...received data:\t" + Arrays.toString(rec)); > } > } > } > } > > > _

Re: [zeromq-dev] PUB/SUB appears to be 'missing' first byte 3.2.2

2013-05-19 Thread Mark Sutheran
om: Pieter Hintjens To: Mark Sutheran ; ZeroMQ development list Sent: Sunday, 19 May 2013, 17:04 Subject: Re: [zeromq-dev] PUB/SUB appears to be 'missing' first byte 3.2.2 Hi Mark, Would you provide a minimal test case that demonstrates the problem? Thanks Pieter On Sat, Ma

Re: [zeromq-dev] PUB/SUB appears to be 'missing' first byte 3.2.2

2013-05-19 Thread Pieter Hintjens
Hi Mark, Would you provide a minimal test case that demonstrates the problem? Thanks Pieter On Sat, May 18, 2013 at 6:56 PM, Mark Sutheran wrote: > Hi, > > I appear to have a issue with PUB/SUB apparently 'dropping' the first byte. > > Setup: > * Basic PUB/SUB running on same machine over TCP/

[zeromq-dev] PUB/SUB appears to be 'missing' first byte 3.2.2

2013-05-18 Thread Mark Sutheran
Hi, I appear to have a issue with PUB/SUB apparently 'dropping' the first byte. Setup:   * Basic PUB/SUB running on same machine over TCP/localhost.   * Message has first 4 bytes as subscription id, rest payload Problem:  * On dev box runs fine  * On prod box the subscriber sees no messages   *