Moved DSNs around

davedevelopment · Dec 2, 2011 · 99a8c7c · 99a8c7c
1 parent 0ebb240
commit 99a8c7c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/app.php b/app.php
@@ -40,11 +40,12 @@
     }
 });
 
-$app['dispatcher.queue.dsn'] = 'tcp://localhost:5567';
+$app['dispatcher.queue.pub.dsn'] = 'tcp://localhost:5567';
+$app['dispatcher.queue.sub.dsn'] = 'tcp://localhost:5566';
 $app['dispatcher.queue.pub'] = $app->share(function($c) {
     $ctx = new ZMQContext();
     $send = $ctx->getSocket(ZMQ::SOCKET_PUSH);
-    $send->connect($c['dispatcher.queue.dsn']);
+    $send->connect($c['dispatcher.queue.pub.dsn']);
     return $send;
 });
 
@@ -141,7 +142,7 @@
     $app['dispatcher']->dispatch('blog.comments.new', $event);
 
     return new Response(
-        json_encode($comment), 
+        json_encode($comment) . "\n", 
         201, 
         array(
             'Content-type' => 'application/json',

diff --git a/refire.php b/refire.php
@@ -16,7 +16,7 @@
 $ctx = new ZMQContext();
 $sub = $ctx->getSocket(ZMQ::SOCKET_SUB);
 $sub->setSockOpt(ZMQ::SOCKOPT_SUBSCRIBE, '');
-$sub->connect('tcp://localhost:5566');
+$sub->connect($app['dispatcher.queue.sub.dsn']);
 $poll = new ZMQPoll();
 $poll->add($sub, ZMQ::POLL_IN);
 $read = $wri = array();