lib/logstash/outputs/zeromq.rb in logstash-output-zeromq-0.1.6 vs lib/logstash/outputs/zeromq.rb in logstash-output-zeromq-1.0.0
- old
+ new
@@ -28,12 +28,10 @@
# * pubsub - inputs are subscribers, outputs are publishers
# * pair - inputs are clients, inputs are servers
#
# If the predefined topology flows don't work for you,
# you can change the 'mode' setting
- # TODO (lusis) add req/rep MAYBE
- # TODO (lusis) add router/dealer
config :topology, :validate => ["pushpull", "pubsub", "pair"], :required => true
# This is used for the 'pubsub' topology only.
# On inputs, this allows you to filter messages by topic.
# On outputs, this allows you to tag a message for routing.
@@ -53,10 +51,13 @@
# * ZMQ::IDENTITY - named queues
# * ZMQ::SWAP_SIZE - space for disk overflow
#
# Example:
# [source,ruby]
- # sockopt => ["ZMQ::HWM", 50, "ZMQ::IDENTITY", "my_named_queue"]
+ # sockopt => {
+ # "ZMQ::HWM" => 50
+ # "ZMQ::IDENTITY" => "my_named_queue"
+ # }
config :sockopt, :validate => :hash
public
def register
require "ffi-rzmq"