krakow
krakow copied to clipboard
Ruby client library for NSQ
Currently you can't set a specific logger to use, resulting in everything just being dumped to STDOUT. In a production environment, this can be a little annoying. Seeing as you...
When trying to consume Bitly-messages the basic configuration looks like this. ``` consumer = Krakow::Consumer.new( :nsqlookupd => 'https://api-ssl.bitly.com/v3/nsq/lookup?access_token=xxx', :topic => 'topic', :channel => 'channel' } ) ``` Using _krakow_ this...
Prompted from #25 investigate if allowing more configuration options for fine tuning response wait times based on criteria (type of message, etc) would beneficial. Also look at allowing override on...
I'm having an issue when I try to write payloads in increments. The simplest setup I could come up with was this: ``` ruby def run producer = Krakow::Producer.new( host:...
If discovery nodes are down, failures force a tight retry cycle. Define retry delay via option config and throw splay on top.