main.go

package main

import (
	"context"
	"encoding/json"
	"fmt"
	"log"
	"time"

	"github.com/kubemq-io/kubemq-go"
	"github.com/kubemq-io/kubemq-targets/pkg/uuid"
	"github.com/kubemq-io/kubemq-targets/types"
)

func main() {
	client, err := kubemq.NewClient(context.Background(),
		kubemq.WithAddress("localhost", 50000),
		kubemq.WithClientId(uuid.New().String()),
		kubemq.WithTransportType(kubemq.TransportTypeGRPC))
	if err != nil {
		log.Fatal(err)
	}
	body, err := json.Marshal("test")
	if err != nil {
		panic(err)
	}
	// send
	sendRequest := types.NewRequest().
		SetMetadataKeyValue("method", "send").
		SetMetadataKeyValue("label", `test`).
		SetData(body)
	sendUploadResponse, err := client.SetQuery(sendRequest.ToQuery()).
		SetChannel("azure.servicebus").
		SetTimeout(10 * time.Second).Send(context.Background())
	if err != nil {
		log.Fatal(err)
	}
	sendResponse, err := types.ParseResponse(sendUploadResponse.Body)
	if err != nil {
		log.Fatal(err)
	}
	log.Println(fmt.Sprintf("send request executed, error: %v , response:%s", sendResponse.Error, sendResponse.Metadata["result"]))
}