diff --git a/main.go b/main.go
index cef8581..5ca487d 100644
--- a/main.go
+++ b/main.go
@@ -2,13 +2,56 @@
 package main
 
 import (
+	logger "gitea.rebus.ninja/lore/wasm-nats-stream-client/gen/wasi/logging/logging"
+	"gitea.rebus.ninja/lore/wasm-nats-stream-client/gen/wasmcloud/messaging/consumer"
 	"gitea.rebus.ninja/lore/wasm-nats-stream-client/gen/wasmcloud/messaging/handler"
+	"gitea.rebus.ninja/lore/wasm-nats-stream-client/gen/wasmcloud/messaging/types"
+	"github.com/bytecodealliance/wasm-tools-go/cm"
 )
 
+type messagingConsumerAdapter struct {
+	Publish func(msg types.BrokerMessage) (result cm.Result[string, struct{}, string])
+}
+
+// NOTE(lxf): this is overridden in tests
+var messagingConsumer = &messagingConsumerAdapter{
+	Publish: consumer.Publish,
+} 
+
 func init() {
 	handler.Exports.HandleMessage = handleMessage
 }
 
+func handleMessage(msg types.BrokerMessage) cm.Result[string, struct{}, string] {
+
+	logger.Log(logger.LevelInfo,"MessageHandler", "Received message on subject" + msg.Subject)
+	
+	// TODO implement the logic to get the destination topic from the config
+	// dest_topic := config.GetAll()
+	dest_topic := "finish"
+
+	// TASK
+	arg := cm.LiftString[string, *uint8, uint8](msg.Body.Data(), uint8(msg.Body.Len()))
+
+	result := exec_task(arg)
+
+	// Send reply
+	reply := types.BrokerMessage{
+		Subject: dest_topic,
+		Body:    cm.ToList([]byte(result)),
+		ReplyTo: cm.None[string](),
+	}
+
+	res := messagingConsumer.Publish(reply)
+	if res.IsErr() {
+		logger.Log(logger.LevelError, "MessageHandler", "Failed to send reply, error: " + *res.Err())
+		return res
+	}
+
+	return cm.OK[cm.Result[string, struct{}, string]](struct{}{})
+}
+
+
 // Since we don't run this program like a CLI, the `main` function is empty. Instead,
 // we call the `handleRequest` function when an HTTP request is received.
 func main() {}