ORE Studio 0.0.4
Loading...
Searching...
No Matches
mq_action_handler.hpp
1/* -*- mode: c++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*-
2 *
3 * Copyright (C) 2026 Marco Craveiro <marco.craveiro@gmail.com>
4 *
5 * This program is free software; you can redistribute it and/or modify it under
6 * the terms of the GNU General Public License as published by the Free Software
7 * Foundation; either version 3 of the License, or (at your option) any later
8 * version.
9 *
10 * This program is distributed in the hope that it will be useful, but WITHOUT
11 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
12 * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
13 * details.
14 *
15 * You should have received a copy of the GNU General Public License along with
16 * this program; if not, write to the Free Software Foundation, Inc., 51
17 * Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
18 *
19 */
20#pragma once
21
22#include "ores.scheduler.core/service/action_handler.hpp"
23
24namespace ores::scheduler::service {
25
32class mq_action_handler final : public action_handler {
33public:
34 [[nodiscard]] std::string_view action_type() const noexcept override {
35 return "send_mq_message";
36 }
37
38 boost::asio::awaitable<std::expected<void, std::string>>
39 execute(const action_context& ctx) override;
40};
41
42} // namespace ores::scheduler::service
Context passed to each action handler on job firing.
Definition action_handler.hpp:33
Abstract interface for job action execution.
Definition action_handler.hpp:44
Sends a message to an MQ queue on each job firing.
Definition mq_action_handler.hpp:32
boost::asio::awaitable< std::expected< void, std::string > > execute(const action_context &ctx) override
Execute the action for the given job.
Definition mq_action_handler.cpp:54
std::string_view action_type() const noexcept override
Returns the action_type string handled by this implementation.
Definition mq_action_handler.hpp:34