Fixes to RDY and go away from Rails dependency

lib/nsqrb.rb

@@ -1,6 +1,4 @@
 # encoding: utf-8
-
-require 'nsqrb'
 require 'nsqrb/command'
 require 'nsqrb/frame'
 require 'nsqrb/frame/error'
@@ -9,6 +7,9 @@
 require 'nsqrb/parser'
 require 'nsqrb/consumer'
 require 'nsqrb/producer'
+require 'nsqrb/version'
+
+require 'json'
 
 Dir[File.dirname(__FILE__) + '/nsqrb/command/*.rb'].each {|file| require file }
 

lib/nsqrb/command/identify.rb

@@ -6,7 +6,7 @@ def to_line
         hash[key] = @args[key] if @args[key].nil?
         hash
       end
-      payload = MultiJson.dump(filtered)
+      payload = JSON.dump(filtered)
       [name, "\n", payload.length, payload].pack('a*a*l>a*')
     end
 

lib/nsqrb/consumer.rb

@@ -1,8 +1,10 @@
+require 'socket'
+
 module Nsqrb
   class Consumer
     attr_reader :options, :messages, :errors, :responses
 
-    TCP_BUFFER = 64.kilobytes
+    TCP_BUFFER = 64 * 1024
     PROTOCOL_VERSION = "v2"
 
     def initialize(options = {})
@@ -27,14 +29,17 @@ def receive
 
     def confirm(message)
       @socket.write Command::Fin.new(message_id: message.id).to_line
+      update_rdy
     end
 
     def requeue(message, timeout = 0)
       @socket.write Command::Req.new(message_id: message.id, timeout: timeout).to_line
+      update_rdy
     end
 
     def touch(message)
       @socket.write Command::Touch.new(message_id: message.id).to_line
+      update_rdy
     end
 
     def close!
@@ -56,6 +61,11 @@ def connect!
 
     private
 
+
+      def update_rdy
+        @socket.write Command::Rdy.new(count: 1).to_line
+      end
+
       def identify_defaults
         return @identify_defaults if @identify_defaults
         @identify_defaults = {

lib/nsqrb/frame.rb

@@ -1,3 +1,5 @@
+require 'ostruct'
+
 module Nsqrb
   class Frame < OpenStruct
   end

lib/nsqrb/producer.rb

@@ -1,3 +1,5 @@
+require 'net/http'
+
 module Nsqrb
   class Producer
     def initialize(host, port, topic)

lib/nsqrb/version.rb

@@ -1,3 +1,3 @@
 module Nsqrb
-  VERSION = "0.0.1"
+  VERSION = "0.0.2"
 end