INNER CODE UNIT · Go

pullSubscribeOnOrder

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

func pullSubscribeOnOrder(js nats.JetStreamContext) {
	// Create Pull based consumer with maximum 128 inflight.
	// PullMaxWaiting defines the max inflight pull requests.
	sub, _ := js.PullSubscribe(subscribeSubject, clientID, nats.PullMaxWaiting(128))
	for {

		msgs, _ := sub.Fetch(batch)
		for _, msg := range msgs {
			msg.Ack()
			var order ordermodel.Order
			// Unmarshal JSON that represents the Order data
			err := json.Unmarshal(msg.Data, &order)
			if err != nil {
				log.Print(err)
				return
			}
			log.Printf("Message subscribed on subject:%s, from:%s,  data:%v", subscribeSubject, clientID, order)
			orderDB, _ := sqldb.NewOrdersDB()

View source record →