You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by mf...@apache.org on 2013/06/24 20:10:37 UTC

svn commit: r1496142 - /incubator/streams/trunk/streams-osgi-components/activity-consumer/src/main/java/org/apache/streams/osgi/components/activityconsumer/impl/PushActivityConsumer.java

Author: mfranklin
Date: Mon Jun 24 18:10:37 2013
New Revision: 1496142

URL: http://svn.apache.org/r1496142
Log:
Committing patch from Danny Sullivan (STREAMS-17)

Modified:
    incubator/streams/trunk/streams-osgi-components/activity-consumer/src/main/java/org/apache/streams/osgi/components/activityconsumer/impl/PushActivityConsumer.java

Modified: incubator/streams/trunk/streams-osgi-components/activity-consumer/src/main/java/org/apache/streams/osgi/components/activityconsumer/impl/PushActivityConsumer.java
URL: http://svn.apache.org/viewvc/incubator/streams/trunk/streams-osgi-components/activity-consumer/src/main/java/org/apache/streams/osgi/components/activityconsumer/impl/PushActivityConsumer.java?rev=1496142&r1=1496141&r2=1496142&view=diff
==============================================================================
--- incubator/streams/trunk/streams-osgi-components/activity-consumer/src/main/java/org/apache/streams/osgi/components/activityconsumer/impl/PushActivityConsumer.java (original)
+++ incubator/streams/trunk/streams-osgi-components/activity-consumer/src/main/java/org/apache/streams/osgi/components/activityconsumer/impl/PushActivityConsumer.java Mon Jun 24 18:10:37 2013
@@ -62,7 +62,7 @@ public class PushActivityConsumer implem
 
     public String receive (String activity){
         //receive activities...do anything that is necessary
-        LOG.info("got a message i subscribed to: " + activity);
+        LOG.info("a message I published: " + activity);
         return activity;
         //pass off to activity splitter
 
@@ -70,12 +70,9 @@ public class PushActivityConsumer implem
 
     public List<String> split(String activities){
         LOG.info("I am going to split this message: " + activities);
+
         ArrayList<String> activitiesList = new ArrayList<String>();
-        activitiesList.add("this");
-        activitiesList.add("is");
-        activitiesList.add("my");
-        activitiesList.add("split");
-        activitiesList.add("message");
+        activitiesList.add(activities);
         return activitiesList;
     }