Add example consumer

example/daemons/price_consumer.go

@@ -0,0 +1,28 @@
+package daemons
+
+import (
+	"log"
+
+	"github.com/localhots/satan"
+)
+
+// PriceConsumer consumes price update messages and prints them to the console.
+type PriceConsumer struct {
+	satan.BaseConsumer
+}
+
+// PriceUpdate describes a price update message.
+type PriceUpdate struct {
+	Product string  `json:"product"`
+	Amount  float64 `json:"amount"`
+}
+
+// Startup creates a new subscription for ProductPriceUpdates topic.
+func (p *PriceConsumer) Startup() {
+	b.Subscribe("ProductPriceUpdates", func(u PriceUpdate) {
+		log.Printf("Price for %q is now $%.2f", u.Product, u.Amount)
+	})
+}
+
+// Shutdown is empty because PriceConsumer requires no cleanup upon exiting.
+func (p *PriceConsumer) Shutdown() {}