program stuck in session.join()

Question

I am using a crossbar.io router with the below configuration, the C++ program seems to be stuck in session.join() call.

    {
       "controller": {
       },
       "workers": [
          {
             "type": "router",
             "realms": [
             {
                "name" : "thinqbot",
                "permissions": [
                            {
                               "uri": "*",
                   "join" : true,
                               "publish": true,
                               "subscribe": true,
                               "call": true,
                               "register": true
                            }
                         ]
             }
         ],
             "transports": [
                {
                   "type": "web",
                   "endpoint":
               {
                      "type": "tcp",
                      "port": 8080
                   },
                   "paths": {
                      "/": {
                         "type": "static",
                         "directory": ".."
                      },
                      "ws": {
                         "type": "websocket"
                      }
                   }
                },
            {
                   "type": "rawsocket",
                   "serializer" : "json",
                   "endpoint":
               {
                      "type": "unix",
              "path" : "/home/rk/router.sock"
                   }
            },
            {
                   "type": "rawsocket",
                   "serializer" : "json",
                   "endpoint":
               {
                      "type": "tcp",
                      "port": 8082
                   }
            }
             ]
          }
       ]
    }

Corresponding C++ code.

int 
main (int ac, char **av, char **env) 
{
   try 
   {
      asio::io_service io;
      tcp::socket socket(io);
      tcp::resolver resolver(io);
      auto endpoint_iterator = resolver.resolve({"127.0.0.1", "8082"});
      bool debug = true;
      autobahn::session<tcp::socket, tcp::socket> session(io, socket, socket, debug);
      future<void> session_future;
      std::cerr<<"\nTrying to connect to server ...";
      boost::asio::async_connect(socket, endpoint_iterator,
         [&](boost::system::error_code ec, tcp::resolver::iterator){
     if(!ec){
     std::cerr << "\nConnected to server" << endl;
     session.start();
     std::cerr<<"\nSession started.";
     session_future = session.join("realm1").then([&](future<uint64_t> s){
         std::cerr << "\nSession joined to realm with session ID " << s.get() << endl;
         auto c0 = session.call("com.thinqbot.ping")
         .then([](future<any> f){
             std::cerr<<"\nping() invoked successfully";
             });
         c0.wait();
         auto finish = when_all(std::move(c0));
         finish.then([&](decltype(finish)){
             session.publish("com.thinqbot.hello");
             std::cerr<<"\nhello event published";
             session.leave().then([&](future<string> reason){
                 std::cerr << "\nSession left [" << reason.get() << "]" << endl;
                 io.stop();
                 }).wait();
             });
         });
     } else {
               std::cerr << "\nCould not connect to server: " << ec.message() << endl;
            }
         }
      );
      io.run();
   }
   catch (std::exception& e) 
   {
      std::cerr << e.what() << endl;
      return 1;
   }
   return 0;
}

logs on the router. 2014-09-15 14:05:31+0530 [Controller 3457] Log opened.

2014-09-15 14:05:31+0530 [Controller 3457] ============================== Crossbar.io ==============================

2014-09-15 14:05:31+0530 [Controller 3457] Crossbar.io 0.9.7-6 starting

2014-09-15 14:05:31+0530 [Controller 3457] Automatically choosing optimal Twisted reactor

2014-09-15 14:05:31+0530 [Controller 3457] Running Twisted reactor twisted.internet.epollreactor.EPollReactor

2014-09-15 14:05:31+0530 [Controller 3457] Running on CPython using EPollReactor reactor

2014-09-15 14:05:31+0530 [Controller 3457] Starting from node directory /home/rk/work/wamp/.crossbar

2014-09-15 14:05:31+0530 [Controller 3457] Starting from local configuration '/home/rk/work/wamp/.crossbar/config.json'

2014-09-15 14:05:31+0530 [Controller 3457] No WAMPlets detected in enviroment.

2014-09-15 14:05:31+0530 [Controller 3457] Starting Router with ID 'worker1' ..

2014-09-15 14:05:31+0530 [Router 3460] Log opened.

2014-09-15 14:05:31+0530 [Router 3460] Running under CPython using EPollReactor reactor

2014-09-15 14:05:31+0530 [Router 3460] Entering event loop ..

2014-09-15 14:05:31+0530 [Controller 3457] Router with ID 'worker1' and PID 3460 started

2014-09-15 14:05:31+0530 [Controller 3457] Router 'worker1': realm 'realm1' started

2014-09-15 14:05:31+0530 [Router 3460] Site starting on 8080

2014-09-15 14:05:31+0530 [Controller 3457] Router 'worker1': transport 'transport1' started

2014-09-15 14:05:31+0530 [Router 3460] CrossbarWampRawSocketServerFactory starting on u'/home/rk/router.sock'

2014-09-15 14:05:31+0530 [Controller 3457] Router 'worker1': transport 'transport2' started

2014-09-15 14:05:31+0530 [Router 3460] CrossbarWampRawSocketServerFactory starting on 8082

2014-09-15 14:05:31+0530 [Controller 3457] Router 'worker1': transport 'transport3' started

Answer 1

There was a serialization mismatch between the client and router, router was expecting json and client was sending msgpack. The serializer needs to be changed to msgpack when using C++ client. Crossbar msgpack serializer needs to be installed. please add "debug": true in the transport stanza in configuration for more verbose error reporting.