Commit 451a59da authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade info a alertas de items bloqueados

parent a372b7b4

src/main/java/es/redmic/commandslib/aggregate/Aggregate.java

+1 −0
Original line number Diff line number Diff line
@@ -95,6 +95,7 @@ public abstract class Aggregate { 


			logger.error("Intentando modificar un elemento bloqueado por una edición en curso, ",

					event.getAggregateId());

			logger.error("Item bloqueado por un evento de tipo: " + event.getType());

			throw new ItemLockedException("id", event.getAggregateId());

		}

	}

src/main/java/es/redmic/commandslib/usersettings/aggregate/PersistenceAggregate.java

+1 −0
Original line number Diff line number Diff line
@@ -228,6 +228,7 @@ public class PersistenceAggregate extends Aggregate { 
			apply((SettingsCancelledEvent) event);

			break;

		default:

			logger.error("Item bloqueado por un evento de tipo: " + eventType);

			throw new ItemLockedException("id", event.getAggregateId());

		}

	}

src/main/java/es/redmic/commandslib/usersettings/aggregate/SelectionAggregate.java

+1 −0
Original line number Diff line number Diff line
@@ -168,6 +168,7 @@ public class SelectionAggregate extends Aggregate { 
			apply((SettingsCancelledEvent) event);

			break;

		default:

			logger.error("Item bloqueado por un evento de tipo: " + eventType);

			throw new ItemLockedException("id", event.getAggregateId());

		}

	}

src/main/java/es/redmic/commandslib/usersettings/handler/SettingsCommandHandler.java

+8 −8
Original line number Diff line number Diff line
@@ -143,7 +143,7 @@ public class SettingsCommandHandler extends CommandHandler { 
		try {

			event = agg.process(cmd);

		} catch (ItemLockedException e) {



			e.printStackTrace();

			unlockStatus(agg, cmd.getSelection().getId(), settingsTopic);

			throw e;

		}
@@ -167,7 +167,7 @@ public class SettingsCommandHandler extends CommandHandler { 
		try {

			event = agg.process(cmd);

		} catch (ItemLockedException e) {



			e.printStackTrace();

			unlockStatus(agg, cmd.getSelection().getId(), settingsTopic);

			throw e;

		}
@@ -191,7 +191,7 @@ public class SettingsCommandHandler extends CommandHandler { 
		try {

			event = agg.process(cmd);

		} catch (ItemLockedException e) {



			e.printStackTrace();

			unlockStatus(agg, cmd.getSelection().getId(), settingsTopic);

			throw e;

		}
@@ -215,7 +215,7 @@ public class SettingsCommandHandler extends CommandHandler { 
		try {

			event = agg.process(cmd);

		} catch (ItemLockedException e) {



			e.printStackTrace();

			unlockStatus(agg, cmd.getPersistence().getId(), settingsTopic);

			throw e;

		}
@@ -239,7 +239,7 @@ public class SettingsCommandHandler extends CommandHandler { 
		try {

			event = agg.process(cmd);

		} catch (ItemLockedException e) {



			e.printStackTrace();

			unlockStatus(agg, cmd.getPersistence().getId(), settingsTopic);

			throw e;

		}
@@ -263,7 +263,7 @@ public class SettingsCommandHandler extends CommandHandler { 
		try {

			event = agg.process(cmd);

		} catch (ItemLockedException e) {



			e.printStackTrace();

			unlockStatus(agg, cmd.getSettingsId(), settingsTopic);

			throw e;

		}
@@ -287,7 +287,7 @@ public class SettingsCommandHandler extends CommandHandler { 
		try {

			event = agg.process(cmd);

		} catch (ItemLockedException e) {



			e.printStackTrace();

			unlockStatus(agg, cmd.getPersistence().getId(), settingsTopic);

			throw e;

		}
@@ -313,7 +313,7 @@ public class SettingsCommandHandler extends CommandHandler { 
		try {

			event = agg.process(cmd);

		} catch (ItemLockedException e) {



			e.printStackTrace();

			unlockStatus(agg, cmd.getSettingsId(), settingsTopic);

			throw e;

		}