PHP Example

PECL Stomp extension

This example requires PECL STOMP package. To install, type "pecl install stomp".

<?php
// Network Rail Stomp Handler example by ian13
$server = "tcp://datafeeds.networkrail.co.uk:61618";
$user = "username";
$password = "password";
$channel = "TRAIN_MVT_ALL_TOC";

$con = new Stomp($server, $user, $password);
if (!$con) {
   die('Connection failed: ' . stomp_connect_error());
}
$con->subscribe("/topic/" . $channel);
while($con){
   if ($con->hasFrame()){
       $msg = $con->readFrame();
       foreach (json_decode($msg->body) as $event) {
         // do stuff with $event here
       }
       $con->ack($msg);
   }
}
die('Connection lost: ' . time());
?>

Optionally, you can specify a client-id header, which will ensure message persistence (if enabled on the server) and queue messages whilst your subscriber is offline.

$con = new Stomp($server, $user, $password, array('client-id' => 'somename');

Further documentation on the PHP Stomp library is available at http://www.php.net/manual/en/class.stomp.php

Stomp library

An alternative Stomp client is available from Fuse Source. It has some minor issues, such as injecting spaces in the username/password, and sleeping on message retrieval.

A fixed version can be obtained from here or here.

 require_once('Stomp.php');
 
 $con = new Stomp('tcp://datafeeds.networkrail.co.uk:61618/');
 $con->clientId = 'someclient';
 $con->connect($username, $password);
 
 $con->subscribe("/topic/TRAIN_MVT_ALL_TOC");
 $msg = $con->readFrame();
 
 if ($msg != null) {
   foreach (json_decode($msg->body) as $event) {
     // do stuff with $event here
   }
   $con->ack(msg);
 }
 
 $con->disconnect();