Class: Emque::Producing::Configuration

Inherits:
Object
  • Object
show all
Defined in:
lib/emque/producing/configuration.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Configuration

Returns a new instance of Configuration.



12
13
14
15
16
17
18
19
20
21
 
# File 'lib/emque/producing/configuration.rb', line 12

def initialize
  @app_name = ""
  @publishing_adapter = :rabbitmq
  @error_handlers = []
  @log_publish_message = false
  @publish_messages = true
  @kafka_options = { :seed_brokers => ["localhost:9092"],
                     :producer_options => {} }
  @rabbitmq_options = { :url => "amqp://guest:guest@localhost:5672" }
end

Instance Attribute Details

#app_name ⇒ Object

Returns the value of attribute app_name.



4
5
6
 
# File 'lib/emque/producing/configuration.rb', line 4

def app_name
  @app_name
end

#error_handlers ⇒ Object

Returns the value of attribute error_handlers.



8
9
10
 
# File 'lib/emque/producing/configuration.rb', line 8

def error_handlers
  @error_handlers
end

#kafka_options ⇒ Object

Returns the value of attribute kafka_options.



6
7
8
 
# File 'lib/emque/producing/configuration.rb', line 6

def kafka_options
  @kafka_options
end

#log_publish_message ⇒ Object

Returns the value of attribute log_publish_message.



9
10
11
 
# File 'lib/emque/producing/configuration.rb', line 9

def log_publish_message
  @log_publish_message
end

#publish_messages ⇒ Object

Returns the value of attribute publish_messages.



10
11
12
 
# File 'lib/emque/producing/configuration.rb', line 10

def publish_messages
  @publish_messages
end

#publishing_adapter ⇒ Object

Returns the value of attribute publishing_adapter.



5
6
7
 
# File 'lib/emque/producing/configuration.rb', line 5

def publishing_adapter
  @publishing_adapter
end

#rabbitmq_options ⇒ Object

Returns the value of attribute rabbitmq_options.



7
8
9
 
# File 'lib/emque/producing/configuration.rb', line 7

def rabbitmq_options
  @rabbitmq_options
end