krakow
krakow copied to clipboard
chrisroberts
Ruby client library for NSQ
Tried running a consumer via the example: `Krakow::Consumer.new(:nsqlookupd` => "http://127.0.0.1:4160", :topic => 'green', :channel => 'provider', :max_in_flight => 10)` However, I get a `: Lookup exception encountered: NoMethodError - undefined...
Krakow makes a request to lookupd to get the list of nsqd nodes. If for any reason lookupd takes a long time to respond Krakow will wait forever. Even worst,...
The http gem v1 removed the `#with` deprecated method. It was used to set the `"Accept"` header in the request to nsqlookupd. Replaces it with `#headers` should do the trick....
I long running rake task that consumes messages from NSQ. Sometimes my process stops getting new messages. The ruby process is still running, however. In my attempts to diagnose the...
Allow producer to use nsqlookup to locate topic locations for publishing
I tried to configure krakow using TLS like so: ``` consumer = Krakow::Consumer.new( :nsqlookupd => 'https://api-ssl.bitly.com/v3/nsq/lookup?access_token=xxx', :topic => 'topic, :channel => 'channel', :connection_options => { :features => { :tls_v1 =>...
when I try the following in `irb`: ``` ruby p = Krakow::Producer.new(host: '127.0.0.1', port: '4150', topic: 'orders') ``` I get the following exception: ``` ruby NameError: uninitialized constant Celluloid::Signals from...
Add ability to fetch the list of existing topics using the `/topics` endpoint on the nsqlookupds I want to write a Logstash (https://www.elastic.co/products/logstash) input plugin to pull logs from NSQ....
fairly self explanatory fixes #37 ``` $ irb irb(main):001:0> require 'krakow' D, [2015-07-10T16:59:27.201807 #22698] DEBUG -- : Celluloid 0.17.0 is running in BACKPORTED mode. [ http://git.io/vJf3J ] => true irb(main):002:0>...
Hello, I use krakow inside a rails app with ruby 2.2 MRE with krakow 0.4.2 and NSQ 0.3.5 I am creating and terminating a topic producer inside a controller to...
