You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by bd...@apache.org on 2014/10/22 11:33:33 UTC
svn commit: r1633577 -
/sling/trunk/launchpad/test-services/src/main/java/org/apache/sling/launchpad/testservices/events/EventsCounterImpl.java
Author: bdelacretaz
Date: Wed Oct 22 09:33:33 2014
New Revision: 1633577
URL: http://svn.apache.org/r1633577
Log:
SLING-4058 - add missing sync
Modified:
sling/trunk/launchpad/test-services/src/main/java/org/apache/sling/launchpad/testservices/events/EventsCounterImpl.java
Modified: sling/trunk/launchpad/test-services/src/main/java/org/apache/sling/launchpad/testservices/events/EventsCounterImpl.java
URL: http://svn.apache.org/viewvc/sling/trunk/launchpad/test-services/src/main/java/org/apache/sling/launchpad/testservices/events/EventsCounterImpl.java?rev=1633577&r1=1633576&r2=1633577&view=diff
==============================================================================
--- sling/trunk/launchpad/test-services/src/main/java/org/apache/sling/launchpad/testservices/events/EventsCounterImpl.java (original)
+++ sling/trunk/launchpad/test-services/src/main/java/org/apache/sling/launchpad/testservices/events/EventsCounterImpl.java Wed Oct 22 09:33:33 2014
@@ -71,7 +71,7 @@ public class EventsCounterImpl extends S
log.debug("{} counter is now {}", topic, counter.get());
}
- public int getEventsCount(String topic) {
+ public synchronized int getEventsCount(String topic) {
final AtomicInteger counter = counters.get(topic);
if(counter == null) {
log.debug("getEventsCount({}) returns 0, counter not found", topic);