configs and comms

[CBFWR.git] / libcbfwr / comms.php

diff --git a/libcbfwr/comms.php b/libcbfwr/comms.php
index b1195c9..db0215e 100644 (file)
--- a/libcbfwr/comms.php
+++ b/libcbfwr/comms.php
@@ -37,11 +37,18 @@ class Comms {
        
        function waitForMessage()
        {
+               global $MESSAGE_KEY, $LOCKING_KEY, $STORE_KEY;
+               $queue = msg_get_queue($MESSAGE_KEY);
+               msg_receive($queue, 0, $msgtype, 1024, $msg);
                
+               return $msg;
        }
        
-       function sendMessage()
+       function sendMessage($msg)
        {
+               global $MESSAGE_KEY, $LOCKING_KEY, $STORE_KEY;
+               $queue = msg_get_queue($MESSAGE_KEY);
+               msg_send($queue, 1, $msg);
                
        }