You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by ds...@apache.org on 2013/11/05 14:19:17 UTC
svn commit: r1538989 -
/incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/activitysubscriber/impl/ActivityStreamsSubscriberWarehouseImpl.java
Author: dsullivan
Date: Tue Nov 5 13:19:16 2013
New Revision: 1538989
URL: http://svn.apache.org/r1538989
Log:
updating subscriber immediately
Modified:
incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/activitysubscriber/impl/ActivityStreamsSubscriberWarehouseImpl.java
Modified: incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/activitysubscriber/impl/ActivityStreamsSubscriberWarehouseImpl.java
URL: http://svn.apache.org/viewvc/incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/activitysubscriber/impl/ActivityStreamsSubscriberWarehouseImpl.java?rev=1538989&r1=1538988&r2=1538989&view=diff
==============================================================================
--- incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/activitysubscriber/impl/ActivityStreamsSubscriberWarehouseImpl.java (original)
+++ incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/activitysubscriber/impl/ActivityStreamsSubscriberWarehouseImpl.java Tue Nov 5 13:19:16 2013
@@ -29,6 +29,7 @@ public class ActivityStreamsSubscriberWa
if (!subscribers.containsKey(subscription.getInRoute())) {
ActivityStreamsSubscriber subscriber = new ActivityStreamsSubscriberDelegate();
subscribers.put(subscription.getInRoute(), subscriber);
+ this.updateSubscriber(subscription);
}
}
@@ -48,7 +49,7 @@ public class ActivityStreamsSubscriberWa
}
@Override
- public void updateSubscriber(ActivityStreamsSubscription subscription) {
+ public synchronized void updateSubscriber(ActivityStreamsSubscription subscription) {
ActivityStreamsSubscriber subscriber = getSubscriber(subscription.getInRoute());
if (subscriber != null) {
//TODO: an activity posted in between the cql query and setting the lastUpdated field will be lost