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..1b362bc 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} ->
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(