| 488 | class TProtocol: public IProtocol { |
| 489 | public: |
| 490 | THandleRef ScheduleRequest(const TMessage& msg, IOnRecv* fallback, TServiceStatRef& ss) override { |
| 491 | return Singleton<TNetLibaBus>()->Schedule(msg, fallback, ss); |
| 492 | } |
| 493 | |
| 494 | NNeh::IRequesterRef CreateRequester(IOnRequest* cb, const TParsedLocation& loc) override { |
| 495 | TRequesterRef r(new TRequester(cb, loc.GetPort())); |