func (eClient *EventClient) WatchProductEvents(callback ProductEventCallback) {
	for {
		if err := eClient.ceClient.StartReceiver(context.Background(), productReceiver(callback)); err != nil {
			log.Printf("failed to start nats receiver, %s", err.Error())
		}
	}
}
// WatchProductEvents will call your callback function on each incoming event from the MMS Nats server.
WatchProductEvents will call your callback function on each incoming event from the MMS Nats server.
// WatchProductEvents will call your callback function on each incoming event from the MMS Nats server .
func (eClient *EventClient) WatchProductEvents(callback ProductEventCallback) {
	for {
		if err := eClient.ceClient.StartReceiver(context.Background(), productReceiver(callback)); err != nil {
			log.Printf("failed to start nats receiver, %s", err.Error())
		}
	}
}
func ( eClient * EventClient ) WatchProductEvents ( callback ProductEventCallback ) { for { if err := eClient . ceClient . StartReceiver ( context . Background ( ) , productReceiver ( callback ) ) ; err != nil { log . Printf ( " " , err . Error ( ) ) } } }
WatchProductEvents will call your callback function on each incoming event from the MMS Nats server.
WatchProductEvents will call your callback function on each incoming event from the MMS Nats server .