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:24:24 UTC
svn commit: r1538992 -
/incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/service/impl/StreamsSubscriberRegistrationServiceImpl.java
Author: dsullivan
Date: Tue Nov 5 13:24:24 2013
New Revision: 1538992
URL: http://svn.apache.org/r1538992
Log:
naming conventions
Modified:
incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/service/impl/StreamsSubscriberRegistrationServiceImpl.java
Modified: incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/service/impl/StreamsSubscriberRegistrationServiceImpl.java
URL: http://svn.apache.org/viewvc/incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/service/impl/StreamsSubscriberRegistrationServiceImpl.java?rev=1538992&r1=1538991&r2=1538992&view=diff
==============================================================================
--- incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/service/impl/StreamsSubscriberRegistrationServiceImpl.java (original)
+++ incubator/streams/branches/webservice/streams-components/src/main/java/org/apache/streams/components/service/impl/StreamsSubscriberRegistrationServiceImpl.java Tue Nov 5 13:24:24 2013
@@ -19,15 +19,15 @@ import java.util.UUID;
public class StreamsSubscriberRegistrationServiceImpl implements StreamsSubscriberRegistrationService {
private Log log = LogFactory.getLog(StreamsSubscriberRegistrationServiceImpl.class);
- private StreamsSubscriptionRepositoryService subscriptionService;
+ private StreamsSubscriptionRepositoryService subscriptionRepositoryService;
private ActivityStreamsSubscriberWarehouse activityStreamsSubscriberWarehouse;
@Autowired
public StreamsSubscriberRegistrationServiceImpl(
- StreamsSubscriptionRepositoryService subscriptionService,
+ StreamsSubscriptionRepositoryService subscriptionRepositoryService,
ActivityStreamsSubscriberWarehouse activityStreamsSubscriberWarehouse
) {
- this.subscriptionService = subscriptionService;
+ this.subscriptionRepositoryService = subscriptionRepositoryService;
this.activityStreamsSubscriberWarehouse = activityStreamsSubscriberWarehouse;
}
@@ -42,7 +42,7 @@ public class StreamsSubscriberRegistrati
ActivityStreamsSubscription subscription = mapper.readValue(subscriberJSON, CassandraSubscription.class);
subscription.setInRoute("" + UUID.randomUUID());
- subscriptionService.saveSubscription(subscription);
+ subscriptionRepositoryService.saveSubscription(subscription);
activityStreamsSubscriberWarehouse.register(subscription);
return subscription.getInRoute();