summaryrefslogtreecommitdiff
path: root/extlib/Stomp/Message
diff options
context:
space:
mode:
Diffstat (limited to 'extlib/Stomp/Message')
-rw-r--r--extlib/Stomp/Message/Map.php12
1 files changed, 5 insertions, 7 deletions
diff --git a/extlib/Stomp/Message/Map.php b/extlib/Stomp/Message/Map.php
index 288456a84..38a32c56c 100644
--- a/extlib/Stomp/Message/Map.php
+++ b/extlib/Stomp/Message/Map.php
@@ -24,30 +24,28 @@ require_once 'Stomp/Message.php';
* Message that contains a set of name-value pairs
*
* @package Stomp
- * @author Dejan Bosanac <dejan@nighttale.net>
- * @version $Revision: 23 $
*/
-class Stomp_Message_Map extends Stomp_Message
+class StompMessageMap extends StompMessage
{
public $map;
/**
* Constructor
*
- * @param Stomp_Frame|string $msg
+ * @param StompFrame|string $msg
* @param array $headers
*/
function __construct ($msg, $headers = null)
{
- if ($msg instanceof Stomp_Frame) {
+ if ($msg instanceof StompFrame) {
$this->_init($msg->command, $msg->headers, $msg->body);
- $this->map = json_decode($msg->body);
+ $this->map = json_decode($msg->body, true);
} else {
$this->_init("SEND", $headers, $msg);
if ($this->headers == null) {
$this->headers = array();
}
- $this->headers['amq-msg-type'] = 'MapMessage';
+ $this->headers['transformation'] = 'jms-map-json';
$this->body = json_encode($msg);
}
}