private void rebuildSubscriptionAndNotifyBusOfEffectiveImmediateChange(final EntitySqlDaoWrapperFactory entitySqlDaoWrapperFactory, final DefaultSubscriptionBase subscription,
                                                                           final SubscriptionBaseEvent immediateEvent, final int seqId, final Catalog catalog, final InternalCallContext context) {
        try {
            // We need to rehydrate the subscription, as some events might have been canceled on disk (e.g. future PHASE after while doing a change plan)
            final List<SubscriptionBaseEvent> activeSubscriptionEvents = getEventsForSubscriptionInTransaction(entitySqlDaoWrapperFactory, subscription.getId(), context);
            subscription.rebuildTransitions(activeSubscriptionEvents, catalog);
            notifyBusOfEffectiveImmediateChange(entitySqlDaoWrapperFactory, subscription, immediateEvent, seqId, context);
        } catch (final CatalogApiException e) {
            log.warn("Failed to post effective event for subscriptionId='{}'", subscription.getId(), e);
        }
    }
private void rebuildSubscriptionAndNotifyBusOfEffectiveImmediateChange ( final EntitySqlDaoWrapperFactory entitySqlDaoWrapperFactory , final DefaultSubscriptionBase subscription , final SubscriptionBaseEvent immediateEvent , final int seqId , final Catalog catalog , final InternalCallContext context ) { try { final List < SubscriptionBaseEvent > activeSubscriptionEvents = getEventsForSubscriptionInTransaction ( entitySqlDaoWrapperFactory , subscription . getId ( ) , context ) ; subscription . rebuildTransitions ( activeSubscriptionEvents , catalog ) ; notifyBusOfEffectiveImmediateChange ( entitySqlDaoWrapperFactory , subscription , immediateEvent , seqId , context ) ; } catch ( final CatalogApiException e ) { log . warn ( "Failed to post effective event for subscriptionId='{}'" , subscription . getId ( ) , e ) ; } }
Sends bus notification for event on effective date -- only used for operation that happen immediately