Details
diff --git a/analytics/src/main/java/com/ning/billing/analytics/AnalyticsListener.java b/analytics/src/main/java/com/ning/billing/analytics/AnalyticsListener.java
index 37b91cd..d769c4a 100644
--- a/analytics/src/main/java/com/ning/billing/analytics/AnalyticsListener.java
+++ b/analytics/src/main/java/com/ning/billing/analytics/AnalyticsListener.java
@@ -48,7 +48,7 @@ import com.google.inject.Inject;
public class AnalyticsListener {
- private final BusinessSubscriptionTransitionRecorder bstRecorder;
+ private final BusinessSubscriptionTransitionDao bstDao;
private final BusinessAccountDao bacDao;
private final BusinessInvoiceDao invoiceDao;
private final BusinessOverdueStatusDao bosDao;
@@ -57,14 +57,14 @@ public class AnalyticsListener {
private final InternalCallContextFactory internalCallContextFactory;
@Inject
- public AnalyticsListener(final BusinessSubscriptionTransitionRecorder bstRecorder,
+ public AnalyticsListener(final BusinessSubscriptionTransitionDao bstDao,
final BusinessAccountDao bacDao,
final BusinessInvoiceDao invoiceDao,
final BusinessOverdueStatusDao bosDao,
final BusinessInvoicePaymentDao bipDao,
final BusinessTagRecorder tagRecorder,
final InternalCallContextFactory internalCallContextFactory) {
- this.bstRecorder = bstRecorder;
+ this.bstDao = bstDao;
this.bacDao = bacDao;
this.invoiceDao = invoiceDao;
this.bosDao = bosDao;
@@ -76,19 +76,19 @@ public class AnalyticsListener {
@Subscribe
public void handleEffectiveSubscriptionTransitionChange(final EffectiveSubscriptionEvent eventEffective) throws AccountApiException, EntitlementUserApiException {
// The event is used as a trigger to rebuild all transitions for this bundle
- bstRecorder.rebuildTransitionsForBundle(eventEffective.getBundleId(), createCallContext(eventEffective));
+ bstDao.rebuildTransitionsForBundle(eventEffective.getBundleId(), createCallContext(eventEffective));
}
@Subscribe
public void handleRequestedSubscriptionTransitionChange(final RequestedSubscriptionEvent eventRequested) throws AccountApiException, EntitlementUserApiException {
// The event is used as a trigger to rebuild all transitions for this bundle
- bstRecorder.rebuildTransitionsForBundle(eventRequested.getBundleId(), createCallContext(eventRequested));
+ bstDao.rebuildTransitionsForBundle(eventRequested.getBundleId(), createCallContext(eventRequested));
}
@Subscribe
public void handleRepairEntitlement(final RepairEntitlementEvent event) {
// In case of repair, just rebuild all transitions
- bstRecorder.rebuildTransitionsForBundle(event.getBundleId(), createCallContext(event));
+ bstDao.rebuildTransitionsForBundle(event.getBundleId(), createCallContext(event));
}
@Subscribe
diff --git a/analytics/src/main/java/com/ning/billing/analytics/setup/AnalyticsModule.java b/analytics/src/main/java/com/ning/billing/analytics/setup/AnalyticsModule.java
index 8467c83..4252211 100644
--- a/analytics/src/main/java/com/ning/billing/analytics/setup/AnalyticsModule.java
+++ b/analytics/src/main/java/com/ning/billing/analytics/setup/AnalyticsModule.java
@@ -18,7 +18,7 @@ package com.ning.billing.analytics.setup;
import com.ning.billing.analytics.AnalyticsListener;
import com.ning.billing.analytics.BusinessAccountDao;
-import com.ning.billing.analytics.BusinessSubscriptionTransitionRecorder;
+import com.ning.billing.analytics.BusinessSubscriptionTransitionDao;
import com.ning.billing.analytics.BusinessTagRecorder;
import com.ning.billing.analytics.api.AnalyticsService;
import com.ning.billing.analytics.api.DefaultAnalyticsService;
@@ -61,7 +61,7 @@ public class AnalyticsModule extends AbstractModule {
bind(BusinessSubscriptionTransitionSqlDao.class).toProvider(new BusinessSqlProvider<BusinessSubscriptionTransitionSqlDao>(BusinessSubscriptionTransitionSqlDao.class));
bind(BusinessSubscriptionTransitionTagSqlDao.class).toProvider(new BusinessSqlProvider<BusinessSubscriptionTransitionTagSqlDao>(BusinessSubscriptionTransitionTagSqlDao.class));
- bind(BusinessSubscriptionTransitionRecorder.class).asEagerSingleton();
+ bind(BusinessSubscriptionTransitionDao.class).asEagerSingleton();
bind(BusinessAccountDao.class).asEagerSingleton();
bind(BusinessTagRecorder.class).asEagerSingleton();
bind(AnalyticsListener.class).asEagerSingleton();
diff --git a/analytics/src/test/java/com/ning/billing/analytics/TestBusinessSubscriptionTransitionRecorder.java b/analytics/src/test/java/com/ning/billing/analytics/TestBusinessSubscriptionTransitionRecorder.java
index 0d1afe8..9eba936 100644
--- a/analytics/src/test/java/com/ning/billing/analytics/TestBusinessSubscriptionTransitionRecorder.java
+++ b/analytics/src/test/java/com/ning/billing/analytics/TestBusinessSubscriptionTransitionRecorder.java
@@ -85,8 +85,8 @@ public class TestBusinessSubscriptionTransitionRecorder extends AnalyticsTestSui
Mockito.when(subscription.getAllTransitions()).thenReturn(ImmutableList.<EffectiveSubscriptionEvent>of(eventEffective));
Mockito.when(entitlementApi.getSubscriptionsForBundle(Mockito.<UUID>any(), Mockito.<TenantContext>any())).thenReturn(ImmutableList.<Subscription>of(subscription));
- final BusinessSubscriptionTransitionRecorder recorder = new BusinessSubscriptionTransitionRecorder(sqlDao, catalogService, entitlementApi, accountApi, new DefaultClock());
- recorder.rebuildTransitionsForBundle(bundle.getId(), internalCallContext);
+ final BusinessSubscriptionTransitionDao dao = new BusinessSubscriptionTransitionDao(sqlDao, catalogService, entitlementApi, accountApi, new DefaultClock());
+ dao.rebuildTransitionsForBundle(bundle.getId(), internalCallContext);
Assert.assertEquals(sqlDao.getTransitionsByKey(externalKey.toString(), internalCallContext).size(), 1);
final BusinessSubscriptionTransition transition = sqlDao.getTransitionsByKey(externalKey.toString(), internalCallContext).get(0);