diff --git a/account/src/main/java/com/ning/billing/account/dao/DefaultAccountDao.java b/account/src/main/java/com/ning/billing/account/dao/DefaultAccountDao.java
index 0747ec1..6070945 100644
--- a/account/src/main/java/com/ning/billing/account/dao/DefaultAccountDao.java
+++ b/account/src/main/java/com/ning/billing/account/dao/DefaultAccountDao.java
@@ -139,12 +139,10 @@ public class DefaultAccountDao extends EntityDaoBase<AccountModelDao, Account, A
specifiedAccount,
context.getAccountRecordId(),
context.getTenantRecordId());
- if (changeEvent.hasChanges()) {
- try {
- eventBus.postFromTransaction(changeEvent, entitySqlDaoWrapperFactory, context);
- } catch (final EventBusException e) {
- log.warn("Failed to post account change event for account " + accountId, e);
- }
+ try {
+ eventBus.postFromTransaction(changeEvent, entitySqlDaoWrapperFactory, context);
+ } catch (final EventBusException e) {
+ log.warn("Failed to post account change event for account " + accountId, e);
}
return null;
@@ -170,12 +168,10 @@ public class DefaultAccountDao extends EntityDaoBase<AccountModelDao, Account, A
final AccountChangeInternalEvent changeEvent = new DefaultAccountChangeEvent(accountId, context.getUserToken(), currentAccount, account,
context.getAccountRecordId(), context.getTenantRecordId());
- if (changeEvent.hasChanges()) {
- try {
- eventBus.postFromTransaction(changeEvent, entitySqlDaoWrapperFactory, context);
- } catch (final EventBusException e) {
- log.warn("Failed to post account change event for account " + accountId, e);
- }
+ try {
+ eventBus.postFromTransaction(changeEvent, entitySqlDaoWrapperFactory, context);
+ } catch (final EventBusException e) {
+ log.warn("Failed to post account change event for account " + accountId, e);
}
return null;
}
diff --git a/util/src/main/java/com/ning/billing/util/events/AccountChangeInternalEvent.java b/util/src/main/java/com/ning/billing/util/events/AccountChangeInternalEvent.java
index ea3f5b6..14feb21 100644
--- a/util/src/main/java/com/ning/billing/util/events/AccountChangeInternalEvent.java
+++ b/util/src/main/java/com/ning/billing/util/events/AccountChangeInternalEvent.java
@@ -20,6 +20,7 @@ import java.util.List;
import java.util.UUID;
public interface AccountChangeInternalEvent extends BusInternalEvent {
+
public UUID getAccountId();
public List<ChangedField> getChangedFields();
