Sha256: eadb42813f41b0bbfda4d1ab012e783a7824539ff06bfcd183eefac0c87063f6

Contents?: true

Size: 419 Bytes

Versions: 24

Compression:

Stored size: 419 Bytes

Contents

require "cabin/namespace"

# This mixin allows you to easily give channel and publish features
# to a class.
module Cabin::Publisher
  # Set the channel
  def channel=(channel)
    @channel = channel
  end # def channel=

  # Get the channel
  def channel
    return @channel
  end # def channel

  # Publish to the channel
  def publish(object)
    @channel << object
  end # def publish
end # module Cabin::Publisher

Version data entries

24 entries across 22 versions & 6 rubygems

Version Path
logstash-filter-zabbix-0.1.2 vendor/bundle/jruby/1.9/gems/cabin-0.8.1/lib/cabin/publisher.rb
logstash-filter-zabbix-0.1.1 vendor/bundle/jruby/1.9/gems/cabin-0.8.1/lib/cabin/publisher.rb
ivanvc-logstash-input-s3-3.1.1.4 vendor/local/gems/cabin-0.8.1/lib/cabin/publisher.rb
ivanvc-logstash-input-s3-3.1.1.3 vendor/local/gems/cabin-0.8.1/lib/cabin/publisher.rb
ivanvc-logstash-input-s3-3.1.1.2 vendor/local/gems/cabin-0.8.1/lib/cabin/publisher.rb
cabin-0.9.0 lib/cabin/publisher.rb
able-neo4j-1.0.0 vendor/bundle/jruby/1.9/gems/cabin-0.7.1/lib/cabin/publisher.rb
cabin-0.8.1 lib/cabin/publisher.rb
cabin-0.8.0 lib/cabin/publisher.rb
logstash-input-beats-2.0.2 vendor/jruby/1.9/gems/logstash-codec-json-2.0.3/vendor/gems/cabin-0.7.2/lib/cabin/publisher.rb
logstash-input-beats-2.0.2 vendor/jruby/1.9/gems/cabin-0.7.1/lib/cabin/publisher.rb
logstash-input-beats-2.0.2 vendor/jruby/1.9/gems/cabin-0.7.2/lib/cabin/publisher.rb
logstash-codec-json-2.0.3 vendor/gems/cabin-0.7.2/lib/cabin/publisher.rb
cabin-0.7.2 lib/cabin/publisher.rb
logstash-input-beats-0.9.2 vendor/jruby/1.9/gems/cabin-0.7.1/lib/cabin/publisher.rb
logstash-input-beats-0.9.1 vendor/jruby/1.9/gems/cabin-0.7.1/lib/cabin/publisher.rb
cabin-0.7.1 lib/cabin/publisher.rb
cabin-0.6.1 lib/cabin/publisher.rb
cabin-0.6.0 lib/cabin/publisher.rb
cabin-0.5.0 lib/cabin/publisher.rb