INNER CODE UNIT · Go

batch

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

	batch            = 1 // just for the same of demo. Use bigger numbers
)

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

View source record →