'Send message to paired agent listening over zmq.'

def act(self):

    if (self.observation is not None):
        text = json.dumps(sanitize(self.observation))
        self.socket.send_unicode(text)
    reply = self.socket.recv_unicode()
    return json.loads(reply)
