Publish messages asynchronously to NATS Streaming Server

publishasync.go

ackHandler := func(ackedNuid string, err error) {
        if err != nil {
            log.Printf("Error publishing message id %s: %v\n", ackedNuid, err.Error())
        } else {
            log.Printf("Received ACK for message id %s\n", ackedNuid)
        }
    }
	
 channel := event.Channel
 eventMsg := []byte(event.EventData)
 // Publish message on subject (channel)
 nuid, err := sc.PublishAsync(channel, eventMs, ackHandler) 
 if err != nil {
	log.Printf("Error publishing message %s: %v\n", nuid, err.Error())
 }