handle_method(#'basic.publish'{exchange    = XNameBin,
                               routing_key = RoutingKey,
                               mandatory   = Mandatory,
                               immediate   = Immediate},
              Content,
              State = #ch{virtual_host = VHostPath,
                          writer_pid = WriterPid}) ->
    XName = rabbit_misc:r(VHostPath, exchange, XNameBin),
    Exchange = rabbit_exchange:lookup_or_die(XName),
    QPids = rabbit_exchange:route(Exchange, RoutingKey),
    deliver(QPids, Mandatory, Immediate,
            #basic_message{exchange_name  = XName,
                           routing_key    = RoutingKey,
                           content        = Content},
            WriterPid),
    {noreply, State};