Skip to content

Commit 8962e41

Browse files
shubhamkumarguptaTCSShubham Gupta C
andauthored
Eib more subscription triggering at high load (#523)
* Uplifted the logback-classic version to 1.2.10 * EIB resilience bug fixed Co-authored-by: Shubham Gupta C <shubham.c.gupta@ericsson.com>
1 parent b9635f2 commit 8962e41

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

src/main/java/com/ericsson/ei/subscription/RunSubscription.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -121,10 +121,9 @@ public boolean runSubscriptionOnObject(String aggregatedObject, Iterator<JsonNod
121121
if (count_conditions != 0 && count_condition_fulfillment == count_conditions) {
122122
conditionFulfilled = true;
123123
if (subscriptionRepeatFlag.equals("false") && id != null) {
124-
final String synchronizationString = new String(subscriptionName);
125124
// the keyword 'synchronized' ensures that this part of the code run
126125
// synchronously. Thus avoids race condition.
127-
synchronized (synchronizationString) {
126+
synchronized (this) {
128127
if (!subscriptionRepeatDbHandler.checkIfAggrObjIdExistInSubscriptionAggrIdsMatchedList(
129128
subscriptionName, requirementIndex, id, false)) {
130129
LOGGER.debug("Adding matched aggregated object to database:" + dataBaseName);
@@ -154,4 +153,4 @@ public static String destringify(String str) {
154153
str = str.replaceAll("\\[", "");
155154
return str;
156155
}
157-
}
156+
}

0 commit comments

Comments
 (0)