protected function getDriverForMessage($message)
    {
        $this->loadRegisteredDrivers();
        foreach ($this->drivers as $driver) {
            if ($driver->acceptMessage($message))
                return $driver;
        }

        throw new \Exception('No driver found to decode message of type: ' . get_class($message));
    }