Found the solution, just in case anyone gets in the same spot as I was
earlier, the problem is with the incompatibility between zmq 2.2 and zmq
4.0.4, although zmq website advertises zmq latest version stating it is
backwards compatible it is NOT. when I stepped down my zmq version to 3.2.5
my scala and c++ zmq programs started talking.
On Monday, March 9, 2015 at 3:50:54 PM UTC-7, ankit master wrote:
>
> Hello,
>
> I am trying to get c++(publisher) to my scala(subscriber ) with little
> luck, I tried using both akka-zeromq and scala-zeromq to get this working
> with little luck. however, my program *does work* with *scala being the
> publisher and c++ being the subscriber (but not other way around)*, can
> anyone please help me figure out what I am doing wrong here !!
>
> The following code will not work, I dont get any messages over on scala
> side, will be very grateful of any help here.
>
> ///////////// Scala Code , zmq version 2.2
>
> import akka.actor._
> import org.zeromq.ZMQ
> import org.zeromq.ZMQ._
>
> object ZMQWithoutAkkaExtensionApp extends App {
> val numberOfMessages = 10
>
> val system = ActorSystem("zmq")
> val subscriber = system.actorOf(Props[Sub])
> subscriber ! "start"
> }
>
>
> class Sub extends Actor {
> var contextZMQ: ZMQ.Context = null
> var subscriberSocket: ZMQ.Socket = null
>
> override def preStart = {
> contextZMQ = ZMQ.context(1)
> subscriberSocket = contextZMQ.socket(ZMQ.SUB)
> subscriberSocket.connect("tcp://localhost:1234")
> subscriberSocket.subscribe("".getBytes())
> Thread.sleep(1000)
> }
>
> def receive = {
> case msg => handleMessages
> }
>
> private def handleMessages = {
> while (true) {
> println("---------------------------------------------")
> val request = subscriberSocket.recv(0)
> println(s"request : $request")
> val data = new String(request)
> println(s"data : $data" )
> }
> }
> }
>
>
>
> //////// C++ Code , zmq version 4.0.4
>
>
> #include <zmq.hpp>
> #include <string>
> #include <iostream>
> #include <windows.h>
> #include <thread>
>
> using namespace std;
> void Pub()
> {
> cout << " Running Pub " << endl;
>
> zmq::context_t context(1);
> zmq::socket_t publisher(context, ZMQ_PUB);
> publisher.bind("tcp://*:1234");
>
> Sleep(4000);
> cout << " awake again " << endl;
>
> int cc = 0;
> while (1) {
> // Write two messages, each with an envelope and content
> string msg = " hello ";
> zmq::message_t req(5);
> memcpy((void *)req.data(), "World", 5);
>
> publisher.send(req);
> cout << cc++ << endl;
>
> Sleep(1000);
> }
> }
>
> int main()
> {
>
> Pub();
>
> return 0;
> }
>
>
> Thank you
> Sincerely,
> AVM
>
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
