|
1 | 1 | #include "FlowMeasureStatusUpdates.h" |
2 | 2 | #include "ECFMP/SdkEvents.h" |
3 | 3 | #include "ECFMP/flowmeasure/CanonicalFlowMeasureInfo.h" |
| 4 | +#include "ECFMP/log/Logger.h" |
4 | 5 | #include "eventbus/InternalEventBus.h" |
5 | 6 |
|
6 | 7 | namespace ECFMP::FlowMeasure { |
@@ -48,17 +49,26 @@ namespace ECFMP::FlowMeasure { |
48 | 49 | { |
49 | 50 | switch (measure->Status()) { |
50 | 51 | case MeasureStatus::Notified: |
| 52 | + WriteLogMessage(*measure, "Notified"); |
51 | 53 | eventBus->OnEvent<Plugin::FlowMeasureNotifiedEvent>({measure}); |
52 | | - return; |
| 54 | + break; |
53 | 55 | case MeasureStatus::Active: |
| 56 | + WriteLogMessage(*measure, "Activated"); |
54 | 57 | eventBus->OnEvent<Plugin::FlowMeasureActivatedEvent>({measure}); |
55 | | - return; |
| 58 | + break; |
56 | 59 | case MeasureStatus::Withdrawn: |
| 60 | + WriteLogMessage(*measure, "Withdrawn"); |
57 | 61 | eventBus->OnEvent<Plugin::FlowMeasureWithdrawnEvent>({measure}); |
58 | | - return; |
| 62 | + break; |
59 | 63 | case MeasureStatus::Expired: |
| 64 | + WriteLogMessage(*measure, "Expired"); |
60 | 65 | eventBus->OnEvent<Plugin::FlowMeasureExpiredEvent>({measure}); |
61 | | - return; |
| 66 | + break; |
62 | 67 | } |
63 | 68 | } |
| 69 | + |
| 70 | + void FlowMeasureStatusUpdates::WriteLogMessage(const FlowMeasure& measure, const std::string& status) |
| 71 | + { |
| 72 | + logger->Info("Flow measure " + measure.Identifier() + " now has a status of " + status + "."); |
| 73 | + } |
64 | 74 | }// namespace ECFMP::FlowMeasure |
0 commit comments