def send_local_subs_to_route
      ObjectSpace.each_object(NATSD::Connection) do |c|
        next if c.closing? || c.type != 'Client'
        c.subscriptions.each_value do |sub|
          queue_data(NATSD::Server.route_sub_proto(sub))
        end
      end
    end
def send_local_subs_to_route
      ObjectSpace.each_object(NATSD::Connection) do |c|
        next if c.closing? || c.type != 'Client'
        c.subscriptions.each_value do |sub|
          queue_data(NATSD::Server.route_sub_proto(sub))
        end
      end
    end
TODO: Make sure max_requested is also propogated on reconnect