From af918da9462dc6896a1400ebd51c251dcda64ed9 Mon Sep 17 00:00:00 2001
From: Artemiy Solopov <a.solopov.001@gmail.com>
Date: Fri, 28 Aug 2026 17:39:54 +0300
Subject: [PATCH] Mild adjustments

---
 compose.yml                                   | 4 +++-
 lib/neon_vertigo_service/message_processor.ex | 6 +++---
 lib/neon_vertigo_service/mqtt/server.ex       | 3 ++-
 3 files changed, 8 insertions(+), 5 deletions(-)

diff --git a/compose.yml b/compose.yml
index dd81f7e..374d247 100644
--- a/compose.yml
+++ b/compose.yml
@@ -8,6 +8,8 @@ services:
       - "9042:9042"
     volumes:
       - cassandra:/var/lib/cassandra
+    environment:
+      - MAX_HEAP_SIZE=2G
 
 volumes:
-  cassandra:
\ No newline at end of file
+  cassandra:
diff --git a/lib/neon_vertigo_service/message_processor.ex b/lib/neon_vertigo_service/message_processor.ex
index 687c2bd..9cd691a 100644
--- a/lib/neon_vertigo_service/message_processor.ex
+++ b/lib/neon_vertigo_service/message_processor.ex
@@ -3,7 +3,7 @@ defmodule NeonVertigoService.MessageProcessor do
 
   import Ecto.Query, only: [from: 2]
 
-  def process_message(mqtt_pid, {"auctions", "create"}, payload, properties) do
+  def process_message(mqtt_pid, {"auctions", "created"}, payload, properties) do
     changeset = Auction.changeset(%Auction{}, payload)
     reply = case Repo.insert(changeset) do
       {:ok, auction} ->
@@ -12,7 +12,7 @@ defmodule NeonVertigoService.MessageProcessor do
         %{ok: false, gid: changeset |> Ecto.Changeset.get_field(:gid)}
     end
 
-    reply(reply, mqtt_pid, properties)
+    reply(reply, mqtt_pid, properties, [qos: 2])
   end
 
   def process_message(mqtt_pid, {"auctions", auction_gid, "bid"}, payload, properties) do
@@ -28,7 +28,7 @@ defmodule NeonVertigoService.MessageProcessor do
             bidder_gid: bid.bidder_gid,
             timestamp: bid.bid_timestamp
           }
-          send_mqtt(bid_data, mqtt_pid, "notify/new_bid/#{auction.gid}")
+          send_mqtt(bid_data, mqtt_pid, "notify/new_bid/#{auction.gid}", qos: 2)
           %{ok: true}
         {:error, changeset} -> %{ok: false}
       end
diff --git a/lib/neon_vertigo_service/mqtt/server.ex b/lib/neon_vertigo_service/mqtt/server.ex
index ef19fa1..e91c8a9 100644
--- a/lib/neon_vertigo_service/mqtt/server.ex
+++ b/lib/neon_vertigo_service/mqtt/server.ex
@@ -13,7 +13,8 @@ defmodule NeonVertigoService.Mqtt.Server do
     {:ok, %MqttServer{}, {:continue, :post_init}}
   end
 
-  # Callbacks
+  # == Callbacks ==
+
   def handle_continue(:post_init, %MqttServer{} = state) do
     mqtt_config = Application.fetch_env!(:neon_vertigo_service, :mqtt_params)
     {:ok, mqtt_pid} = Supervisor.start_child(