diff --git a/platform-parent/platform-imdg-api-hazelcast-impl/src/main/java/ru/spcex/platform/imdg/iml/hazelcast/adapter/ImdgHazelcast.java b/platform-parent/platform-imdg-api-hazelcast-impl/src/main/java/ru/spcex/platform/imdg/iml/hazelcast/adapter/ImdgHazelcast.java
index d60cadcdd..93b85cfce 100644
--- a/platform-parent/platform-imdg-api-hazelcast-impl/src/main/java/ru/spcex/platform/imdg/iml/hazelcast/adapter/ImdgHazelcast.java
+++ b/platform-parent/platform-imdg-api-hazelcast-impl/src/main/java/ru/spcex/platform/imdg/iml/hazelcast/adapter/ImdgHazelcast.java
@@ -28,6 +28,7 @@ public class ImdgHazelcast<T extends SpcexObjectBase> implements Imdg<T> {
 
     @Override
     public void insert(T paramT) {
-        map.put(idGenerator.newId(), paramT);
+        paramT.setId(idGenerator.newId());
+        map.put(paramT.getId(), paramT);
     }
 }
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 f8643da44..0afa160d9 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
@@ -39,11 +39,15 @@ public class QueueConsumer implements AutoCloseable {
             try {
                 consumer.subscribe(callbacks.keySet());
                 while (!closed.get()) {
-                    ConsumerRecords<String, Object> records = consumer.poll(Duration.of(10, ChronoUnit.SECONDS));
-                    for (ConsumerRecord<String, Object> next : records) {
-                        ConsumerSpecificClass<?> callback = callbacks.get(next.topic());
-                        Object o = json.readValue((String) next.value(), callback.getClazz());
-                        callback.acceptRaw(o);
+                    try {
+                        ConsumerRecords<String, Object> records = consumer.poll(Duration.of(10, ChronoUnit.SECONDS));
+                        for (ConsumerRecord<String, Object> next : records) {
+                            ConsumerSpecificClass<?> callback = callbacks.get(next.topic());
+                            Object o = json.readValue((String) next.value(), callback.getClazz());
+                            callback.acceptRaw(o);
+                        }
+                    } catch (Throwable e) {
+                        log.error(ExceptionUtils.getStackTrace(e));
                     }
                 }
             } catch (WakeupException e) {