class Citrus::EventBus::Configuration

Attributes

event_serializer[R]
host[R]
port[R]
topic[R]

Public Class Methods

new() click to toggle source
# File lib/citrus/event_bus/configuration.rb, line 8
def initialize
  @event_serializer = Serializer.new
  @topic            = 'citrus_stream'
  @host             = 'localhost'
  @port             = 9092
end

Public Instance Methods

connection_string() click to toggle source
# File lib/citrus/event_bus/configuration.rb, line 15
def connection_string
  "#{host}:#{port}"
end