/
atombpmn
/
atom-engine
Обзор
Документация
Войти
/
atombpmn
/
atom-engine
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
master
src/process/message_callback_manager_interface.go
38 строк
1 KB
sembaev-a-a
Initial commit
18 ноя 2025, 03:22
18 ноя 2025, 03:22
8f621c0
Код
Авторство
О чём код?
/* This file is part of the AtomBPMN (R) project. Copyright (c) 2025 Matreska Market LLC (ООО «Matreska Market»). Authors: Matreska Team. This project is dual-licensed under AGPL-3.0 and AtomBPMN Commercial License. */ package process import ( "atom-engine/src/core/models" ) // MessageCallbackManagerInterface handles message operations // Интерфейс менеджера сообщений type MessageCallbackManagerInterface interface { // Message callback operations HandleMessageCallback(messageID, messageName, correlationKey, tokenID string, variables map[string]interface{}) error CheckBufferedMessages(messageName, correlationKey string) (*models.BufferedMessage, error) ProcessBufferedMessage(message *models.BufferedMessage, token *models.Token) error // Message subscription operations CreateMessageSubscription(subscription *models.ProcessMessageSubscription) error DeleteMessageSubscription(subscriptionID string) error PublishMessage( messageName, correlationKey string, variables map[string]interface{}, ) (*models.MessageCorrelationResult, error) PublishMessageWithElementID( messageName, correlationKey, elementID string, variables map[string]interface{}, ) (*models.MessageCorrelationResult, error) CorrelateMessage( messageName, correlationKey, processInstanceID string, variables map[string]interface{}, ) (*models.MessageCorrelationResult, error) }