aboutsummaryrefslogtreecommitdiffstats
path: root/ydb/core/ymq/actor/actor.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'ydb/core/ymq/actor/actor.cpp')
-rw-r--r--ydb/core/ymq/actor/actor.cpp106
1 files changed, 53 insertions, 53 deletions
diff --git a/ydb/core/ymq/actor/actor.cpp b/ydb/core/ymq/actor/actor.cpp
index d2ebd7cf50..3fe2a78735 100644
--- a/ydb/core/ymq/actor/actor.cpp
+++ b/ydb/core/ymq/actor/actor.cpp
@@ -1,82 +1,82 @@
-#include "actor.h"
-#include "action.h"
+#include "actor.h"
+#include "action.h"
#include "ping.h"
#include "proxy_actor.h"
-
+
#include <util/system/defaults.h>
-using namespace NKikimrTxUserProxy;
-
+using namespace NKikimrTxUserProxy;
+
namespace NKikimr::NSQS {
-
-class TUnimplementedRequestActor
- : public TActionActor<TUnimplementedRequestActor>
-{
-public:
+
+class TUnimplementedRequestActor
+ : public TActionActor<TUnimplementedRequestActor>
+{
+public:
TUnimplementedRequestActor(const NKikimrClient::TSqsRequest& req, THolder<IReplyCallback> cb)
: TActionActor(req, EAction::Unknown, std::move(cb))
- {
- Response_.MutableGetQueueUrl()->SetRequestId(RequestId_);
- }
-
-private:
+ {
+ Response_.MutableGetQueueUrl()->SetRequestId(RequestId_);
+ }
+
+private:
void DoAction() override {
SendReplyAndDie();
- }
-
+ }
+
TError* MutableErrorDesc() override {
return Response_.MutableGetQueueUrl()->MutableError();
}
- TString DoGetQueueName() const override {
- return TString();
- }
-};
-
+ TString DoGetQueueName() const override {
+ return TString();
+ }
+};
+
IActor* CreateActionActor(const NKikimrClient::TSqsRequest& req, THolder<IReplyCallback> cb) {
Y_VERIFY(req.GetRequestId());
-
-#define REQUEST_CASE(action) \
+
+#define REQUEST_CASE(action) \
case NKikimrClient::TSqsRequest::Y_CAT(k, action): { \
extern IActor* Y_CAT(Y_CAT(Create, action), Actor)(const NKikimrClient::TSqsRequest& sourceSqsRequest, THolder<IReplyCallback> cb); \
return Y_CAT(Y_CAT(Create, action), Actor)(req, std::move(cb)); \
- }
-
- switch (req.GetRequestCase()) {
- REQUEST_CASE(ChangeMessageVisibility)
- REQUEST_CASE(ChangeMessageVisibilityBatch)
- REQUEST_CASE(CreateQueue)
- REQUEST_CASE(CreateUser)
- REQUEST_CASE(DeleteMessage)
- REQUEST_CASE(DeleteMessageBatch)
- REQUEST_CASE(DeleteQueue)
+ }
+
+ switch (req.GetRequestCase()) {
+ REQUEST_CASE(ChangeMessageVisibility)
+ REQUEST_CASE(ChangeMessageVisibilityBatch)
+ REQUEST_CASE(CreateQueue)
+ REQUEST_CASE(CreateUser)
+ REQUEST_CASE(DeleteMessage)
+ REQUEST_CASE(DeleteMessageBatch)
+ REQUEST_CASE(DeleteQueue)
REQUEST_CASE(DeleteQueueBatch)
- REQUEST_CASE(DeleteUser)
+ REQUEST_CASE(DeleteUser)
REQUEST_CASE(ListPermissions)
- REQUEST_CASE(GetQueueAttributes)
+ REQUEST_CASE(GetQueueAttributes)
REQUEST_CASE(GetQueueAttributesBatch)
- REQUEST_CASE(GetQueueUrl)
- REQUEST_CASE(ListQueues)
- REQUEST_CASE(ListUsers)
+ REQUEST_CASE(GetQueueUrl)
+ REQUEST_CASE(ListQueues)
+ REQUEST_CASE(ListUsers)
REQUEST_CASE(ModifyPermissions)
- REQUEST_CASE(PurgeQueue)
+ REQUEST_CASE(PurgeQueue)
REQUEST_CASE(PurgeQueueBatch)
- REQUEST_CASE(ReceiveMessage)
- REQUEST_CASE(SendMessage)
- REQUEST_CASE(SendMessageBatch)
- REQUEST_CASE(SetQueueAttributes)
+ REQUEST_CASE(ReceiveMessage)
+ REQUEST_CASE(SendMessage)
+ REQUEST_CASE(SendMessageBatch)
+ REQUEST_CASE(SetQueueAttributes)
REQUEST_CASE(ListDeadLetterSourceQueues)
REQUEST_CASE(CountQueues)
-
-#undef REQUEST_CASE
-
- case NKikimrClient::TSqsRequest::REQUEST_NOT_SET:
+
+#undef REQUEST_CASE
+
+ case NKikimrClient::TSqsRequest::REQUEST_NOT_SET:
return new TUnimplementedRequestActor(req, std::move(cb));
- }
-
- Y_FAIL();
-}
-
+ }
+
+ Y_FAIL();
+}
+
IActor* CreateProxyActionActor(const NKikimrClient::TSqsRequest& req, THolder<IReplyCallback> cb, bool enableQueueLeader) {
if (enableQueueLeader && TProxyActor::NeedCreateProxyActor(req)) {
return new TProxyActor(req, std::move(cb));