كيف يمكنني مواصلة عملية تدفق سالولز عندما أتلقى رسالة JMS؟

https://stackoverflow.com/questions/3282933

17-09-2020
|

سؤال

لدي تدفق بسيط للغاية، تبدأ رسالة JMS عملية تتلقى قائمة بالكائنات.تكرار في هذه القائمة وإرسال رسالة JMS إلى مكون لمعالجة الكائن في القائمة.يحتاج هذا المكون إلى إرسال إشعار إكمال مرة أخرى إلى عملية التدفق حتى تتمكن من الاستمرار.هل لدى أي شخص أي فكرة عن كيف يمكن تحقيق ذلك؟

شكرا.

المحلول

كيف يمكنك تنفيذ إرسال هذه الرسالة؟باستخدام عقدة عنصر العمل مخصص؟أرى خياران:

إذا كنت تتوقع دائما رسالة JMS ناتجا، فيمكنك أن يكون لديك معالج عنصر عملك إرسال رسالة JMS عندما يتم تشغيل عقدة عنصر العمل ولكن إكمال عنصر العمل فقط عند وصول رسالة النتائج المتوقعة، وهذا سوفاجعل التدفق يستمر إلا إذا تم استلام رسالة النتائج (ويمكنك على سبيل المثال إرسال معرف عنصر العمل كنوع من معلمة السياق في رسالتك حتى تعرف أي عنصر يعمل لإكماله إذا عادت النتيجة)

إذا كنت ترغب أيضا في التعامل مع رسائل JMS غير متوقعة (ليس بالضرورة نتيجة رسالة JMS الطلب الأولى)، فيمكنك استخدام عقدة حدث لذلك، ولها مستمع JMS يترجم رسائل JMS الواردة (مننوع معين) إلى signalevent (..) الدعوات، التي ستستمر بعد ذلك في التدفق من عقدة الأحداث إلى الأمام.

kris

مرخصة بموجب: CC-BY-SA مع الإسناد

لا تنتمي إلى StackOverflow