INNER CODE UNIT · Go

main

shijuvar/go-distributed-sys · eventstream/querymodelworker/main.go:23

func main() {
	natsComponent := natsutil.NewNATSComponent(clientID)
	err := natsComponent.ConnectToServer(nats.DefaultURL)
	if err != nil {
		log.Fatal(err)
	}
	jetStreamContext, err := natsComponent.JetStreamContext()
	if err != nil {
		log.Fatal(err)
	}
	pullSubscribeOnOrder(jetStreamContext)
}

func pushSubscribeOnOrder(js nats.JetStreamContext) {
	// Create durable push consumer
	js.QueueSubscribe(subscribeSubject, queueGroup, func(msg *nats.Msg) {
		msg.Ack()
		var order ordermodel.Order

View source record →