diff --git a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/Consts.java b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/Consts.java
index 51410a656..c6c9f0d28 100644
--- a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/Consts.java
+++ b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/Consts.java
@@ -99,7 +99,6 @@ public interface Consts {
     String SDF11_PROCESS = "sdf11-process";
     String EXPORT_PROCESS = "export-process";
     String S_TRADES_IMPORTED = "s_trades-imported";
-    String ACCOUNT_NEW = "account-new";
     String ACCOUNT_TERMINATION = "account-termination";
     String BALANCE_ACCOUNT_NEW = "balance-account-new";
     String BALANCE_ACCOUNT_UPDATE = "balance-account-update";
diff --git a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumer.java b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumer.java
index 83a2d7ca5..0b26d5c03 100644
--- a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumer.java
+++ b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumer.java
@@ -80,6 +80,7 @@ public class QueueConsumer implements AutoCloseable {
                     consumer.subscribe(callbacks.keySet());
                 }
                 Object o = null;
+                int lastErrors = 0;
                 while (!closed.get()) {
                     try {
                         ConsumerRecords<String, Object> records = consumer.poll(Duration.of(10, ChronoUnit.SECONDS));
@@ -95,11 +96,21 @@ public class QueueConsumer implements AutoCloseable {
                                 }
                             }
                         }
+                        lastErrors = 0;
                     } catch (Throwable e) {
                         log.error(ExceptionUtils.getStackTrace(e));
                         if (producer != null && o != null) {
                             sendErrorResponse((BaseRequest<?>) o);
                         }
+                        if (lastErrors++ > 20) {
+                            log.warn("Too many error at row, {}. Sleep.", lastErrors);
+                            try {
+                                Thread.sleep(1000L);
+                            } catch (InterruptedException ie) {
+                                log.info("Thread interrupted. {}", ExceptionUtils.getStackTrace(ie));
+                                break;
+                            }
+                        }
                     }
                 }
             } catch (WakeupException e) {