class SenderClient
SenderClient
parses arguments and runs sender
Public Class Methods
new(args)
click to toggle source
Initialization of sender client, parsing sender client arguments and sender client run
Parameters¶ ↑
- args
-
sender client arguments
# File lib/sender_client.rb, line 30 def initialize(args) # Parse arguments sender_options_parser = Options::SenderOptionParser.new(args) # Create sender handler sender_handler = Handlers::SenderHandler.new( sender_options_parser.options.broker, sender_options_parser.options.log_msgs, sender_options_parser.options.msg_content_hashed, sender_options_parser.options.count, sender_options_parser.options.msg_properties, sender_options_parser.options.msg_content, sender_options_parser.options.msg_content_type, sender_options_parser.options.msg_durable, sender_options_parser.options.msg_ttl, sender_options_parser.options.msg_correlation_id, sender_options_parser.options.msg_reply_to, sender_options_parser.options.msg_group_id, sender_options_parser.options.msg_to, sender_options_parser.options.msg_priority, sender_options_parser.options.msg_id, sender_options_parser.options.msg_user_id, sender_options_parser.options.msg_subject, sender_options_parser.options.anonymous, sender_options_parser.options.sasl_mechs, sender_options_parser.options.idle_timeout, sender_options_parser.options.max_frame_size, sender_options_parser.options.sasl_enabled, sender_options_parser.options.log_lib, sender_options_parser.options.auto_settle_off, sender_options_parser.options.exit_timer, sender_options_parser.options.duration, sender_options_parser.options.duration_mode ) # Run sender client Qpid::Proton::Container.new(sender_handler).run end