killbill-aplcache

subscription: Fix missing expected bus in test

10/20/2017 2:15:28 AM

stephane brossier

Commit: 244ab3d

Tree: 467aaed

Parents: 29c4e11

Changes

subscription/src/test/java/org/killbill/billing/subscription/engine/dao/TestSubscriptionDao.java 3(+3 -0)

Details

subscription/src/test/java/org/killbill/billing/subscription/engine/dao/TestSubscriptionDao.java 3(+3 -0)

diff --git a/subscription/src/test/java/org/killbill/billing/subscription/engine/dao/TestSubscriptionDao.java b/subscription/src/test/java/org/killbill/billing/subscription/engine/dao/TestSubscriptionDao.java
index 9eb2dea..0455390 100644
--- a/subscription/src/test/java/org/killbill/billing/subscription/engine/dao/TestSubscriptionDao.java
+++ b/subscription/src/test/java/org/killbill/billing/subscription/engine/dao/TestSubscriptionDao.java
@@ -24,6 +24,7 @@ import org.joda.time.DateTime;
 import org.killbill.billing.ErrorCode;
 import org.killbill.billing.account.api.Account;
 import org.killbill.billing.account.api.AccountData;
+import org.killbill.billing.api.TestApiListener.NextEvent;
 import org.killbill.billing.catalog.DefaultPriceListSet;
 import org.killbill.billing.catalog.api.ProductCategory;
 import org.killbill.billing.subscription.SubscriptionTestSuiteWithEmbeddedDB;
@@ -106,7 +107,9 @@ public class TestSubscriptionDao extends SubscriptionTestSuiteWithEmbeddedDB {
         final SubscriptionBaseEvent creationEvent = new ApiEventCreate(createBuilder);
 
         final DefaultSubscriptionBase subscription = new DefaultSubscriptionBase(builder);
+        testListener.pushExpectedEvents(NextEvent.CREATE);
         dao.createSubscription(subscription, ImmutableList.of(creationEvent), catalog, internalCallContext);
+        assertListenerStatus();
 
         // Operation Should now fail
         try {