Proxy events to stream processors

proxy.go

sub, err := sc.Subscribe("eventstore.events", func(m *stan.Msg) {
    // TODO check if event was already processed
    stan.PublishAsync("eventstore.events.order-projection", m.Data)
    stan.PublishAsync("eventstore.events.order-reactor", m.Data)
	
	// TODO track event as processed
    
	// ack message
	if err := m.Ack(); err != nil {
		log.WithFields(eventLogFields).WithFields(r.baseLogFields).WithError(err).Error("ack event")
	}
},
  stan.maxInFlight(1),
  stan.AckWait("30s"),
  stan.SetManualAckMode(),
  stan.DurableName(durableName),
)