nats url consts now prefixed with nats

regner · Aug 19, 2017 · dc9b4ab · dc9b4ab
1 parent 5d73a8f
commit dc9b4ab
Show file tree

Hide file tree

Showing 5 changed files with 8 additions and 8 deletions.
diff --git a/client/operation_auction_get_offers.go b/client/operation_auction_get_offers.go
@@ -63,5 +63,5 @@ func (op operationAuctionGetOffersResponse) Process(state *albionState, uploader
 		return
 	}
 
-	uploader.sendToIngest(data, lib.MarketOrdersIngest)
+	uploader.sendToIngest(data, lib.NatsMarketOrdersIngest)
 }
diff --git a/client/operation_auction_get_requests.go b/client/operation_auction_get_requests.go
@@ -48,5 +48,5 @@ func (op operationAuctionGetRequestsResponse) Process(state *albionState, upload
 		return
 	}
 
-	uploader.sendToIngest(data, lib.MarketOrdersIngest)
+	uploader.sendToIngest(data, lib.NatsMarketOrdersIngest)
 }
diff --git a/client/operation_gold_market_get_average_info.go b/client/operation_gold_market_get_average_info.go
@@ -32,5 +32,5 @@ func (op operationGoldMarketGetAverageInfoResponse) Process(state *albionState,
 		return
 	}
 
-	uploader.sendToIngest(data, lib.GoldPricesIngest)
+	uploader.sendToIngest(data, lib.NatsGoldPricesIngest)
 }
diff --git a/cmd/natsdumper/natsdumper.go b/cmd/natsdumper/natsdumper.go
@@ -39,7 +39,7 @@ func main() {
 	defer nc.Close()
 
 	marketCh := make(chan *nats.Msg, 64)
-	marketSub, err := nc.ChanSubscribe(lib.GoldPricesDeduped, marketCh)
+	marketSub, err := nc.ChanSubscribe(lib.NatsGoldPricesDeduped, marketCh)
 	if err != nil {
 		fmt.Printf("%v\n", err)
 		return

diff --git a/lib/nats.go b/lib/nats.go
@@ -1,8 +1,8 @@
 package lib
 
 const (
-	GoldPricesIngest    = "goldprices.ingest"
-	GoldPricesDeduped   = "goldprices.deduped"
-	MarketOrdersIngest  = "marketorders.ingest"
-	MarketOrdersDeduped = "marketorders.deduped"
+	NatsGoldPricesIngest    = "goldprices.ingest"
+	NatsGoldPricesDeduped   = "goldprices.deduped"
+	NatsMarketOrdersIngest  = "marketorders.ingest"
+	NatsMarketOrdersDeduped = "marketorders.deduped"
 )
-Original file line number
+Diff line change
@@ Expand Up @@
     		return
     	}
-    	uploader.sendToIngest(data, lib.MarketOrdersIngest)
+    	uploader.sendToIngest(data, lib.NatsMarketOrdersIngest)
     }