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/10/31 18:38:22 UTC
svn commit: r1537565 -
/incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/service/impl/CassandraSubscriptionService.java
Author: dsullivan
Date: Thu Oct 31 17:38:21 2013
New Revision: 1537565
URL: http://svn.apache.org/r1537565
Log:
creating empty filters if filters is null
Modified:
incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/service/impl/CassandraSubscriptionService.java
Modified: incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/service/impl/CassandraSubscriptionService.java
URL: http://svn.apache.org/viewvc/incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/service/impl/CassandraSubscriptionService.java?rev=1537565&r1=1537564&r2=1537565&view=diff
==============================================================================
--- incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/service/impl/CassandraSubscriptionService.java (original)
+++ incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/service/impl/CassandraSubscriptionService.java Thu Oct 31 17:38:21 2013
@@ -6,6 +6,7 @@ import org.apache.streams.persistence.re
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
+import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.UUID;
@@ -23,6 +24,9 @@ public class CassandraSubscriptionServic
@Override
public void saveSubscription(ActivityStreamsSubscription subscription) {
subscription.setId("" + UUID.randomUUID());
+ if(subscription.getFilters() == null){
+ subscription.setFilters(new ArrayList<String>());
+ }
repository.save(subscription);
}