diff options
| -rw-r--r-- | yt/yt/client/api/rpc_proxy/api_service_proxy.h | 1 | ||||
| -rw-r--r-- | yt/yt/client/driver/driver.cpp | 1 |
2 files changed, 2 insertions, 0 deletions
diff --git a/yt/yt/client/api/rpc_proxy/api_service_proxy.h b/yt/yt/client/api/rpc_proxy/api_service_proxy.h index 6270a25e6b1..0f3f9f04543 100644 --- a/yt/yt/client/api/rpc_proxy/api_service_proxy.h +++ b/yt/yt/client/api/rpc_proxy/api_service_proxy.h @@ -87,6 +87,7 @@ public: // Queues DEFINE_RPC_PROXY_METHOD(NRpcProxy::NProto, AdvanceConsumer); DEFINE_RPC_PROXY_METHOD(NRpcProxy::NProto, PullQueue); + // COMPAT(nadya73): For compatability with old versions of clients. DEFINE_RPC_PROXY_METHOD_GENERIC(PullConsumer, NRpcProxy::NProto::TReqPullQueueConsumer, NRpcProxy::NProto::TRspPullQueueConsumer); DEFINE_RPC_PROXY_METHOD(NRpcProxy::NProto, PullQueueConsumer); DEFINE_RPC_PROXY_METHOD(NRpcProxy::NProto, RegisterQueueConsumer); diff --git a/yt/yt/client/driver/driver.cpp b/yt/yt/client/driver/driver.cpp index 2f9db97950e..0d6488193f8 100644 --- a/yt/yt/client/driver/driver.cpp +++ b/yt/yt/client/driver/driver.cpp @@ -349,6 +349,7 @@ public: REGISTER (TUnregisterQueueConsumerCommand, "unregister_queue_consumer", Null, Structured, true, false, ApiVersion4); REGISTER (TListQueueConsumerRegistrationsCommand, "list_queue_consumer_registrations", Null, Structured, false, false, ApiVersion4); REGISTER (TPullQueueCommand, "pull_queue", Null, Tabular, false, true , ApiVersion4); + // COMPAT(nadya73): for compatibility with old versions of clients. REGISTER (TPullQueueConsumerCommand, "pull_consumer", Null, Tabular, false, true , ApiVersion4); REGISTER (TPullQueueConsumerCommand, "pull_queue_consumer", Null, Tabular, false, true , ApiVersion4); REGISTER (TAdvanceConsumerCommand, "advance_consumer", Null, Structured, true, false, ApiVersion4); |