Contents

class Cabin::Subscriber
  attr :output
  attr :options
  def initialize(output, options = {})
    @output = output
    @options = options
  end

  def <<(data)
    @output << data
  end
end

Version data entries

7 entries across 7 versions & 3 rubygems

Version	Path
logstash-filter-zabbix-0.1.2	vendor/bundle/jruby/1.9/gems/cabin-0.8.1/lib/cabin/subscriber.rb
logstash-filter-zabbix-0.1.1	vendor/bundle/jruby/1.9/gems/cabin-0.8.1/lib/cabin/subscriber.rb
ivanvc-logstash-input-s3-3.1.1.4	vendor/local/gems/cabin-0.8.1/lib/cabin/subscriber.rb
ivanvc-logstash-input-s3-3.1.1.3	vendor/local/gems/cabin-0.8.1/lib/cabin/subscriber.rb
ivanvc-logstash-input-s3-3.1.1.2	vendor/local/gems/cabin-0.8.1/lib/cabin/subscriber.rb
cabin-0.9.0	lib/cabin/subscriber.rb
cabin-0.8.1	lib/cabin/subscriber.rb