old_contents: # Copyright (c) 2013 Mirantis Inc.
  #
  # Licensed under the Apache License, Version 2.0 (the "License");
  # you may not use this file except in compliance with the License.
  # You may obtain a copy of the License at
  #
  #    http://www.apache.org/licenses/LICENSE-2.0
  #
  # Unless required by applicable law or agreed to in writing, software
  # distributed under the License is distributed on an "AS IS" BASIS,
  # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
  # implied.
  # See the License for the specific language governing permissions and
  # limitations under the License.
  
  import anyjson
  import logging
  
  LOG = logging.getLogger("murano-common.messaging")
  
  
  class Message(object):
      def __init__(self, connection=None, message_handle=None):
          self._body = None
          self._connection = connection
          self._message_handle = message_handle
          if message_handle:
              self.id = message_handle.header.get('message_id')
          else:
              self.id = None
  
          try:
              if message_handle:
                  self.body = anyjson.loads(message_handle.body)
              else:
                  self.body = None
          except ValueError as e:
              self.body = None
              LOG.exception(e)
  
      @property
      def body(self):
          return self._body
  
      @body.setter
      def body(self, value):
          self._body = value
  
      @property
      def id(self):
          return self._id
  
      @id.setter
      def id(self, value):
          self._id = value or ''
  
      def ack(self):
          self._message_handle.ack()
  
new_contents: # Copyright (c) 2013 Mirantis Inc.
  #
  # Licensed under the Apache License, Version 2.0 (the "License");
  # you may not use this file except in compliance with the License.
  # You may obtain a copy of the License at
  #
  #    http://www.apache.org/licenses/LICENSE-2.0
  #
  # Unless required by applicable law or agreed to in writing, software
  # distributed under the License is distributed on an "AS IS" BASIS,
  # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
  # implied.
  # See the License for the specific language governing permissions and
  # limitations under the License.
  
  import anyjson
  import logging
  
  LOG = logging.getLogger("murano-common.messaging")
  
  
  class Message(object):
      def __init__(self, connection=None, message_handle=None):
          self._body = None
          self._connection = connection
          self._message_handle = message_handle
          if message_handle:
              self.id = message_handle.headers.get('message_id')
          else:
              self.id = None
  
          try:
              if message_handle:
                  self.body = anyjson.loads(message_handle.body)
              else:
                  self.body = None
          except ValueError as e:
              self.body = None
              LOG.exception(e)
  
      @property
      def body(self):
          return self._body
  
      @body.setter
      def body(self, value):
          self._body = value
  
      @property
      def id(self):
          return self._id
  
      @id.setter
      def id(self, value):
          self._id = value or ''
  
      def ack(self):
          self._message_handle.ack()
  
subject: Correct murano-agent reference to message headers