activity monitor performance logging

activity-monitor.go

deliveryTimings := make(map[string]time.Time)

// Run forever.
for d := range deliveries {
	if d.ReplyTo != "" {
		deliveryTimings[fmt.Sprintf("%s:%s", d.CorrelationId, d.ReplyTo)] 	= time.Now()
	} else {
		rpcSent := deliveryTimings[fmt.Sprintf("%s:%s", d.CorrelationId, d.RoutingKey)]
		if rpcSent != nil {
			respTime := time.Since(rpcSent)
			delete(deliveryTimings, fmt.Sprintf("%s:%s", d.CorrelationId, d.RoutingKey))
			fmt.Printf("RPC call [%s] from [%s] took %s\n", d.Type, d.RoutingKey, respTime)
		}
	}
	// Pass each message to the Analysis Engine
	err = ae.ProcessMessage(d)
	if err != nil {
		logger.Alert(fmt.Sprintf("Could not process message: %s", err))

	} else {
		// Only ack the delivery we actually handled (ackMultiple=false)
		const ackMultiple = false
		d.Ack(ackMultiple)
	}
}