This is a good observation Marcin, but I can't find any equivalent in JeroMQ. This example does employ some type of filter ( http://zguide.zeromq.org/java:wuclient) but I'm not sure if it's the same thing as zmq_setsockopt.... Is there someone who is an expert in jeromq that I can talk to?
On Tue, Jul 21, 2015 at 3:00 PM, Marcin Romaszewicz <[email protected]> wrote: > Subscribers by default (at least in the C++ version of ZMQ) do not > subscribe to anything. You need to call zmq_setsockopt(ZMQ_SUBSCRIBE...) to > establish a subscription. You probably have to do something similar on the > subscriber socket in jeroMQ > > On Tue, Jul 21, 2015 at 2:21 PM, Areeb Mehmood < > [email protected]> wrote: > >> Santosh, >> >> You mean add filtering on the publisher side? >> >> - Areeb M. >> >> On Tue, Jul 21, 2015 at 2:19 PM, <[email protected]> wrote: >> >>> *Dell Customer Communication* >>> >>> Please add a filtering for the required events and try. Sorry, I don’t >>> know much about jeroMQ as I use CZMQ library, hence I don’t know the exact >>> syntax for filtering in jeroMQ. >>> >>> >>> >>> Thanks, >>> >>> Santosh >>> >>> >>> >>> >>> >>> *From:* [email protected] [mailto: >>> [email protected]] *On Behalf Of *Areeb Mehmood >>> *Sent:* Tuesday, July 21, 2015 4:15 PM >>> *To:* [email protected] >>> *Subject:* [zeromq-dev] Setting an Android Device as a Subscriber >>> >>> >>> >>> Hello ZMQ, >>> >>> Using Android Studio, and the jeromq-0.3.5.jar library, I am attempting >>> to build a mobile application that will subscribe to a publisher that is >>> dumping string messages. >>> >>> Here is what my code looks like on the Subscriber side: >>> >>> Runnable runnable = *new *Runnable() >>> { >>> *public void *run() >>> { >>> ZMQ.Context context = ZMQ.*context*(1); >>> ZMQ.Socket subscriber = context.socket(ZMQ.*SUB*); >>> subscriber.connect(*"tcp://192.168.1.36:6666 >>> <http://192.168.1.36:6666>"*); >>> String testcase = subscriber.recvStr(0); >>> TextView strDisplay = (TextView) >>> findViewById(R.id.*stringDisplay*); >>> Log.*i*(*"Output"*, *"the testcase recieved something"*); >>> strDisplay.setText(testcase); >>> Log.*i*(*"Output"*, *"strDisplay was set"*); >>> } >>> }; >>> >>> The code hangs at: >>> >>> String testcase = subscriber.recvStr(0); >>> >>> I am not sure how to resolve this issue as I have tried various things. >>> The IP Address and Port are correct, and the publisher is running. I can >>> also provide the publisher side code if you need. >>> >>> _______________________________________________ >>> zeromq-dev mailing list >>> [email protected] >>> http://lists.zeromq.org/mailman/listinfo/zeromq-dev >>> >>> >> >> _______________________________________________ >> zeromq-dev mailing list >> [email protected] >> http://lists.zeromq.org/mailman/listinfo/zeromq-dev >> >> > > _______________________________________________ > zeromq-dev mailing list > [email protected] > http://lists.zeromq.org/mailman/listinfo/zeromq-dev > >
_______________________________________________ zeromq-dev mailing list [email protected] http://lists.zeromq.org/mailman/listinfo/zeromq-dev
