@Override
    protected boolean xsend (Msg msg_, int flags_)
    {   
        byte[] data = msg_.data(); 
        // Malformed subscriptions.
        if (data.length < 1 || (data[0] != 0 && data[0] != 1)) {
            return false;
        }
        
        // Process the subscription.
        if (data[0] == 1) {
            if (subscriptions.add (data , 1))
                return dist.send_to_all (msg_, flags_);
        }
        else {
            if (subscriptions.rm (data, 1))
                return dist.send_to_all (msg_, flags_);
        }

        return true;
    }