はじめに
引き続き極小ネタです。
今回はAnypoint MQのコネクタでサーキットブレーカーの動作を確認してみます。
特に意味はないです。たまたま思いついたことで、サクッと書けそうなネタということで。申し訳ないです。
サーキットブレーカーとは
この辺が分かり易いかと思います。
https://docs.microsoft.com/ja-jp/azure/architecture/patterns/circuit-breaker
つまるところ、
「おっ、なにやら送信に失敗したな。」
（エラーが続く）
「う～ん、直らないな。向こうで何か起こってるるのかもしれない。一旦停止しよう。」
（ちょっと待つ）
「そろそろ元に戻ったかもしれない。１回だけ送ってみるか」
「う～ん、やっぱり失敗するな。もう少し様子を見るか。」
（ちょっと待つ）
「そろそろどうかな。もう１回！おっ、送信できた！」
「復活したようだから、じゃんじゃん送るよ！」
といったような、無駄にエラーを続かせないために、ちょっと人間味のあるリトライをしてくれるよ、という機能かともやっと解釈しました。
Anypoint MQのサーキットブレーカーで遊んでみる
では、Anypoint MQのサーキットブレーカーを触ってみようと思います。
コネクタの説明はこの辺に呼んでくださいませ。
https://docs.mulesoft.com/jp/connectors/anypoint-mq/anypoint-mq-listener#%E3%82%B5%E3%83%BC%E3%82%AD%E3%83%83%E3%83%88%E3%83%96%E3%83%AC%E3%83%BC%E3%82%AB
まずは、こんな感じのPub/Subのサブスクライバのフローを作成します。
何をしているかというと、単純に最初の5回はエラーとして、6回目以降は正常に完了するだけのフローです。
Subscrberのプロパティ > Advancedは以下のように設定しました。
「TEST:TEST」というタイプのエラーが3回続いたら、１分待ちます、といった感じです。
では、動かしてみます。
test1～3というメッセージをキューに配置して、このサブスクライバのフローの動作をさせた結果のログです。
*******************************************************************************************************
* - - + APPLICATION + - - * - - + DOMAIN + - - * - - + STATUS + - - *
*******************************************************************************************************
* demo_publisher * default * DEPLOYED *
* demo_subscriber1 * default * DEPLOYED *
*******************************************************************************************************
INFO 2019-12-21 11:15:51,434 [[MuleRuntime].cpuLight.02: [demo_publisher].demopublisherFlow.CPU_LITE @3d5dfcd8] [event: cb60e420-2397-11ea-a607-7470fd71e47b] org.mule.runtime.core.internal.processor.LoggerMessageProcessor: start publisher [test1]
INFO 2019-12-21 11:15:51,936 [[MuleRuntime].cpuLight.02: [demo_publisher].demopublisherFlow.CPU_LITE @3d5dfcd8] [event: cb60e420-2397-11ea-a607-7470fd71e47b] org.mule.runtime.core.internal.processor.LoggerMessageProcessor: end publisher [test1]
ERROR 2019-12-21 11:15:52,499 [[MuleRuntime].io.02: [demo_subscriber1].demosubscriber1Flow.BLOCKING @787776b6] [event: cfaeba71-2397-11ea-a607-7470fd71e47b] org.mule.runtime.core.internal.exception.OnErrorPropagateHandler:
********************************************************************************
Message : An error occurred.
Error type : TEST:TEST
Element : demosubscriber1Flow/processors/1/route/1/processors/1 @ demo_subscriber1:demosubscriber1.xml:27 (Raise error)
Element XML : <raise-error doc:name="Raise error" doc:id="90e5046c-ffa0-4410-a64f-6bd972887ce1" type="TEST:TEST"></raise-error>
(set debug level logging or '-Dmule.verbose.exceptions=true' for everything)
********************************************************************************
ERROR 2019-12-21 11:15:52,936 [[MuleRuntime].io.01: [demo_subscriber1].demosubscriber1Flow.BLOCKING @787776b6] [event: d036fd40-2397-11ea-a607-7470fd71e47b] org.mule.runtime.core.internal.exception.OnErrorPropagateHandler:
********************************************************************************
Message : An error occurred.
Error type : TEST:TEST
Element : demosubscriber1Flow/processors/1/route/1/processors/1 @ demo_subscriber1:demosubscriber1.xml:27 (Raise error)
Element XML : <raise-error doc:name="Raise error" doc:id="90e5046c-ffa0-4410-a64f-6bd972887ce1" type="TEST:TEST"></raise-error>
(set debug level logging or '-Dmule.verbose.exceptions=true' for everything)
********************************************************************************
ERROR 2019-12-21 11:15:53,126 [[MuleRuntime].io.02: [demo_subscriber1].demosubscriber1Flow.BLOCKING @787776b6] [event: d05cfbd0-2397-11ea-a607-7470fd71e47b] org.mule.runtime.core.internal.exception.OnErrorPropagateHandler:
********************************************************************************
Message : An error occurred.
Error type : TEST:TEST
Element : demosubscriber1Flow/processors/1/route/1/processors/1 @ demo_subscriber1:demosubscriber1.xml:27 (Raise error)
Element XML : <raise-error doc:name="Raise error" doc:id="90e5046c-ffa0-4410-a64f-6bd972887ce1" type="TEST:TEST"></raise-error>
(set debug level logging or '-Dmule.verbose.exceptions=true' for everything)
********************************************************************************
INFO 2019-12-21 11:15:55,787 [[MuleRuntime].cpuLight.02: [demo_publisher].demopublisherFlow.CPU_LITE @3d5dfcd8] [event: d1f68790-2397-11ea-a607-7470fd71e47b] org.mule.runtime.core.internal.processor.LoggerMessageProcessor: start publisher [test2]
INFO 2019-12-21 11:15:56,176 [[MuleRuntime].cpuLight.02: [demo_publisher].demopublisherFlow.CPU_LITE @3d5dfcd8] [event: d1f68790-2397-11ea-a607-7470fd71e47b] org.mule.runtime.core.internal.processor.LoggerMessageProcessor: end publisher [test2]
INFO 2019-12-21 11:15:58,903 [[MuleRuntime].cpuLight.02: [demo_publisher].demopublisherFlow.CPU_LITE @3d5dfcd8] [event: d3d1fe50-2397-11ea-a607-7470fd71e47b] org.mule.runtime.core.internal.processor.LoggerMessageProcessor: start publisher [test3]
INFO 2019-12-21 11:15:59,055 [[MuleRuntime].cpuLight.02: [demo_publisher].demopublisherFlow.CPU_LITE @3d5dfcd8] [event: d3d1fe50-2397-11ea-a607-7470fd71e47b] org.mule.runtime.core.internal.processor.LoggerMessageProcessor: end publisher [test3]
ERROR 2019-12-21 11:16:53,609 [[MuleRuntime].io.03: [demo_subscriber1].demosubscriber1Flow.BLOCKING @787776b6] [event: f46c17e0-2397-11ea-a607-7470fd71e47b] org.mule.runtime.core.internal.exception.OnErrorPropagateHandler:
********************************************************************************
Message : An error occurred.
Error type : TEST:TEST
Element : demosubscriber1Flow/processors/1/route/1/processors/1 @ demo_subscriber1:demosubscriber1.xml:27 (Raise error)
Element XML : <raise-error doc:name="Raise error" doc:id="90e5046c-ffa0-4410-a64f-6bd972887ce1" type="TEST:TEST"></raise-error>
(set debug level logging or '-Dmule.verbose.exceptions=true' for everything)
********************************************************************************
ERROR 2019-12-21 11:17:59,466 [[MuleRuntime].io.01: [demo_subscriber1].demosubscriber1Flow.BLOCKING @787776b6] [event: 1bad12f0-2398-11ea-a607-7470fd71e47b] org.mule.runtime.core.internal.exception.OnErrorPropagateHandler:
********************************************************************************
Message : An error occurred.
Error type : TEST:TEST
Element : demosubscriber1Flow/processors/1/route/1/processors/1 @ demo_subscriber1:demosubscriber1.xml:27 (Raise error)
Element XML : <raise-error doc:name="Raise error" doc:id="90e5046c-ffa0-4410-a64f-6bd972887ce1" type="TEST:TEST"></raise-error>
(set debug level logging or '-Dmule.verbose.exceptions=true' for everything)
********************************************************************************
INFO 2019-12-21 11:19:03,603 [[MuleRuntime].io.03: [demo_subscriber1].demosubscriber1Flow.BLOCKING @787776b6] [event: 41e6b020-2398-11ea-a607-7470fd71e47b] org.mule.runtime.core.internal.processor.LoggerMessageProcessor: demo_subscriber_1 [test2]
INFO 2019-12-21 11:19:03,979 [[MuleRuntime].io.01: [demo_subscriber1].demosubscriber1Flow.BLOCKING @787776b6] [event: 4221bd50-2398-11ea-a607-7470fd71e47b] org.mule.runtime.core.internal.processor.LoggerMessageProcessor: demo_subscriber_1 [test3]
INFO 2019-12-21 11:19:04,126 [[MuleRuntime].io.01: [demo_subscriber1].demosubscriber1Flow.BLOCKING @787776b6] [event: 42382b80-2398-11ea-a607-7470fd71e47b] org.mule.runtime.core.internal.processor.LoggerMessageProcessor: demo_subscriber_1 [test1]
INFO 2019-12-21 11:19:14,704 [qtp1053539698-33] com.mulesoft.agent.services.AgentStudioManagementService: Received request to stop runtime
最初に3回、立て続けにエラーとなった後、1分毎に2回処理がエラーとなり、さらに1分後、3件のメッセージが正常に処理されることが確認できます。
最後に
プロパティをちょろちょろと設定するだけで、簡単にこういった機能が実装できてしまうのはうれしいですね。
では