@callback publish_message(map() | binary()) ::
  :ok | {:error, reason :: :blocked | :closing}