- Use mqrpc's new 'delayable' message header

lib/net/clients/agent.rb

@@ -33,7 +33,7 @@ module LogStash; module Net; module Clients
       ier.metadata["source_host"] = @hostname
 
       @logger.debug "Indexing #{type}: #{string}"
-      ier.want_buffer(true)
+      ier.delayable = true
       sendmsg("logstash", ier)
     end # def index
 

lib/net/servers/indexer.rb

@@ -244,7 +244,6 @@ module LogStash; module Net; module Servers
     def broadcaster
       msg = LogStash::Net::Messages::BroadcastMessage.new
       msg.queue = @id
-      msg.want_buffer(false)
       loop do
         @logger.info "Sending #{msg.class}"
         sendmsg_topic("logstash-broadcast", msg)