public function emit(Message $message, $messageCode)
    {
        $payload = $this->encodeMessage($message, $messageCode);
        $stream  = $this->connection->createStream();

        return $this->connection->send($payload, $stream);
    }