Mild adjustments

compose.yml

@@ -8,6 +8,8 @@ services:
       - "9042:9042"
     volumes:
       - cassandra:/var/lib/cassandra
+    environment:
+      - MAX_HEAP_SIZE=2G
 
 volumes:
   cassandra:

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} ->

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(