You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by le...@apache.org on 2013/02/04 16:04:38 UTC
svn commit: r1442147 - in /incubator/streams/trunk:
streams-eip-routes/src/main/java/org/apache/streams/messaging/processors/
streams-eip-routes/src/main/java/org/apache/streams/messaging/routers/impl/
streams-osgi-components/activity-consumer/src/main...
Author: letourneau
Date: Mon Feb 4 15:04:37 2013
New Revision: 1442147
URL: http://svn.apache.org/viewvc?rev=1442147&view=rev
Log:
added authenticate boolean and changed filter interface
Added:
incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/impl/ActivityStreamsSubscriptionLuceneFilterImpl.java
Removed:
incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/impl/ActivityStreamsSubscriptionFilterImpl.java
Modified:
incubator/streams/trunk/streams-eip-routes/src/main/java/org/apache/streams/messaging/processors/ActivityStreamsSubscriberRegistrationProcessor.java
incubator/streams/trunk/streams-eip-routes/src/main/java/org/apache/streams/messaging/routers/impl/ActivityConsumerRouter.java
incubator/streams/trunk/streams-eip-routes/src/main/java/org/apache/streams/messaging/routers/impl/ActivityStreamsSubscriberRouter.java
incubator/streams/trunk/streams-osgi-components/activity-consumer/src/main/java/org/apache/streams/osgi/components/activityconsumer/ActivityConsumer.java
incubator/streams/trunk/streams-osgi-components/activity-consumer/src/main/java/org/apache/streams/osgi/components/activityconsumer/impl/PushActivityConsumer.java
incubator/streams/trunk/streams-osgi-components/activity-registration/src/main/java/org/apache/streams/osgi/components/impl/ActivityPublisherRegistrationImpl.java
incubator/streams/trunk/streams-osgi-components/activity-registration/src/main/java/org/apache/streams/osgi/components/impl/ActivityStreamsSubscriberRegistrationImpl.java
incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/ActivityStreamsSubscriber.java
incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/ActivityStreamsSubscription.java
incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/ActivityStreamsSubscriptionFilter.java
incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/impl/ActivityStreamsSubscriberDelegate.java
incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/impl/ActivityStreamsSubscriptionImpl.java
Modified: incubator/streams/trunk/streams-eip-routes/src/main/java/org/apache/streams/messaging/processors/ActivityStreamsSubscriberRegistrationProcessor.java
URL: http://svn.apache.org/viewvc/incubator/streams/trunk/streams-eip-routes/src/main/java/org/apache/streams/messaging/processors/ActivityStreamsSubscriberRegistrationProcessor.java?rev=1442147&r1=1442146&r2=1442147&view=diff
==============================================================================
--- incubator/streams/trunk/streams-eip-routes/src/main/java/org/apache/streams/messaging/processors/ActivityStreamsSubscriberRegistrationProcessor.java (original)
+++ incubator/streams/trunk/streams-eip-routes/src/main/java/org/apache/streams/messaging/processors/ActivityStreamsSubscriberRegistrationProcessor.java Mon Feb 4 15:04:37 2013
@@ -6,6 +6,7 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.streams.osgi.components.activitysubscriber.ActivityStreamsSubscription;
import org.apache.streams.osgi.components.activitysubscriber.impl.ActivityStreamsSubscriptionImpl;
+import org.codehaus.jackson.JsonNode;
import org.codehaus.jackson.map.DeserializationConfig;
import org.codehaus.jackson.map.ObjectMapper;
@@ -36,8 +37,9 @@ public class ActivityStreamsSubscriberRe
mapper.configure(DeserializationConfig.Feature.FAIL_ON_UNKNOWN_PROPERTIES,false);
try {
+
// read from file, convert it to user class
- ActivityStreamsSubscription configuration = mapper.readValue(body, ActivityStreamsSubscriptionImpl.class);
+ ActivityStreamsSubscription configuration = mapper.readValue(body, ActivityStreamsSubscription.class);
exchange.getOut().setBody(configuration);
} catch (Exception e) {
Modified: incubator/streams/trunk/streams-eip-routes/src/main/java/org/apache/streams/messaging/routers/impl/ActivityConsumerRouter.java
URL: http://svn.apache.org/viewvc/incubator/streams/trunk/streams-eip-routes/src/main/java/org/apache/streams/messaging/routers/impl/ActivityConsumerRouter.java?rev=1442147&r1=1442146&r2=1442147&view=diff
==============================================================================
--- incubator/streams/trunk/streams-eip-routes/src/main/java/org/apache/streams/messaging/routers/impl/ActivityConsumerRouter.java (original)
+++ incubator/streams/trunk/streams-eip-routes/src/main/java/org/apache/streams/messaging/routers/impl/ActivityConsumerRouter.java Mon Feb 4 15:04:37 2013
@@ -38,30 +38,37 @@ public class ActivityConsumerRouter exte
//todo: add some better scheme then getCount for URL...
//todo: make the route again if consumer exists...and context doesn't have route
- ActivityConsumer existingConsumer = activityConsumerWarehouse.findConsumerBySrc(activityConsumer.getSrc());
+ if (activityConsumer.isAuthenticated()){
+ ActivityConsumer existingConsumer = activityConsumerWarehouse.findConsumerBySrc(activityConsumer.getSrc());
- if (existingConsumer==null){
+ if (existingConsumer==null){
- activityConsumer.setInRoute("http://" + configuration.getConsumerInRouteHost()+ ":" + configuration.getConsumerInRoutePort() + EipConfigurator.CONSUMER_URL_RESOURCE + "/" + activityConsumerWarehouse.getConsumersCount());
+ activityConsumer.setInRoute("http://" + configuration.getConsumerInRouteHost()+ ":" + configuration.getConsumerInRoutePort() + EipConfigurator.CONSUMER_URL_RESOURCE + "/" + activityConsumerWarehouse.getConsumersCount());
- try{
- //setup a message queue for this consumer.getInRoute()
- camelContext.addRoutes(new DynamicConsumerRouteBuilder(configuration,camelContext, "jetty:" + activityConsumer.getInRoute(), activityConsumer));
- //set the body to the url the producer should post to
- exchange.getOut().setBody(activityConsumer.getInRoute());
- LOG.info("all messages sent from " + activityConsumer.getSrc() + " must be posted to " + activityConsumer.getInRoute());
- //only add the route to the warehouse after its been created in messaging system...
- activityConsumerWarehouse.register(activityConsumer);
- }catch (Exception e){
- exchange.getOut().setHeader(Exchange.HTTP_RESPONSE_CODE,500);
- exchange.getOut().setBody("error creating route: " + e);
- LOG.error("error creating route: " + e);
- }
-
- } else{
-
- exchange.getOut().setBody(existingConsumer.getInRoute());
+ try{
+ //setup a message queue for this consumer.getInRoute()
+ camelContext.addRoutes(new DynamicConsumerRouteBuilder(configuration,camelContext, "jetty:" + activityConsumer.getInRoute(), activityConsumer));
+ //set the body to the url the producer should post to
+ exchange.getOut().setBody(activityConsumer.getInRoute());
+ LOG.info("all messages sent from " + activityConsumer.getSrc() + " must be posted to " + activityConsumer.getInRoute());
+ //only add the route to the warehouse after its been created in messaging system...
+ activityConsumerWarehouse.register(activityConsumer);
+ }catch (Exception e){
+ exchange.getOut().setHeader(Exchange.HTTP_RESPONSE_CODE,500);
+ exchange.getOut().setBody("error creating route: " + e);
+ LOG.error("error creating route: " + e);
+ }
+
+ } else{
+
+ exchange.getOut().setBody(existingConsumer.getInRoute());
+ }
+
+ }else{
+ exchange.getOut().setFault(true);
+ exchange.getOut().setHeader(Exchange.HTTP_RESPONSE_CODE,401);
+ exchange.getOut().setBody("Authentication failed.");
}
}
Modified: incubator/streams/trunk/streams-eip-routes/src/main/java/org/apache/streams/messaging/routers/impl/ActivityStreamsSubscriberRouter.java
URL: http://svn.apache.org/viewvc/incubator/streams/trunk/streams-eip-routes/src/main/java/org/apache/streams/messaging/routers/impl/ActivityStreamsSubscriberRouter.java?rev=1442147&r1=1442146&r2=1442147&view=diff
==============================================================================
--- incubator/streams/trunk/streams-eip-routes/src/main/java/org/apache/streams/messaging/routers/impl/ActivityStreamsSubscriberRouter.java (original)
+++ incubator/streams/trunk/streams-eip-routes/src/main/java/org/apache/streams/messaging/routers/impl/ActivityStreamsSubscriberRouter.java Mon Feb 4 15:04:37 2013
@@ -39,7 +39,7 @@ public class ActivityStreamsSubscriberRo
//todo: add some better scheme then getCount for URL...
//todo: make the route again if subscriber exists...and context doesn't have route
-
+ if (activityStreamsSubscriber.isAuthenticated()){
activityStreamsSubscriber.setInRoute("http://" + configuration.getSubscriberInRouteHost()+ ":" + configuration.getSubscriberInRoutePort() + EipConfigurator.SUBSCRIBER_URL_RESOURCE + "/" + UUID.randomUUID());
try{
@@ -55,7 +55,11 @@ public class ActivityStreamsSubscriberRo
LOG.error("error creating route: " + e);
}
-
+ }else{
+ exchange.getOut().setFault(true);
+ exchange.getOut().setHeader(Exchange.HTTP_RESPONSE_CODE,401);
+ exchange.getOut().setBody("Authentication failed.");
+ }
}
Modified: incubator/streams/trunk/streams-osgi-components/activity-consumer/src/main/java/org/apache/streams/osgi/components/activityconsumer/ActivityConsumer.java
URL: http://svn.apache.org/viewvc/incubator/streams/trunk/streams-osgi-components/activity-consumer/src/main/java/org/apache/streams/osgi/components/activityconsumer/ActivityConsumer.java?rev=1442147&r1=1442146&r2=1442147&view=diff
==============================================================================
--- incubator/streams/trunk/streams-osgi-components/activity-consumer/src/main/java/org/apache/streams/osgi/components/activityconsumer/ActivityConsumer.java (original)
+++ incubator/streams/trunk/streams-osgi-components/activity-consumer/src/main/java/org/apache/streams/osgi/components/activityconsumer/ActivityConsumer.java Mon Feb 4 15:04:37 2013
@@ -7,4 +7,6 @@ public interface ActivityConsumer {
public String getSrc();
public void setInRoute(String route);
public String getInRoute();
+ public boolean isAuthenticated();
+ public void setAuthenticated(boolean authenticated);
}
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=1442147&r1=1442146&r2=1442147&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 Feb 4 15:04:37 2013
@@ -13,6 +13,9 @@ public class PushActivityConsumer implem
private String src;
+
+ private boolean authenticated;
+
private String inRoute;
public PushActivityConsumer(String src){
@@ -27,6 +30,13 @@ public class PushActivityConsumer implem
this.src = src;
}
+ public boolean isAuthenticated() {
+ return authenticated;
+ }
+
+ public void setAuthenticated(boolean authenticated) {
+ this.authenticated = authenticated;
+ }
public String receive (String activity){
//receive activities...do anything that is necessary
Modified: incubator/streams/trunk/streams-osgi-components/activity-registration/src/main/java/org/apache/streams/osgi/components/impl/ActivityPublisherRegistrationImpl.java
URL: http://svn.apache.org/viewvc/incubator/streams/trunk/streams-osgi-components/activity-registration/src/main/java/org/apache/streams/osgi/components/impl/ActivityPublisherRegistrationImpl.java?rev=1442147&r1=1442146&r2=1442147&view=diff
==============================================================================
--- incubator/streams/trunk/streams-osgi-components/activity-registration/src/main/java/org/apache/streams/osgi/components/impl/ActivityPublisherRegistrationImpl.java (original)
+++ incubator/streams/trunk/streams-osgi-components/activity-registration/src/main/java/org/apache/streams/osgi/components/impl/ActivityPublisherRegistrationImpl.java Mon Feb 4 15:04:37 2013
@@ -22,7 +22,11 @@ public class ActivityPublisherRegistrati
String answer = prefix + " set body: " + body + " " + new Date();
LOG.info(">> call >>" + answer);
- return new PushActivityConsumer(body.toString());
+ //should be configed like the subscriber = what type? polling? how often? etc...
+ PushActivityConsumer activityConsumer =new PushActivityConsumer(body.toString());
+ //authenticate..
+ activityConsumer.setAuthenticated(true);
+ return activityConsumer;
}
Modified: incubator/streams/trunk/streams-osgi-components/activity-registration/src/main/java/org/apache/streams/osgi/components/impl/ActivityStreamsSubscriberRegistrationImpl.java
URL: http://svn.apache.org/viewvc/incubator/streams/trunk/streams-osgi-components/activity-registration/src/main/java/org/apache/streams/osgi/components/impl/ActivityStreamsSubscriberRegistrationImpl.java?rev=1442147&r1=1442146&r2=1442147&view=diff
==============================================================================
--- incubator/streams/trunk/streams-osgi-components/activity-registration/src/main/java/org/apache/streams/osgi/components/impl/ActivityStreamsSubscriberRegistrationImpl.java (original)
+++ incubator/streams/trunk/streams-osgi-components/activity-registration/src/main/java/org/apache/streams/osgi/components/impl/ActivityStreamsSubscriberRegistrationImpl.java Mon Feb 4 15:04:37 2013
@@ -20,7 +20,13 @@ public class ActivityStreamsSubscriberRe
ActivityStreamsSubscription configuration = (ActivityStreamsSubscription)body;
- return new ActivityStreamsSubscriberDelegate(configuration);
+ ActivityStreamsSubscriberDelegate delegate = new ActivityStreamsSubscriberDelegate(configuration);
+ //authenticate
+ delegate.setAuthenticated(true);
+
+
+
+ return delegate;
}
Modified: incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/ActivityStreamsSubscriber.java
URL: http://svn.apache.org/viewvc/incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/ActivityStreamsSubscriber.java?rev=1442147&r1=1442146&r2=1442147&view=diff
==============================================================================
--- incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/ActivityStreamsSubscriber.java (original)
+++ incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/ActivityStreamsSubscriber.java Mon Feb 4 15:04:37 2013
@@ -9,5 +9,7 @@ public interface ActivityStreamsSubscrib
public String getInRoute();
public void setActivityStreamsSubscriberConfiguration(ActivityStreamsSubscription config);
public void updateActivityStreamsSubscriberConfiguration(String config);
+ public boolean isAuthenticated();
+ public void setAuthenticated(boolean authenticated);
}
Modified: incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/ActivityStreamsSubscription.java
URL: http://svn.apache.org/viewvc/incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/ActivityStreamsSubscription.java?rev=1442147&r1=1442146&r2=1442147&view=diff
==============================================================================
--- incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/ActivityStreamsSubscription.java (original)
+++ incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/ActivityStreamsSubscription.java Mon Feb 4 15:04:37 2013
@@ -1,7 +1,9 @@
package org.apache.streams.osgi.components.activitysubscriber;
-import java.util.ArrayList;
+import org.codehaus.jackson.annotate.JsonTypeInfo;
+import java.util.ArrayList;
+@JsonTypeInfo(use= JsonTypeInfo.Id.CLASS, include=JsonTypeInfo.As.PROPERTY, property="@class")
public interface ActivityStreamsSubscription {
public ArrayList<ActivityStreamsSubscriptionFilter> getActivityStreamsSubscriptionFilters();
@@ -10,4 +12,10 @@ public interface ActivityStreamsSubscrip
public ArrayList<ActivityStreamsSubscriptionOutput> getActivityStreamsSubscriptionOutputs();
public void setActivityStreamsSubscriptionOutputs(ArrayList<ActivityStreamsSubscriptionOutput> outputs);
+ public String getAuthToken();
+ public void setAuthToken(String token);
+
+
+
+
}
Modified: incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/ActivityStreamsSubscriptionFilter.java
URL: http://svn.apache.org/viewvc/incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/ActivityStreamsSubscriptionFilter.java?rev=1442147&r1=1442146&r2=1442147&view=diff
==============================================================================
--- incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/ActivityStreamsSubscriptionFilter.java (original)
+++ incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/ActivityStreamsSubscriptionFilter.java Mon Feb 4 15:04:37 2013
@@ -1,15 +1,14 @@
package org.apache.streams.osgi.components.activitysubscriber;
+import org.codehaus.jackson.annotate.JsonTypeInfo;
+@JsonTypeInfo(use= JsonTypeInfo.Id.CLASS, include=JsonTypeInfo.As.PROPERTY, property="@class")
public interface ActivityStreamsSubscriptionFilter {
- public String[] getFields();
- public void setFields(String[] fields);
- public String getComparisonOperator();
- public void setComparisonOperator(String comparisonOperator);
- public String[] getValueSet();
- public void setValueSet(String[] valueSet);
+ public void setQuery(String query);
+
+ public boolean evaluate(String activity);
}
Modified: incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/impl/ActivityStreamsSubscriberDelegate.java
URL: http://svn.apache.org/viewvc/incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/impl/ActivityStreamsSubscriberDelegate.java?rev=1442147&r1=1442146&r2=1442147&view=diff
==============================================================================
--- incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/impl/ActivityStreamsSubscriberDelegate.java (original)
+++ incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/impl/ActivityStreamsSubscriberDelegate.java Mon Feb 4 15:04:37 2013
@@ -13,6 +13,7 @@ public class ActivityStreamsSubscriberDe
private static final transient Log LOG = LogFactory.getLog(ActivityStreamsSubscriberDelegate.class);
+ private boolean authenticated;
private ActivityStreamsSubscription activityStreamsSubscriberConfiguration;
@@ -52,6 +53,14 @@ public class ActivityStreamsSubscriberDe
}
+ public boolean isAuthenticated() {
+ return authenticated;
+ }
+
+ public void setAuthenticated(boolean authenticated) {
+ this.authenticated = authenticated;
+ }
+
public String getInRoute() {
return inRoute;
}
Modified: incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/impl/ActivityStreamsSubscriptionImpl.java
URL: http://svn.apache.org/viewvc/incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/impl/ActivityStreamsSubscriptionImpl.java?rev=1442147&r1=1442146&r2=1442147&view=diff
==============================================================================
--- incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/impl/ActivityStreamsSubscriptionImpl.java (original)
+++ incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/impl/ActivityStreamsSubscriptionImpl.java Mon Feb 4 15:04:37 2013
@@ -13,6 +13,10 @@ public class ActivityStreamsSubscription
private ArrayList<ActivityStreamsSubscriptionOutput> activityStreamsSubscriptionOutputs;
+
+
+ private String authToken;
+
@Override
public ArrayList<ActivityStreamsSubscriptionFilter> getActivityStreamsSubscriptionFilters() {
return activityStreamsSubscriptionFilters;
@@ -32,4 +36,17 @@ public class ActivityStreamsSubscription
public void setActivityStreamsSubscriptionOutputs(ArrayList<ActivityStreamsSubscriptionOutput> outputs) {
this.activityStreamsSubscriptionOutputs = outputs;
}
+
+ public String getAuthToken() {
+ return authToken;
+ }
+
+ public void setAuthToken(String auth_token) {
+ this.authToken = auth_token;
+ }
+
+
+
+
+
}
Added: incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/impl/ActivityStreamsSubscriptionLuceneFilterImpl.java
URL: http://svn.apache.org/viewvc/incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/impl/ActivityStreamsSubscriptionLuceneFilterImpl.java?rev=1442147&view=auto
==============================================================================
--- incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/impl/ActivityStreamsSubscriptionLuceneFilterImpl.java (added)
+++ incubator/streams/trunk/streams-osgi-components/activity-subscriber/src/main/java/org/apache/streams/osgi/components/activitysubscriber/impl/ActivityStreamsSubscriptionLuceneFilterImpl.java Mon Feb 4 15:04:37 2013
@@ -0,0 +1,21 @@
+package org.apache.streams.osgi.components.activitysubscriber.impl;
+
+
+import org.apache.streams.osgi.components.activitysubscriber.ActivityStreamsSubscriptionFilter;
+
+public class ActivityStreamsSubscriptionLuceneFilterImpl implements ActivityStreamsSubscriptionFilter{
+
+ private String query;
+
+
+
+ public void setQuery(String query) {
+ this.query=query;
+ }
+
+ public boolean evaluate(String activity){
+ return true;
+ }
+
+
+}