File tree Expand file tree Collapse file tree 3 files changed +5
-3
lines changed
main/java/com/ericsson/ei
test/java/com/ericsson/ei/flowtests Expand file tree Collapse file tree 3 files changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -53,7 +53,7 @@ public class EventHandler {
53
53
public void eventReceived (String event ) {
54
54
RulesObject eventRules = rulesHandler .getRulesForEvent (event );
55
55
idRulesHandler .runIdRules (eventRules , event );
56
- downstreamIdRulesHandler .runIdRules (eventRules , event );
56
+ // downstreamIdRulesHandler.runIdRules(eventRules, event);
57
57
}
58
58
59
59
public void eventReceived (byte [] message ) {
Original file line number Diff line number Diff line change @@ -64,6 +64,7 @@ public void run() {
64
64
String event = dbObject .get ("Event" ).toString ();
65
65
rulesObject = rulesHandler .getRulesForEvent (event );
66
66
String idRule = rulesObject .getIdentifyRules ();
67
+ if (idRule != null && !idRule .isEmpty ()) {
67
68
JsonNode ids = jmesPathInterface .runRuleOnEvent (idRule , event );
68
69
if (ids .isArray ()) {
69
70
for (final JsonNode idJsonObj : ids ) {
@@ -74,6 +75,7 @@ public void run() {
74
75
}
75
76
}
76
77
}
78
+ }
77
79
}
78
80
}
79
81
}
Original file line number Diff line number Diff line change @@ -40,9 +40,9 @@ public class FlowTestExternalComposition extends FlowTestBase {
40
40
protected ArrayList <String > getEventNamesToSend () {
41
41
ArrayList <String > eventNames = new ArrayList <>();
42
42
eventNames .add ("event_EiffelArtifactCreatedEvent_3" );
43
- eventNames .add ("event_EiffelCompositionDefinedEvent_4" );
43
+ // eventNames.add("event_EiffelCompositionDefinedEvent_4");
44
44
eventNames .add ("event_EiffelArtifactCreatedEvent_4" );
45
- eventNames .add ("event_EiffelCompositionDefinedEvent_5" );
45
+ // eventNames.add("event_EiffelCompositionDefinedEvent_5");
46
46
eventNames .add ("event_EiffelArtifactCreatedEvent_5" );
47
47
return eventNames ;
48
48
}
You can’t perform that action at this time.
0 commit comments