gistfile1.go

	submission := func() {
	label:
		for {
			switch message := psc.Receive().(type) {
			case redis.Message:
				return db.Loads(message.Data)
			case error:
				log.Println(colors.Red("Failed to pubsub on trading session! %e", message.Error))
				break label
			}
		}
	}()