GEMPI

Implementing Publisher and Consumer with SQS

Getting Started

Installing

go get github.com/sofyan48/gempi

Getting Client

// configure aws creds
cfg := config.Configure()
cfg.PathURL = os.Getenv("SQS_URL")
cfg.AwsAccessKeyID = os.Getenv("ACCESS_KEY")
cfg.AwsSecretAccessKey = os.Getenv("SECRET_KEY")
cfg.APArea = "ap-southeast-1"
cfg.Backend = "backend"
cfg.Broker = "broker"
// get sqs client
client := config.NewConfig().Credential(cfg).New()

Starting Worker

Before carrying out road activities, start the worker first

// Create Worker
worker := api.NewWorker(client)
// worker.SetWorker()
worker.Start()

Producer

// create sqs Producer
producer := api.NewProducer(client)
// Publish Messages
message := producer.GetMessageInput()
message.Topic = "send1"
message.Status = "progres"
message.Body = "dataBody"
message.Parameter = "dataParams"
result, err := producer.Send(message)
if err != nil {
	fmt.Println("ERROR : ", err)
}
fmt.Println("Messages Sending : ", result)

Consumer

Callback

func callback(context *entity.Context, client *entity.NewClient) {
	cb := api.GetCallbackFunction()
	obj := &entity.StateFullModels{}
	json.Unmarshal([]byte(*context.Message.Body), &obj)
	fmt.Println("Message Raw From Context", obj)
	// cb.Flush(client, context.Message, context.Data)
	cb.Deleted(client, context.Message)
}

now get consume

// Create Consumer
consumer := api.NewConsumer(client)
// consumer get data with callback
consumer.Consumer("send1", callbackData, 1)