[zeromq-dev] polling in jeromq

Yu Dongmin miniway at gmail.com
Sun Jul 21 20:01:12 CEST 2013


Hi,

Hmm, I'm surprised that jzmq works without poller.poll(). poller.poll() non only controls a timeout or set readiness.

Thanks
Min

On Jul 20, 2013, at 3:47 AM, ashwini ramamurthy <ashwini.ram21 at gmail.com> wrote:

> Hi , 
> 
> Thanks,it worked. Could you please explain how it made a difference? Doesn't poller.poll define a timeout so that it does not wait infinitely? And also when i used polling in jzmq i did not use poller.poll() but it still worked. Is this specific to jeromq?
> 
> Regards,
> Ashwini
> 
> 
> On Thu, Jul 18, 2013 at 5:59 PM, Yu Dongmin <miniway at gmail.com> wrote:
> Hi,
> 
> You need to call poller.poll(timeout) before you call poller.pollin
> 
> Thanks
> Min
> 
> On Jul 19, 2013, at 12:10 AM, ashwini ramamurthy <ashwini.ram21 at gmail.com> wrote:
> 
>> Hi ,
>> 
>> I am learning to use zeromq polling in android . I am polling on a req socket and a sub socket in the android program(client). So that this client can receive both reply messages from the server and also published messages.
>> 
>> My polling is not working. Both the req socket and the publish socket does not get polled in. If i don't use polling both the sockets receive the message. 
>> 
>> I tried searching online but could not find anything relevant. 
>> 
>> The client code is this :
>> 
>> public void run()
>>     {
>>     	ZMQ.Context context = ZMQ.context(1);
>>         ZMQ.Socket reqsocket = context.socket(ZMQ.REQ);
>>         ZMQ.Socket subsocket =context.socket(ZMQ.SUB);
>>         reqsocket.connect("tcp://10.186.3.174:8081");
>>         subsocket.connect("tcp://10.186.3.174:8083");
>>         subsocket.subscribe("".getBytes());
>>         byte[] receivedmessage;
>>         Poller poller=context.poller();
>>         poller.register(reqsocket,Poller.POLLIN);
>>         poller.register(subsocket,Poller.POLLIN);
>>         
>>         reqsocket.send(msg.getBytes(),0); 
>>        
>>         while(!Thread.currentThread().isInterrupted())
>>          {
>>         	
>>           	if(poller.pollin(0))
>>          	{
>>         		receivedmessage=s.recv(0);
>>         		
>>         	}
>>               if(poller.pollin(0))
>>               {
>>         		receivedmessage=subsocket.recv(0);
>>         	   
>>               }
>>        }
>>         s.close();
>>         context.term();
>>         
>> }
>> 
>> Am i missing out something or doing something wrong? I don't get any errors. 
>> 
>> Thanks
>> Ashwini
>> 
>> 
>> _______________________________________________
>> zeromq-dev mailing list
>> zeromq-dev at lists.zeromq.org
>> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
> 
> 
> _______________________________________________
> zeromq-dev mailing list
> zeromq-dev at lists.zeromq.org
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
> 
> 
> _______________________________________________
> zeromq-dev mailing list
> zeromq-dev at lists.zeromq.org
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev

-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.zeromq.org/pipermail/zeromq-dev/attachments/20130722/82bb5f33/attachment.htm>


More information about the zeromq-dev mailing list