diff --git a/.gradle/8.4/checksums/checksums.lock b/.gradle/8.4/checksums/checksums.lock
index b01eae2..950eefd 100644
Binary files a/.gradle/8.4/checksums/checksums.lock and b/.gradle/8.4/checksums/checksums.lock differ
diff --git a/.gradle/8.4/checksums/md5-checksums.bin b/.gradle/8.4/checksums/md5-checksums.bin
index 1cf5320..ccfbbd9 100644
Binary files a/.gradle/8.4/checksums/md5-checksums.bin and b/.gradle/8.4/checksums/md5-checksums.bin differ
diff --git a/.gradle/8.4/checksums/sha1-checksums.bin b/.gradle/8.4/checksums/sha1-checksums.bin
index d8e573f..4e48acf 100644
Binary files a/.gradle/8.4/checksums/sha1-checksums.bin and b/.gradle/8.4/checksums/sha1-checksums.bin differ
diff --git a/.gradle/8.5/checksums/checksums.lock b/.gradle/8.5/checksums/checksums.lock
new file mode 100644
index 0000000..d154b7c
Binary files /dev/null and b/.gradle/8.5/checksums/checksums.lock differ
diff --git a/.gradle/8.5/checksums/md5-checksums.bin b/.gradle/8.5/checksums/md5-checksums.bin
new file mode 100644
index 0000000..81bd5cc
Binary files /dev/null and b/.gradle/8.5/checksums/md5-checksums.bin differ
diff --git a/.gradle/8.5/checksums/sha1-checksums.bin b/.gradle/8.5/checksums/sha1-checksums.bin
new file mode 100644
index 0000000..2e8c195
Binary files /dev/null and b/.gradle/8.5/checksums/sha1-checksums.bin differ
diff --git a/.gradle/8.5/dependencies-accessors/dependencies-accessors.lock b/.gradle/8.5/dependencies-accessors/dependencies-accessors.lock
new file mode 100644
index 0000000..d0f2888
Binary files /dev/null and b/.gradle/8.5/dependencies-accessors/dependencies-accessors.lock differ
diff --git a/.gradle/8.5/dependencies-accessors/gc.properties b/.gradle/8.5/dependencies-accessors/gc.properties
new file mode 100644
index 0000000..e69de29
diff --git a/.gradle/8.5/executionHistory/executionHistory.bin b/.gradle/8.5/executionHistory/executionHistory.bin
new file mode 100644
index 0000000..336b46a
Binary files /dev/null and b/.gradle/8.5/executionHistory/executionHistory.bin differ
diff --git a/.gradle/8.5/executionHistory/executionHistory.lock b/.gradle/8.5/executionHistory/executionHistory.lock
new file mode 100644
index 0000000..8df2d3f
Binary files /dev/null and b/.gradle/8.5/executionHistory/executionHistory.lock differ
diff --git a/.gradle/8.5/fileChanges/last-build.bin b/.gradle/8.5/fileChanges/last-build.bin
new file mode 100644
index 0000000..f76dd23
Binary files /dev/null and b/.gradle/8.5/fileChanges/last-build.bin differ
diff --git a/.gradle/8.5/fileHashes/fileHashes.bin b/.gradle/8.5/fileHashes/fileHashes.bin
new file mode 100644
index 0000000..036dc7c
Binary files /dev/null and b/.gradle/8.5/fileHashes/fileHashes.bin differ
diff --git a/.gradle/8.5/fileHashes/fileHashes.lock b/.gradle/8.5/fileHashes/fileHashes.lock
new file mode 100644
index 0000000..1d87d7e
Binary files /dev/null and b/.gradle/8.5/fileHashes/fileHashes.lock differ
diff --git a/.gradle/8.5/fileHashes/resourceHashesCache.bin b/.gradle/8.5/fileHashes/resourceHashesCache.bin
new file mode 100644
index 0000000..a20392a
Binary files /dev/null and b/.gradle/8.5/fileHashes/resourceHashesCache.bin differ
diff --git a/.gradle/8.5/gc.properties b/.gradle/8.5/gc.properties
new file mode 100644
index 0000000..e69de29
diff --git a/.gradle/buildOutputCleanup/buildOutputCleanup.lock b/.gradle/buildOutputCleanup/buildOutputCleanup.lock
index c05759e..3d7d304 100644
Binary files a/.gradle/buildOutputCleanup/buildOutputCleanup.lock and b/.gradle/buildOutputCleanup/buildOutputCleanup.lock differ
diff --git a/.gradle/buildOutputCleanup/cache.properties b/.gradle/buildOutputCleanup/cache.properties
index 674ef95..ac1afda 100644
--- a/.gradle/buildOutputCleanup/cache.properties
+++ b/.gradle/buildOutputCleanup/cache.properties
@@ -1,2 +1,2 @@
-#Tue Apr 09 14:58:45 MSK 2024
-gradle.version=8.4
+#Tue Dec 23 04:28:23 MSK 2025
+gradle.version=8.5
diff --git a/.gradle/buildOutputCleanup/outputFiles.bin b/.gradle/buildOutputCleanup/outputFiles.bin
index 17f893c..1f258ff 100644
Binary files a/.gradle/buildOutputCleanup/outputFiles.bin and b/.gradle/buildOutputCleanup/outputFiles.bin differ
diff --git a/.gradle/file-system.probe b/.gradle/file-system.probe
index cec7bc0..41e2ae5 100644
Binary files a/.gradle/file-system.probe and b/.gradle/file-system.probe differ
diff --git a/.idea/gradle.xml b/.idea/gradle.xml
index f9163b4..ce1c62c 100644
--- a/.idea/gradle.xml
+++ b/.idea/gradle.xml
@@ -1,5 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
+  <component name="GradleMigrationSettings" migrationVersion="1" />
   <component name="GradleSettings">
     <option name="linkedExternalProjectsSettings">
       <GradleProjectSettings>
