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