diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/EndStageNotificationAction.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/EndStageNotificationAction.java
index 034e47f9e..f1348b1f2 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/EndStageNotificationAction.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/EndStageNotificationAction.java
@@ -55,7 +55,7 @@ public class EndStageNotificationAction extends AbstractSessionActionForOkErrorH
     @Override
     protected void actualExecute(StateContext<TaskType, SsnEvent> ctx) {
         Long sessionId = ctx.getExtendedState().get(DataEnum.sessionId, Long.class);
-        String section = ctx.getExtendedState().get(DataEnum.section, String.class);
+        Section section = ctx.getExtendedState().get(DataEnum.section, Section.class);
         // 1. Изменить статус
         Session theSession = sessionImdg.getSingleObjectByID(sessionId);
         if (theSession == null) {
@@ -79,9 +79,9 @@ public class EndStageNotificationAction extends AbstractSessionActionForOkErrorH
             log.trace("For registry group {} send notification",
                 groupId);
             Optional<EnumMessage> sResult;
-            if (Section.FOND.equalsByKey(section)) {
+            if (Section.FOND.equals(section)) {
                 sResult = notificationDF14(groupId);
-            } else if (Section.MKR.equalsByKey(section)) {
+            } else if (Section.MKR.equals(section)) {
                 sResult = notificationDF05(groupId);
             } else {
                 throw new IllegalArgumentException("Unsupported section " + section);