Изменения документа Движок cccc1808. ProcessEngine
Редактировал(а) Alexandr Fokin 2026/04/27 13:28
От версии 27.5
отредактировано Alexandr Fokin
на 2026/04/10 20:15
на 2026/04/10 20:15
Изменить комментарий:
К данной версии нет комментариев
К версии 27.1
отредактировано Alexandr Fokin
на 2026/04/10 19:43
на 2026/04/10 19:43
Изменить комментарий:
Загрузить новое изображение TransactionOutbox. Sequence.jpg
Сводка
-
Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Содержимое
-
... ... @@ -101,13 +101,8 @@ 101 101 ))) 102 102 |(% style="width:32px" %)2|(% style="width:171px" %)Transaction outbox stream process.|(% style="width:1066px" %)[[image:TransactionOutbox. Sequence.jpg]] 103 103 |(% style="width:32px" %)3|(% style="width:171px" %)Stream trigger|(% style="width:1066px" %)((( 104 -|(% style="width:94px" %) |(% style="width:1002px" %)((( 105 -* Позволяет убрать лишние запросы пробуждения процесса (когда он и так запущен). 106 -* Позволяет полностью убрать задержку после остановки процесса (если есть новое сообщения, то он сразу же будет пробужден). 107 -За счет того, что триггер точно знает, что есть новые сообщения и процесс только что уснул. 108 -* Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение). 109 -* Вводит дополнительное состояние в триггер: максимальный offset сообщения, максимальный offset обработанного процессом сообщения, флаг состояния сна процесса. 110 -))) 104 +|(% style="width:94px" %) |(% style="width:1002px" %)Позволяет убрать лишние запросы пробуждения процесса (когда он и так запущен). 105 +Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение). 111 111 |(% style="width:94px" %)Алгоритм триггера.|(% style="width:1002px" %)((( 112 112 * При получении события о засыпании процесса: 113 113 Фиксирует смещение процесса обработки и сравнивает со смещением сообщения. ... ... @@ -117,6 +117,7 @@ 117 117 Если процесс не спит (по флагу в триггере), то ничего не делает. 118 118 Если процесс спит (по флагу), то пробуждает процесс. 119 119 115 + 120 120 Отслеживает смещение обработки процесса и последнего события. 121 121 Ожидает от процесса события о том, что он все обработал, его последнее смещение и он идет спать. 122 122 Если есть сообщения со смещением больше чем указал процесс, то делает гарантированное пробуждение процесса. ... ... @@ -126,26 +126,4 @@ 126 126 ))) 127 127 ))) 128 128 129 ----- 130 - 131 -==== Внутренние ссылки: ==== 132 - 133 -====== Дочерние страницы: ====== 134 - 135 -{{children/}} 136 - 137 -====== Обратные ссылки: ====== 138 - 139 -{{velocity}} 140 -#set ($links = $doc.getBacklinks()) 141 -#if ($links.size() > 0) 142 - #foreach ($docname in $links) 143 - #set ($rdoc = $xwiki.getDocument($docname).getTranslatedDocument()) 144 - * [[$escapetool.xml($rdoc.fullName)]] 145 - #end 146 -#else 147 - No back links for this page! 148 -#end 149 -{{/velocity}} 150 - 151 ----- 125 +