diff --git a/.idea/modules.xml b/.idea/modules.xml
deleted file mode 100644
index 5c567f2..0000000
--- a/.idea/modules.xml
+++ /dev/null
@@ -1,9 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="ProjectModuleManager">
-    <modules>
-      <module fileurl="file://$PROJECT_DIR$/.idea/modules/lab_3.main.iml" filepath="$PROJECT_DIR$/.idea/modules/lab_3.main.iml" />
-      <module fileurl="file://$PROJECT_DIR$/.idea/modules/lab_3.test.iml" filepath="$PROJECT_DIR$/.idea/modules/lab_3.test.iml" />
-    </modules>
-  </component>
-</project>
\ No newline at end of file
diff --git a/README.md b/README.md
index 97f8c85..98999e5 100644
--- a/README.md
+++ b/README.md
@@ -1,3 +1,4 @@
+[![Review Assignment Due Date](https://classroom.github.com/assets/deadline-readme-button-22041afd0340ce965d47ae6ef1cefeee28c7c493a6346c4f15d667ab976d596c.svg)](https://classroom.github.com/a/QODoQuhO)
 # Распределенная обработка текстовых данных с использованием брокера сообщений
 
 ## Цель задания:
diff --git a/build.gradle.kts b/build.gradle.kts
index 8e91d96..18faa93 100644
--- a/build.gradle.kts
+++ b/build.gradle.kts
@@ -1,5 +1,6 @@
 plugins {
     kotlin("jvm") version "1.9.20"
+    java
     application
 }
 
@@ -11,8 +12,9 @@ repositories {
 }
 
 dependencies {
-    implementation("javax.jms:jms-api:2.0.1")
+    implementation("com.rabbitmq:amqp-client:5.27.1")
     implementation("org.apache.activemq:activemq-broker:6.1.1")
+    implementation("com.fasterxml.jackson.core:jackson-databind:2.17.1")
     testImplementation(kotlin("test"))
 }
 
@@ -25,5 +27,5 @@ kotlin {
 }
 
 application {
-    mainClass.set("MainKt")
+    mainClass.set("Main")
 }
\ No newline at end of file
diff --git a/build/classes/java/main/AggregatorApp.class b/build/classes/java/main/AggregatorApp.class
new file mode 100644
index 0000000..550cfa0
Binary files /dev/null and b/build/classes/java/main/AggregatorApp.class differ
diff --git a/build/classes/java/main/JobState.class b/build/classes/java/main/JobState.class
new file mode 100644
index 0000000..afdeed6
Binary files /dev/null and b/build/classes/java/main/JobState.class differ
diff --git a/build/classes/java/main/Main.class b/build/classes/java/main/Main.class
new file mode 100644
index 0000000..93e376a
Binary files /dev/null and b/build/classes/java/main/Main.class differ
diff --git a/build/classes/java/main/ProducerApp.class b/build/classes/java/main/ProducerApp.class
new file mode 100644
index 0000000..b9b4e9b
Binary files /dev/null and b/build/classes/java/main/ProducerApp.class differ
diff --git a/build/classes/java/main/RabbitConfig.class b/build/classes/java/main/RabbitConfig.class
new file mode 100644
index 0000000..df6a002
Binary files /dev/null and b/build/classes/java/main/RabbitConfig.class differ
diff --git a/build/classes/java/main/WorkerApp.class b/build/classes/java/main/WorkerApp.class
new file mode 100644
index 0000000..2b44888
Binary files /dev/null and b/build/classes/java/main/WorkerApp.class differ
diff --git a/build/classes/java/main/WorkerLauncher.class b/build/classes/java/main/WorkerLauncher.class
new file mode 100644
index 0000000..e4bfe4a
Binary files /dev/null and b/build/classes/java/main/WorkerLauncher.class differ
diff --git a/build/classes/java/main/analyzers/NameAnonymizer.class b/build/classes/java/main/analyzers/NameAnonymizer.class
new file mode 100644
index 0000000..594fbfc
Binary files /dev/null and b/build/classes/java/main/analyzers/NameAnonymizer.class differ
diff --git a/build/classes/java/main/analyzers/SentenceSorter.class b/build/classes/java/main/analyzers/SentenceSorter.class
new file mode 100644
index 0000000..a9222fd
Binary files /dev/null and b/build/classes/java/main/analyzers/SentenceSorter.class differ
diff --git a/build/classes/java/main/analyzers/SentimentAnalyzer.class b/build/classes/java/main/analyzers/SentimentAnalyzer.class
new file mode 100644
index 0000000..e664b8a
Binary files /dev/null and b/build/classes/java/main/analyzers/SentimentAnalyzer.class differ
diff --git a/build/classes/java/main/analyzers/WordCounter.class b/build/classes/java/main/analyzers/WordCounter.class
new file mode 100644
index 0000000..cdfe411
Binary files /dev/null and b/build/classes/java/main/analyzers/WordCounter.class differ
diff --git a/build/classes/java/main/analyzers/WordFrequency.class b/build/classes/java/main/analyzers/WordFrequency.class
new file mode 100644
index 0000000..ede7d55
Binary files /dev/null and b/build/classes/java/main/analyzers/WordFrequency.class differ
diff --git a/build/classes/java/main/entity/Counters.class b/build/classes/java/main/entity/Counters.class
new file mode 100644
index 0000000..7a6a657
Binary files /dev/null and b/build/classes/java/main/entity/Counters.class differ
diff --git a/build/classes/java/main/entity/ResultMessage.class b/build/classes/java/main/entity/ResultMessage.class
new file mode 100644
index 0000000..62f0018
Binary files /dev/null and b/build/classes/java/main/entity/ResultMessage.class differ
diff --git a/build/classes/java/main/entity/TaskMessage.class b/build/classes/java/main/entity/TaskMessage.class
new file mode 100644
index 0000000..c8243f2
Binary files /dev/null and b/build/classes/java/main/entity/TaskMessage.class differ
diff --git a/build/classes/java/main/utils/JsonUtils.class b/build/classes/java/main/utils/JsonUtils.class
new file mode 100644
index 0000000..4a7b6dc
Binary files /dev/null and b/build/classes/java/main/utils/JsonUtils.class differ
diff --git a/build/classes/java/main/utils/TextSplitter.class b/build/classes/java/main/utils/TextSplitter.class
new file mode 100644
index 0000000..a106d8d
Binary files /dev/null and b/build/classes/java/main/utils/TextSplitter.class differ
diff --git a/build/distributions/lab2-froggeisnotagoodprogge-1.0-SNAPSHOT.tar b/build/distributions/lab2-froggeisnotagoodprogge-1.0-SNAPSHOT.tar
new file mode 100644
index 0000000..0306002
Binary files /dev/null and b/build/distributions/lab2-froggeisnotagoodprogge-1.0-SNAPSHOT.tar differ
diff --git a/build/distributions/lab2-froggeisnotagoodprogge-1.0-SNAPSHOT.zip b/build/distributions/lab2-froggeisnotagoodprogge-1.0-SNAPSHOT.zip
new file mode 100644
index 0000000..3cd7195
Binary files /dev/null and b/build/distributions/lab2-froggeisnotagoodprogge-1.0-SNAPSHOT.zip differ
diff --git a/build/libs/lab2-froggeisnotagoodprogge-1.0-SNAPSHOT.jar b/build/libs/lab2-froggeisnotagoodprogge-1.0-SNAPSHOT.jar
new file mode 100644
index 0000000..fdcd31b
Binary files /dev/null and b/build/libs/lab2-froggeisnotagoodprogge-1.0-SNAPSHOT.jar differ
diff --git a/build/scripts/lab2-froggeisnotagoodprogge b/build/scripts/lab2-froggeisnotagoodprogge
new file mode 100755
index 0000000..5758aac
--- /dev/null
+++ b/build/scripts/lab2-froggeisnotagoodprogge
@@ -0,0 +1,248 @@
+#!/bin/sh
+
+#
+# Copyright © 2015-2021 the original authors.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+##############################################################################
+#
+#   lab2-froggeisnotagoodprogge start up script for POSIX generated by Gradle.
+#
+#   Important for running:
+#
+#   (1) You need a POSIX-compliant shell to run this script. If your /bin/sh is
+#       noncompliant, but you have some other compliant shell such as ksh or
+#       bash, then to run this script, type that shell name before the whole
+#       command line, like:
+#
+#           ksh lab2-froggeisnotagoodprogge
+#
+#       Busybox and similar reduced shells will NOT work, because this script
+#       requires all of these POSIX shell features:
+#         * functions;
+#         * expansions «$var», «${var}», «${var:-default}», «${var+SET}»,
+#           «${var#prefix}», «${var%suffix}», and «$( cmd )»;
+#         * compound commands having a testable exit status, especially «case»;
+#         * various built-in commands including «command», «set», and «ulimit».
+#
+#   Important for patching:
+#
+#   (2) This script targets any POSIX shell, so it avoids extensions provided
+#       by Bash, Ksh, etc; in particular arrays are avoided.
+#
+#       The "traditional" practice of packing multiple parameters into a
+#       space-separated string is a well documented source of bugs and security
+#       problems, so this is (mostly) avoided, by progressively accumulating
+#       options in "$@", and eventually passing that to Java.
+#
+#       Where the inherited environment variables (DEFAULT_JVM_OPTS, JAVA_OPTS,
+#       and LAB2_FROGGEISNOTAGOODPROGGE_OPTS) rely on word-splitting, this is performed explicitly;
+#       see the in-line comments for details.
+#
+#       There are tweaks for specific operating systems such as AIX, CygWin,
+#       Darwin, MinGW, and NonStop.
+#
+#   (3) This script is generated from the Groovy template
+#       https://github.com/gradle/gradle/blob/HEAD/subprojects/plugins/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt
+#       within the Gradle project.
+#
+#       You can find Gradle at https://github.com/gradle/gradle/.
+#
+##############################################################################
+
+# Attempt to set APP_HOME
+
+# Resolve links: $0 may be a link
+app_path=$0
+
+# Need this for daisy-chained symlinks.
+while
+    APP_HOME=${app_path%"${app_path##*/}"}  # leaves a trailing /; empty if no leading path
+    [ -h "$app_path" ]
+do
+    ls=$( ls -ld "$app_path" )
+    link=${ls#*' -> '}
+    case $link in             #(
+      /*)   app_path=$link ;; #(
+      *)    app_path=$APP_HOME$link ;;
+    esac
+done
+
+# This is normally unused
+# shellcheck disable=SC2034
+APP_BASE_NAME=${0##*/}
+# Discard cd standard output in case $CDPATH is set (https://github.com/gradle/gradle/issues/25036)
+APP_HOME=$( cd "${APP_HOME:-./}.." > /dev/null && pwd -P ) || exit
+
+# Use the maximum available, or set MAX_FD != -1 to use that value.
+MAX_FD=maximum
+
+warn () {
+    echo "$*"
+} >&2
+
+die () {
+    echo
+    echo "$*"
+    echo
+    exit 1
+} >&2
+
+# OS specific support (must be 'true' or 'false').
+cygwin=false
+msys=false
+darwin=false
+nonstop=false
+case "$( uname )" in                #(
+  CYGWIN* )         cygwin=true  ;; #(
+  Darwin* )         darwin=true  ;; #(
+  MSYS* | MINGW* )  msys=true    ;; #(
+  NONSTOP* )        nonstop=true ;;
+esac
+
+CLASSPATH=$APP_HOME/lib/lab2-froggeisnotagoodprogge-1.0-SNAPSHOT.jar:$APP_HOME/lib/kotlin-stdlib-1.9.20.jar:$APP_HOME/lib/amqp-client-5.27.1.jar:$APP_HOME/lib/activemq-broker-6.1.1.jar:$APP_HOME/lib/annotations-13.0.jar:$APP_HOME/lib/activemq-openwire-legacy-6.1.1.jar:$APP_HOME/lib/activemq-client-6.1.1.jar:$APP_HOME/lib/slf4j-api-2.0.12.jar:$APP_HOME/lib/netty-codec-4.2.7.Final.jar:$APP_HOME/lib/netty-handler-4.2.7.Final.jar:$APP_HOME/lib/netty-codec-compression-4.2.7.Final.jar:$APP_HOME/lib/netty-codec-protobuf-4.2.7.Final.jar:$APP_HOME/lib/netty-codec-marshalling-4.2.7.Final.jar:$APP_HOME/lib/netty-codec-base-4.2.7.Final.jar:$APP_HOME/lib/netty-transport-native-unix-common-4.2.7.Final.jar:$APP_HOME/lib/netty-transport-4.2.7.Final.jar:$APP_HOME/lib/jakarta.annotation-api-2.1.1.jar:$APP_HOME/lib/jackson-annotations-2.16.2.jar:$APP_HOME/lib/jackson-core-2.16.2.jar:$APP_HOME/lib/jackson-databind-2.16.2.jar:$APP_HOME/lib/netty-buffer-4.2.7.Final.jar:$APP_HOME/lib/netty-resolver-4.2.7.Final.jar:$APP_HOME/lib/netty-common-4.2.7.Final.jar:$APP_HOME/lib/jakarta.jms-api-3.1.0.jar:$APP_HOME/lib/hawtbuf-1.11.jar
+
+
+# Determine the Java command to use to start the JVM.
+if [ -n "$JAVA_HOME" ] ; then
+    if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+        # IBM's JDK on AIX uses strange locations for the executables
+        JAVACMD=$JAVA_HOME/jre/sh/java
+    else
+        JAVACMD=$JAVA_HOME/bin/java
+    fi
+    if [ ! -x "$JAVACMD" ] ; then
+        die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+else
+    JAVACMD=java
+    if ! command -v java >/dev/null 2>&1
+    then
+        die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+fi
+
+# Increase the maximum file descriptors if we can.
+if ! "$cygwin" && ! "$darwin" && ! "$nonstop" ; then
+    case $MAX_FD in #(
+      max*)
+        # In POSIX sh, ulimit -H is undefined. That's why the result is checked to see if it worked.
+        # shellcheck disable=SC2039,SC3045
+        MAX_FD=$( ulimit -H -n ) ||
+            warn "Could not query maximum file descriptor limit"
+    esac
+    case $MAX_FD in  #(
+      '' | soft) :;; #(
+      *)
+        # In POSIX sh, ulimit -n is undefined. That's why the result is checked to see if it worked.
+        # shellcheck disable=SC2039,SC3045
+        ulimit -n "$MAX_FD" ||
+            warn "Could not set maximum file descriptor limit to $MAX_FD"
+    esac
+fi
+
+# Collect all arguments for the java command, stacking in reverse order:
+#   * args from the command line
+#   * the main class name
+#   * -classpath
+#   * -D...appname settings
+#   * --module-path (only if needed)
+#   * DEFAULT_JVM_OPTS, JAVA_OPTS, and LAB2_FROGGEISNOTAGOODPROGGE_OPTS environment variables.
+
+# For Cygwin or MSYS, switch paths to Windows format before running java
+if "$cygwin" || "$msys" ; then
+    APP_HOME=$( cygpath --path --mixed "$APP_HOME" )
+    CLASSPATH=$( cygpath --path --mixed "$CLASSPATH" )
+
+    JAVACMD=$( cygpath --unix "$JAVACMD" )
+
+    # Now convert the arguments - kludge to limit ourselves to /bin/sh
+    for arg do
+        if
+            case $arg in                                #(
+              -*)   false ;;                            # don't mess with options #(
+              /?*)  t=${arg#/} t=/${t%%/*}              # looks like a POSIX filepath
+                    [ -e "$t" ] ;;                      #(
+              *)    false ;;
+            esac
+        then
+            arg=$( cygpath --path --ignore --mixed "$arg" )
+        fi
+        # Roll the args list around exactly as many times as the number of
+        # args, so each arg winds up back in the position where it started, but
+        # possibly modified.
+        #
+        # NB: a `for` loop captures its iteration list before it begins, so
+        # changing the positional parameters here affects neither the number of
+        # iterations, nor the values presented in `arg`.
+        shift                   # remove old arg
+        set -- "$@" "$arg"      # push replacement arg
+    done
+fi
+
+
+# Add default JVM options here. You can also use JAVA_OPTS and LAB2_FROGGEISNOTAGOODPROGGE_OPTS to pass JVM options to this script.
+DEFAULT_JVM_OPTS=""
+
+# Collect all arguments for the java command:
+#   * DEFAULT_JVM_OPTS, JAVA_OPTS, JAVA_OPTS, and optsEnvironmentVar are not allowed to contain shell fragments,
+#     and any embedded shellness will be escaped.
+#   * For example: A user cannot expect ${Hostname} to be expanded, as it is an environment variable and will be
+#     treated as '${Hostname}' itself on the command line.
+
+set -- \
+        -classpath "$CLASSPATH" \
+        Main \
+        "$@"
+
+# Stop when "xargs" is not available.
+if ! command -v xargs >/dev/null 2>&1
+then
+    die "xargs is not available"
+fi
+
+# Use "xargs" to parse quoted args.
+#
+# With -n1 it outputs one arg per line, with the quotes and backslashes removed.
+#
+# In Bash we could simply go:
+#
+#   readarray ARGS < <( xargs -n1 <<<"$var" ) &&
+#   set -- "${ARGS[@]}" "$@"
+#
+# but POSIX shell has neither arrays nor command substitution, so instead we
+# post-process each arg (as a line of input to sed) to backslash-escape any
+# character that might be a shell metacharacter, then use eval to reverse
+# that process (while maintaining the separation between arguments), and wrap
+# the whole thing up as a single "set" statement.
+#
+# This will of course break if any of these variables contains a newline or
+# an unmatched quote.
+#
+
+eval "set -- $(
+        printf '%s\n' "$DEFAULT_JVM_OPTS $JAVA_OPTS $LAB2_FROGGEISNOTAGOODPROGGE_OPTS" |
+        xargs -n1 |
+        sed ' s~[^-[:alnum:]+,./:=@_]~\\&~g; ' |
+        tr '\n' ' '
+    )" '"$@"'
+
+exec "$JAVACMD" "$@"
diff --git a/build/scripts/lab2-froggeisnotagoodprogge.bat b/build/scripts/lab2-froggeisnotagoodprogge.bat
new file mode 100644
index 0000000..6599e85
--- /dev/null
+++ b/build/scripts/lab2-froggeisnotagoodprogge.bat
@@ -0,0 +1,92 @@
+@rem
+@rem Copyright 2015 the original author or authors.
+@rem
+@rem Licensed under the Apache License, Version 2.0 (the "License");
+@rem you may not use this file except in compliance with the License.
+@rem You may obtain a copy of the License at
+@rem
+@rem      https://www.apache.org/licenses/LICENSE-2.0
+@rem
+@rem Unless required by applicable law or agreed to in writing, software
+@rem distributed under the License is distributed on an "AS IS" BASIS,
+@rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+@rem See the License for the specific language governing permissions and
+@rem limitations under the License.
+@rem
+
+@if "%DEBUG%"=="" @echo off
+@rem ##########################################################################
+@rem
+@rem  lab2-froggeisnotagoodprogge startup script for Windows
+@rem
+@rem ##########################################################################
+
+@rem Set local scope for the variables with windows NT shell
+if "%OS%"=="Windows_NT" setlocal
+
+set DIRNAME=%~dp0
+if "%DIRNAME%"=="" set DIRNAME=.
+@rem This is normally unused
+set APP_BASE_NAME=%~n0
+set APP_HOME=%DIRNAME%..
+
+@rem Resolve any "." and ".." in APP_HOME to make it shorter.
+for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi
+
+@rem Add default JVM options here. You can also use JAVA_OPTS and LAB2_FROGGEISNOTAGOODPROGGE_OPTS to pass JVM options to this script.
+set DEFAULT_JVM_OPTS=
+
+@rem Find java.exe
+if defined JAVA_HOME goto findJavaFromJavaHome
+
+set JAVA_EXE=java.exe
+%JAVA_EXE% -version >NUL 2>&1
+if %ERRORLEVEL% equ 0 goto execute
+
+echo.
+echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:findJavaFromJavaHome
+set JAVA_HOME=%JAVA_HOME:"=%
+set JAVA_EXE=%JAVA_HOME%/bin/java.exe
+
+if exist "%JAVA_EXE%" goto execute
+
+echo.
+echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME%
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:execute
+@rem Setup the command line
+
+set CLASSPATH=%APP_HOME%\lib\lab2-froggeisnotagoodprogge-1.0-SNAPSHOT.jar;%APP_HOME%\lib\kotlin-stdlib-1.9.20.jar;%APP_HOME%\lib\amqp-client-5.27.1.jar;%APP_HOME%\lib\activemq-broker-6.1.1.jar;%APP_HOME%\lib\annotations-13.0.jar;%APP_HOME%\lib\activemq-openwire-legacy-6.1.1.jar;%APP_HOME%\lib\activemq-client-6.1.1.jar;%APP_HOME%\lib\slf4j-api-2.0.12.jar;%APP_HOME%\lib\netty-codec-4.2.7.Final.jar;%APP_HOME%\lib\netty-handler-4.2.7.Final.jar;%APP_HOME%\lib\netty-codec-compression-4.2.7.Final.jar;%APP_HOME%\lib\netty-codec-protobuf-4.2.7.Final.jar;%APP_HOME%\lib\netty-codec-marshalling-4.2.7.Final.jar;%APP_HOME%\lib\netty-codec-base-4.2.7.Final.jar;%APP_HOME%\lib\netty-transport-native-unix-common-4.2.7.Final.jar;%APP_HOME%\lib\netty-transport-4.2.7.Final.jar;%APP_HOME%\lib\jakarta.annotation-api-2.1.1.jar;%APP_HOME%\lib\jackson-annotations-2.16.2.jar;%APP_HOME%\lib\jackson-core-2.16.2.jar;%APP_HOME%\lib\jackson-databind-2.16.2.jar;%APP_HOME%\lib\netty-buffer-4.2.7.Final.jar;%APP_HOME%\lib\netty-resolver-4.2.7.Final.jar;%APP_HOME%\lib\netty-common-4.2.7.Final.jar;%APP_HOME%\lib\jakarta.jms-api-3.1.0.jar;%APP_HOME%\lib\hawtbuf-1.11.jar
+
+
+@rem Execute lab2-froggeisnotagoodprogge
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %LAB2_FROGGEISNOTAGOODPROGGE_OPTS%  -classpath "%CLASSPATH%" Main %*
+
+:end
+@rem End local scope for the variables with windows NT shell
+if %ERRORLEVEL% equ 0 goto mainEnd
+
+:fail
+rem Set variable LAB2_FROGGEISNOTAGOODPROGGE_EXIT_CONSOLE if you need the _script_ return code instead of
+rem the _cmd.exe /c_ return code!
+set EXIT_CODE=%ERRORLEVEL%
+if %EXIT_CODE% equ 0 set EXIT_CODE=1
+if not ""=="%LAB2_FROGGEISNOTAGOODPROGGE_EXIT_CONSOLE%" exit %EXIT_CODE%
+exit /b %EXIT_CODE%
+
+:mainEnd
+if "%OS%"=="Windows_NT" endlocal
+
+:omega
diff --git a/build/tmp/compileJava/compileTransaction/stash-dir/AggregatorApp.class.uniqueId0 b/build/tmp/compileJava/compileTransaction/stash-dir/AggregatorApp.class.uniqueId0
new file mode 100644
index 0000000..455c233
Binary files /dev/null and b/build/tmp/compileJava/compileTransaction/stash-dir/AggregatorApp.class.uniqueId0 differ
diff --git a/build/tmp/compileJava/previous-compilation-data.bin b/build/tmp/compileJava/previous-compilation-data.bin
new file mode 100644
index 0000000..24af62c
Binary files /dev/null and b/build/tmp/compileJava/previous-compilation-data.bin differ
diff --git a/build/tmp/jar/MANIFEST.MF b/build/tmp/jar/MANIFEST.MF
new file mode 100644
index 0000000..59499bc
--- /dev/null
+++ b/build/tmp/jar/MANIFEST.MF
@@ -0,0 +1,2 @@
+Manifest-Version: 1.0
+
diff --git a/gradle/wrapper/gradle-wrapper.jar b/gradle/wrapper/gradle-wrapper.jar
index 7f93135..d64cd49 100644
Binary files a/gradle/wrapper/gradle-wrapper.jar and b/gradle/wrapper/gradle-wrapper.jar differ
diff --git a/gradle/wrapper/gradle-wrapper.properties b/gradle/wrapper/gradle-wrapper.properties
index 3fa8f86..1af9e09 100644
--- a/gradle/wrapper/gradle-wrapper.properties
+++ b/gradle/wrapper/gradle-wrapper.properties
@@ -1,6 +1,6 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-8.4-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.5-bin.zip
 networkTimeout=10000
 validateDistributionUrl=true
 zipStoreBase=GRADLE_USER_HOME
