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;
}