Ndtyjky

I am trying to get the ratchet push tutorial to work.

http://socketo.me/docs/push

I am doing exactly what the tutorial is saying but no messages will be received by my subscriber.

My server.php

<?php

require dirname(__DIR__) . '/vendor/autoload.php';



$loop   = ReactEventLoopFactory::create();

$pusher = new MyAppPusher;



// Listen for the web server to make a ZeroMQ push after an ajax request

$context = new ReactZMQContext($loop);

$pull = $context->getSocket(ZMQ::SOCKET_PULL);

$pull->bind('tcp://127.0.0.1:5555'); // Binding to 127.0.0.1 means the only client that can connect is itself

$pull->on('message', array($pusher, 'onBlogEntry'));



// Set up our WebSocket server for clients wanting real-time updates

$webSock = new ReactSocketServer('0.0.0.0:8080', $loop); // Binding to 0.0.0.0 means remotes can connect

$webServer = new RatchetServerIoServer(

    new RatchetHttpHttpServer(

        new RatchetWebSocketWsServer(

            new RatchetWampWampServer(

                $pusher

            )

        )

    ),

    $webSock

);



$loop->run();

My addblog.php

<?php

// post.php ???

// This all was here before  ;)

$entryData = array(

    'category' => 'kittensCategory'

  , 'title'    => 'Test'

  , 'article'  => 'Test'

  , 'when'     => time()

);



$context = new ZMQContext();

$socket = $context->getSocket(ZMQ::SOCKET_PUSH, 'my pusher');

$socket->connect("tcp://localhost:5555");



$socket->send(json_encode($entryData));

And my listener.html

    <script src="autobahn.js"></script>

<script>

    var conn = new ab.Session('ws://localhost:8080',

        function() {

            conn.subscribe('kittensCategory', function(topic, data) {

                // This is where you would add the new article to the DOM (beyond the scope of this tutorial)

                console.log('New article published to category "' + topic + '" : ' + data.title);

            });

        },

        function() {

            console.warn('WebSocket connection closed');

        },

        {'skipSubprotocolCheck': true}

    );

</script>

And my Pusher.php

<?php

namespace MyApp;

use RatchetConnectionInterface;

use RatchetWampWampServerInterface;



class Pusher implements WampServerInterface {

/**

 * A lookup of all the topics clients have subscribed to

 */

protected $subscribedTopics = array();



public function onSubscribe(ConnectionInterface $conn, $topic) {

  echo "Hello to: ".$topic;

    $this->subscribedTopics[$topic->getId()] = $topic;

}



/**

 * @param string JSON'ified string we'll receive from ZeroMQ

 */

public function onBlogEntry($entry) {

    $entryData = json_decode($entry, true);

echo "gallogallo";

    // If the lookup topic object isn't set there is no one to publish to

    if (!array_key_exists($entryData['category'], $this->subscribedTopics)) 

{

        return;

    }



    $topic = $this->subscribedTopics[$entryData['category']];



    // re-send the data to all the clients subscribed to that category

    $topic->broadcast($entryData);

}

I do not receive any errors or warnings.
When I try to call addblog.php nothing is happening and I do not understand why.

Any hints maybe? I am testing this with XAMPP and Windows 10.

I don't know why, but it is working very well on another system...