diff --git a/input.txt b/input.txt
new file mode 100644
index 0000000..7dec6bf
--- /dev/null
+++ b/input.txt
@@ -0,0 +1,15 @@
+Alice was beginning to get very tired of sitting by her sister on the bank,
+and of having nothing to do: once or twice she had peeped into the book her
+sister was reading, but it had no pictures or conversations in it.
+
+So she was considering in her own mind whether the pleasure of making a
+daisy-chain would be worth the trouble of getting up and picking the daisies,
+when suddenly a White Rabbit with pink eyes ran close by her.
+
+Alice was beginning to get very tired of sitting by her sister on the bank,
+and of having nothing to do: once or twice she had peeped into the book her
+sister was reading, but it had no pictures or conversations in it.
+
+So she was considering in her own mind whether the pleasure of making a
+daisy-chain would be worth the trouble of getting up and picking the daisies,
+when suddenly a White Rabbit with pink eyes ran close by her.
\ No newline at end of file
diff --git a/job_job-1_report.json b/job_job-1_report.json
new file mode 100644
index 0000000..8f850c6
--- /dev/null
+++ b/job_job-1_report.json
@@ -0,0 +1,94 @@
+{
+  "totalSections" : 18,
+  "received" : 18,
+  "totalWordCount" : 179,
+  "globalWordFreq" : {
+    "but" : 2,
+    "very" : 2,
+    "own" : 2,
+    "alice" : 2,
+    "had" : 4,
+    "do" : 2,
+    "when" : 2,
+    "bank" : 2,
+    "would" : 2,
+    "white" : 2,
+    "her" : 7,
+    "whether" : 2,
+    "rabbit" : 2,
+    "up" : 2,
+    "ith" : 1,
+    "ran" : 2,
+    "sister" : 4,
+    "making" : 2,
+    "peeped" : 2,
+    "read" : 1,
+    "having" : 2,
+    "in" : 4,
+    "considering" : 2,
+    "pleasure" : 2,
+    "nothing" : 2,
+    "it" : 4,
+    "picking" : 1,
+    "wort" : 1,
+    "she" : 4,
+    "twice" : 1,
+    "once" : 2,
+    "ng" : 1,
+    "no" : 2,
+    "pink" : 2,
+    "be" : 2,
+    "beginning" : 1,
+    "ain" : 1,
+    "book" : 2,
+    "conversations" : 1,
+    "eyes" : 2,
+    "pictures" : 2,
+    "worth" : 1,
+    "getting" : 2,
+    "into" : 2,
+    "and" : 4,
+    "by" : 3,
+    "nversations" : 1,
+    "get" : 2,
+    "of" : 8,
+    "trouble" : 2,
+    "so" : 2,
+    "daisy" : 2,
+    "close" : 2,
+    "on" : 2,
+    "a" : 4,
+    "mind" : 2,
+    "chain" : 1,
+    "daisies" : 1,
+    "b" : 1,
+    "ing" : 1,
+    "icking" : 1,
+    "or" : 4,
+    "e" : 1,
+    "ch" : 1,
+    "h" : 1,
+    "tired" : 2,
+    "was" : 6,
+    "reading" : 1,
+    "twic" : 1,
+    "co" : 1,
+    "suddenly" : 2,
+    "daisie" : 1,
+    "p" : 1,
+    "the" : 9,
+    "with" : 1,
+    "r" : 1,
+    "s" : 1,
+    "t" : 1,
+    "w" : 1,
+    "y" : 1,
+    "to" : 4,
+    "beginni" : 1,
+    "he" : 2,
+    "sitting" : 2
+  },
+  "totalSentiment" : 4,
+  "anonymizedText" : "y her sister on the bank,\nand of having nothing to\n<NAME> was beginning to get very tired of sitting b\n do: once or twice she had peeped into the book he\nr\nsister was reading, but it had no pictures or co\nown mind whether the pleasure of making a\ndaisy-ch\nnversations in it.\n\n<NAME> she was considering in her \nicking the daisies,\nwhen suddenly a <NAME> <NAME> w\nain would be worth the trouble of getting up and p\nith pink eyes ran close by her.\n\n<NAME> was beginni\nng to get very tired of sitting by her sister on t\ne she had peeped into the book her\nsister was read\nhe bank,\nand of having nothing to do: once or twic\ning, but it had no pictures or conversations in it\n.\n\n<NAME> she was considering in her own mind whether \nthe pleasure of making a\ndaisy-chain would be wort\nh the trouble of getting up and picking the daisie\n close by her.\ns,\nwhen suddenly a <NAME> <NAME> with pink eyes ran\n",
+  "sortedSentences" : [ "y her sister on the bank,\nand of having nothing to", "Alice was beginning to get very tired of sitting b", " do: once or twice she had peeped into the book he", "r\nsister was reading, but it had no pictures or co", "own mind whether the pleasure of making a\ndaisy-ch", "nversations in it.", "So she was considering in her ", "icking the daisies,\nwhen suddenly a White Rabbit w", "ain would be worth the trouble of getting up and p", "Alice was beginni", "ith pink eyes ran close by her.", "ng to get very tired of sitting by her sister on t", "e she had peeped into the book her\nsister was read", "he bank,\nand of having nothing to do: once or twic", "ing, but it had no pictures or conversations in it", ".", "So she was considering in her own mind whether ", "the pleasure of making a\ndaisy-chain would be wort", "h the trouble of getting up and picking the daisie", " close by her.", "s,\nwhen suddenly a White Rabbit with pink eyes ran" ]
+}
\ No newline at end of file
diff --git a/src/main/java/AggregatorApp.java b/src/main/java/AggregatorApp.java
new file mode 100644
index 0000000..cbb5352
--- /dev/null
+++ b/src/main/java/AggregatorApp.java
@@ -0,0 +1,69 @@
+import com.rabbitmq.client.*;
+import entity.Counters;
+import entity.ResultMessage;
+import utils.JsonUtils;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+public class AggregatorApp {
+
+    private static final Map<String, JobState> jobs = new ConcurrentHashMap<>();
+
+    public static void main(String[] args) throws Exception {
+
+        ConnectionFactory factory = new ConnectionFactory();
+        factory.setHost(RabbitConfig.HOST);
+
+        Connection connection = factory.newConnection();
+        Channel channel = connection.createChannel();
+
+        channel.exchangeDeclare(RabbitConfig.RESULTS_EXCHANGE, BuiltinExchangeType.DIRECT, true);
+        channel.queueDeclare(RabbitConfig.RESULTS_QUEUE, true, false, false, null);
+        channel.queueBind(
+                RabbitConfig.RESULTS_QUEUE,
+                RabbitConfig.RESULTS_EXCHANGE,
+                RabbitConfig.RESULTS_ROUTING_KEY
+        );
+
+
+        DeliverCallback callback = (tag, delivery) -> {
+            ResultMessage result =
+                    JsonUtils.fromJsonBytes(delivery.getBody(), ResultMessage.class);
+
+            JobState state = jobs.computeIfAbsent(result.jobId, id -> {
+                JobState js = new JobState(result.totalSections);
+                return js;
+            });
+
+            Counters counters = result.counters;
+
+            state.totalWordCount.addAndGet(counters.wordCount);
+
+            counters.wordFreq.forEach((word, count) ->
+                                              state.globalWordFreq.merge(word, count, Integer::sum));
+
+            state.totalSentiment.addAndGet(counters.sentimentScore);
+
+            state.anonymizedText.append(counters.anonymizedText).append("\n");
+
+            state.sortedSentences.addAll(counters.sortedSentences);
+
+            int received = state.received.incrementAndGet();
+            if (received == state.totalSections) {
+                System.out.println("==== JOB FINISHED ====");
+                System.out.println("Total words: " + state.totalWordCount.get());
+                System.out.println("Top words: " + JobState.getTopN(state.globalWordFreq, 10));
+                System.out.println("Total sentiment: " + state.totalSentiment.get());
+
+
+                JsonUtils.toFile(state, "job_" + result.jobId + "_report.json");
+                System.out.println("Results saved to job_" + result.jobId + "_report.json");
+            }
+
+            channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
+        };
+
+        channel.basicConsume(RabbitConfig.RESULTS_QUEUE, false, callback, tag -> {});
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/JobState.java b/src/main/java/JobState.java
new file mode 100644
index 0000000..58d13ff
--- /dev/null
+++ b/src/main/java/JobState.java
@@ -0,0 +1,44 @@
+import java.util.*;
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.concurrent.atomic.AtomicLong;
+import java.util.stream.Collectors;
+
+public class JobState {
+
+    public final int totalSections;          // общее число секций для этого job
+    public final AtomicInteger received;     // сколько секций уже обработано
+
+    // Агрегированные результаты
+    public final AtomicLong totalWordCount;  // суммарное количество слов
+    public final Map<String, Integer> globalWordFreq; // глобальная частота слов
+    public final AtomicInteger totalSentiment; // суммарная тональность
+    public final StringBuilder anonymizedText; // объединённые тексты с заменой имён
+    public final List<String> sortedSentences; // объединённые отсортированные предложения
+
+    public JobState(int totalSections) {
+        this.totalSections = totalSections;
+        this.received = new AtomicInteger(0);
+
+        this.totalWordCount = new AtomicLong(0);
+        this.globalWordFreq = new HashMap<>();
+        this.totalSentiment = new AtomicInteger(0);
+        this.anonymizedText = new StringBuilder();
+        this.sortedSentences = new ArrayList<>();
+    }
+
+    public static List<String> getTopN(Map<String, Integer> freqMap, int N) {
+        return freqMap.entrySet()
+                .stream()
+                .sorted(Map.Entry.<String, Integer>comparingByValue().reversed())
+                .limit(N)
+                .map(Map.Entry::getKey)
+                .collect(Collectors.toList());
+    }
+
+    public static List<Map.Entry<String, Integer>> getTopNWithCount(Map<String, Integer> freqMap, int N) {
+        return freqMap.entrySet()
+                .stream()
+                .sorted(Map.Entry.<String, Integer>comparingByValue().reversed())
+                .limit(N).collect(Collectors.toList());
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/ProducerApp.java b/src/main/java/ProducerApp.java
new file mode 100644
index 0000000..0551be3
--- /dev/null
+++ b/src/main/java/ProducerApp.java
@@ -0,0 +1,55 @@
+import com.rabbitmq.client.*;
+import entity.TaskMessage;
+import utils.JsonUtils;
+import utils.TextSplitter;
+
+import java.nio.charset.StandardCharsets;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.util.List;
+
+public class ProducerApp {
+
+    public static void main(String[] args) throws Exception {
+
+        Path path = Paths.get("input.txt");
+        byte[] encoded = Files.readAllBytes(path);
+        String text = new String(encoded, StandardCharsets.UTF_8);
+
+        System.out.println(text);
+        TextSplitter splitter = new TextSplitter(50);
+        List<String> parts = splitter.split(text);
+
+        ConnectionFactory factory = new ConnectionFactory();
+        factory.setHost(RabbitConfig.HOST);
+
+        try (Connection connection = factory.newConnection();
+             Channel channel = connection.createChannel()) {
+
+            channel.exchangeDeclare(RabbitConfig.TASKS_EXCHANGE, BuiltinExchangeType.DIRECT, true);
+            channel.queueDeclare(RabbitConfig.TASKS_QUEUE, true, false, false, null);
+            channel.queueBind(
+                    RabbitConfig.TASKS_QUEUE,
+                    RabbitConfig.TASKS_EXCHANGE,
+                    RabbitConfig.TASKS_ROUTING_KEY
+            );
+
+            String jobId = "job-1";
+            int total = parts.size();
+
+            for (int i = 0; i < parts.size(); i++) {
+                TaskMessage msg = new TaskMessage(jobId, i, total, parts.get(i));
+
+                channel.basicPublish(
+                        RabbitConfig.TASKS_EXCHANGE,
+                        RabbitConfig.TASKS_ROUTING_KEY,
+                        null,
+                        JsonUtils.toJsonBytes(msg)
+                );
+
+                System.out.println("Sent section " + i);
+            }
+        }
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/RabbitConfig.java b/src/main/java/RabbitConfig.java
new file mode 100644
index 0000000..ccf6a40
--- /dev/null
+++ b/src/main/java/RabbitConfig.java
@@ -0,0 +1,12 @@
+public class RabbitConfig {
+
+    public static final String HOST = "localhost";
+
+    public static final String TASKS_EXCHANGE = "text.tasks.exchange";
+    public static final String TASKS_QUEUE = "text.tasks.queue";
+    public static final String TASKS_ROUTING_KEY = "text.task";
+
+    public static final String RESULTS_EXCHANGE = "text.results.exchange";
+    public static final String RESULTS_QUEUE = "text.results.queue";
+    public static final String RESULTS_ROUTING_KEY = "text.result";
+}
\ No newline at end of file
diff --git a/src/main/java/WorkerApp.java b/src/main/java/WorkerApp.java
new file mode 100644
index 0000000..122b3a9
--- /dev/null
+++ b/src/main/java/WorkerApp.java
@@ -0,0 +1,82 @@
+import analyzers.NameAnonymizer;
+import analyzers.SentenceSorter;
+import analyzers.SentimentAnalyzer;
+import analyzers.WordCounter;
+import analyzers.WordFrequency;
+import com.rabbitmq.client.*;
+import entity.Counters;
+import entity.ResultMessage;
+import entity.TaskMessage;
+import utils.JsonUtils;
+
+import java.util.List;
+import java.util.Map;
+
+
+public class WorkerApp {
+
+    public static void start() {
+        try {
+            ConnectionFactory factory = new ConnectionFactory();
+            factory.setHost(RabbitConfig.HOST);
+
+            Connection connection = factory.newConnection();
+            Channel channel = connection.createChannel();
+
+            channel.queueDeclare(RabbitConfig.TASKS_QUEUE, true, false, false, null);
+            channel.exchangeDeclare(RabbitConfig.RESULTS_EXCHANGE, BuiltinExchangeType.DIRECT, true);
+            channel.queueDeclare(RabbitConfig.RESULTS_QUEUE, true, false, false, null);
+            channel.queueBind(
+                    RabbitConfig.RESULTS_QUEUE,
+                    RabbitConfig.RESULTS_EXCHANGE,
+                    RabbitConfig.RESULTS_ROUTING_KEY
+            );
+            channel.basicQos(1);
+
+            WordCounter wc = new WordCounter();
+            WordFrequency wf = new WordFrequency();
+            SentimentAnalyzer sa = new SentimentAnalyzer();
+            NameAnonymizer na = new NameAnonymizer();
+            SentenceSorter ss = new SentenceSorter();
+
+            DeliverCallback deliverCallback = (consumerTag, delivery) -> {
+                TaskMessage task = JsonUtils.fromJsonBytes(delivery.getBody(), TaskMessage.class);
+
+                long wordCount = wc.count(task.text);
+                Map<String, Integer> wordFreq = wf.countFrequency(task.text);
+                int sentiment = sa.analyze(task.text);
+                String anonymized = na.anonymize(task.text);
+                List<String> sortedSentences = ss.sortByLength(task.text);
+
+                Counters counters = new Counters(wordCount, wordFreq, sentiment, anonymized, sortedSentences);
+
+                ResultMessage result = new ResultMessage(
+                        task.jobId,
+                        task.sectionId,
+                        task.totalSections,
+                        counters
+                );
+
+                channel.basicPublish(
+                        RabbitConfig.RESULTS_EXCHANGE,
+                        RabbitConfig.RESULTS_ROUTING_KEY,
+                        null,
+                        JsonUtils.toJsonBytes(result)
+                );
+
+                channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
+
+                System.out.println(Thread.currentThread().getName() + " processed section " + task.sectionId);
+            };
+
+            channel.basicConsume(
+                    RabbitConfig.TASKS_QUEUE,
+                    false,  // autoAck = false
+                    deliverCallback,
+                    consumerTag -> {}
+            );
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/WorkerLauncher.java b/src/main/java/WorkerLauncher.java
new file mode 100644
index 0000000..c0c9114
--- /dev/null
+++ b/src/main/java/WorkerLauncher.java
@@ -0,0 +1,13 @@
+public class WorkerLauncher {
+
+    public static void main(String[] args) {
+
+        int workers = args.length != 0 ? Integer.parseInt(args[0]) : 4;
+
+        for (int i = 0; i < workers; i++) {
+            Thread t = new Thread(() -> WorkerApp.start());
+            t.setName("worker-" + i);
+            t.start();
+        }
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/analyzers/NameAnonymizer.java b/src/main/java/analyzers/NameAnonymizer.java
new file mode 100644
index 0000000..81011c1
--- /dev/null
+++ b/src/main/java/analyzers/NameAnonymizer.java
@@ -0,0 +1,7 @@
+package analyzers;
+
+public class NameAnonymizer {
+    public String anonymize(String text) {
+        return text.replaceAll("\\b[A-Z][a-z]+\\b", "<NAME>");
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/analyzers/SentenceSorter.java b/src/main/java/analyzers/SentenceSorter.java
new file mode 100644
index 0000000..b89b80a
--- /dev/null
+++ b/src/main/java/analyzers/SentenceSorter.java
@@ -0,0 +1,15 @@
+package analyzers;
+
+import java.util.Arrays;
+import java.util.Comparator;
+import java.util.List;
+import java.util.stream.Collectors;
+
+public class SentenceSorter {
+    public List<String> sortByLength(String text) {
+        String[] sentences = text.split("(?<=[.!?])\\s+");
+        return Arrays.stream(sentences)
+                .sorted(Comparator.comparingInt(String::length))
+                .collect(Collectors.toList());
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/analyzers/SentimentAnalyzer.java b/src/main/java/analyzers/SentimentAnalyzer.java
new file mode 100644
index 0000000..bf9057c
--- /dev/null
+++ b/src/main/java/analyzers/SentimentAnalyzer.java
@@ -0,0 +1,22 @@
+package analyzers;
+
+
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.Set;
+
+public class SentimentAnalyzer {
+
+    private static final Set<String> POSITIVE = new HashSet<>(Arrays.asList("good", "happy", "great", "love", "excellent", "sister"));
+
+    private static final Set<String> NEGATIVE = new HashSet<>(Arrays.asList("bad", "sad", "terrible", "hate", "poor"));
+
+    public int analyze(String text) {
+        int score = 0;
+        for (String word : text.toLowerCase().split("\\W+")) {
+            if (POSITIVE.contains(word)) score++;
+            if (NEGATIVE.contains(word)) score--;
+        }
+        return score;
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/analyzers/WordCounter.java b/src/main/java/analyzers/WordCounter.java
new file mode 100644
index 0000000..cacc733
--- /dev/null
+++ b/src/main/java/analyzers/WordCounter.java
@@ -0,0 +1,8 @@
+package analyzers;
+
+public class WordCounter {
+
+    public long count(String text) {
+        return text.split("\\s+").length;
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/analyzers/WordFrequency.java b/src/main/java/analyzers/WordFrequency.java
new file mode 100644
index 0000000..e7ada0d
--- /dev/null
+++ b/src/main/java/analyzers/WordFrequency.java
@@ -0,0 +1,15 @@
+package analyzers;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class WordFrequency {
+    public Map<String, Integer> countFrequency(String text) {
+        Map<String, Integer> freq = new HashMap<>();
+        for (String word : text.toLowerCase().split("\\W+")) {
+            if (word.isEmpty()) continue;
+            freq.put(word, freq.getOrDefault(word, 0) + 1);
+        }
+        return freq;
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/entity/Counters.java b/src/main/java/entity/Counters.java
new file mode 100644
index 0000000..a237bf6
--- /dev/null
+++ b/src/main/java/entity/Counters.java
@@ -0,0 +1,28 @@
+package entity;
+
+import java.io.Serializable;
+import java.util.List;
+import java.util.Map;
+
+public class Counters implements Serializable {
+    public long wordCount;
+    public Map<String, Integer> wordFreq;
+    public int sentimentScore;
+    public String anonymizedText;
+    public List<String> sortedSentences;
+
+    public Counters() {
+    }
+
+    public Counters(long wordCount,
+                    Map<String, Integer> wordFreq,
+                    int sentimentScore,
+                    String anonymizedText,
+                    List<String> sortedSentences) {
+        this.wordCount = wordCount;
+        this.wordFreq = wordFreq;
+        this.sentimentScore = sentimentScore;
+        this.anonymizedText = anonymizedText;
+        this.sortedSentences = sortedSentences;
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/entity/ResultMessage.java b/src/main/java/entity/ResultMessage.java
new file mode 100644
index 0000000..35c85c8
--- /dev/null
+++ b/src/main/java/entity/ResultMessage.java
@@ -0,0 +1,18 @@
+package entity;
+
+public class ResultMessage {
+    public String jobId;
+    public int sectionId;
+    public int totalSections;
+    public Counters counters;
+
+    public ResultMessage() {
+    }
+
+    public ResultMessage(String jobId, int sectionId, int totalSections, Counters counters) {
+        this.jobId = jobId;
+        this.sectionId = sectionId;
+        this.totalSections = totalSections;
+        this.counters = counters;
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/entity/TaskMessage.java b/src/main/java/entity/TaskMessage.java
new file mode 100644
index 0000000..11d898a
--- /dev/null
+++ b/src/main/java/entity/TaskMessage.java
@@ -0,0 +1,18 @@
+package entity;
+
+public class TaskMessage {
+    public String jobId;
+    public int sectionId;
+    public int totalSections;
+    public String text;
+
+    public TaskMessage() {
+    }
+
+    public TaskMessage(String jobId, int sectionId, int totalSections, String text) {
+        this.jobId = jobId;
+        this.sectionId = sectionId;
+        this.totalSections = totalSections;
+        this.text = text;
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/utils/JsonUtils.java b/src/main/java/utils/JsonUtils.java
new file mode 100644
index 0000000..1493d57
--- /dev/null
+++ b/src/main/java/utils/JsonUtils.java
@@ -0,0 +1,35 @@
+package utils;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import java.io.File;
+import java.io.IOException;
+
+public class JsonUtils {
+
+    private static final ObjectMapper MAPPER = new ObjectMapper();
+
+    public static byte[] toJsonBytes(Object obj) {
+        try {
+            return MAPPER.writeValueAsBytes(obj);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    public static <T> T fromJsonBytes(byte[] data, Class<T> clazz) {
+        try {
+            return MAPPER.readValue(data, clazz);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    public static void toFile(Object obj, String path) {
+        try {
+            MAPPER.writerWithDefaultPrettyPrinter().writeValue(new File(path), obj);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/utils/TextSplitter.java b/src/main/java/utils/TextSplitter.java
new file mode 100644
index 0000000..af2e721
--- /dev/null
+++ b/src/main/java/utils/TextSplitter.java
@@ -0,0 +1,23 @@
+package utils;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class TextSplitter {
+
+    private final int chunkSize;
+
+    public TextSplitter(int chunkSize) {
+        this.chunkSize = chunkSize;
+    }
+
+    public List<String> split(String text) {
+        List<String> chunks = new ArrayList<>();
+
+        for (int i = 0; i < text.length(); i += chunkSize) {
+            chunks.add(text.substring(i, Math.min(text.length(), i + chunkSize)));
+        }
+
+        return chunks;
+    }
+}
\ No newline at end of file