fix bug

Dockerfile

@@ -49,4 +49,4 @@ WORKDIR /app
 
 # Install go dependencies, build the wasm module, push it to the registry
 #CMD ["sh", "-c", "go mod download && go mod verify && go mod tidy && wash build && wash push $REGISTRY build/*_s.wasm"]
-CMD ["sh", "-c", "go env -w GOFLAGS=-buildvcs=false && go mod download && go mod verify && wash build && wash push $REGISTRY build/*_s.wasm"]
+CMD ["sh", "-c", "go env -w GOFLAGS=-buildvcs=false && go mod download && go mod verify && wash build && wash push $REGISTRY build/*.wasm"]

main.go

@@ -2,7 +2,6 @@
 package main
 
 import (
-	"gitea.rebus.ninja/lore/wasm-nats-producer-client/gen/wasmcloud/messaging/handler"
 )
 
 func init() {

messaging.go

@@ -6,6 +6,7 @@ import (
 	"gitea.rebus.ninja/lore/wasm-nats-producer-client/gen/wasmcloud/messaging/types"
 	logger "gitea.rebus.ninja/lore/wasm-nats-producer-client/gen/wasi/logging/logging"
 	//config "gitea.rebus.ninja/lore/wasm-nats-producer-client/gen/wasi/config/runtime"
+	"time"
 )
 
 type messagingConsumerAdapter struct {
@@ -22,12 +23,13 @@ func loop() cm.Result[string, struct{}, string] {
 	// TODO implement the logic to get the destination topic from the config
 	// dest_topic := config.GetAll()
 	dest_topic := "test.reply"	
+	counter := 0
 
 	// TASK
-	for true {
+	for {
 
 		// generate random message
-		data := []byte("Hello, World!")
+		data := []byte("Hello, World! " + string(counter))
 
 		// Send reply
 		reply := types.BrokerMessage{
@@ -41,6 +43,15 @@ func loop() cm.Result[string, struct{}, string] {
 			return res
 		}
 
+		counter++
+
+		if counter == 1000 {
+			break
+		}
+
+		// sleep for 1 second
+		time.Sleep(1 * time.Second) 
+
 	}
 
 	return cm.OK[cm.Result[string, struct{}, string]](struct{}{})