exe/kafkr in kafkr-0.18.0 vs exe/kafkr in kafkr-0.018.1
- old
+ new
@@ -4,21 +4,21 @@
PORT = ENV["KAFKR_PORT"] || 4000
begin
require "kafkr"
rescue LoadError => e
- puts "Failed to load Kafkr: #{e.message}"
+ Kafkr.log "Failed to load Kafkr: #{e.message}"
exit(1)
end
begin
server = Kafkr::Log.new(PORT.to_i)
- puts "Kafkr Log version #{Kafkr::VERSION} started on port #{PORT}!"
+ Kafkr.log "Kafkr Log version #{Kafkr::VERSION} started on port #{PORT}!"
server.start
rescue => e
- puts "An error occurred: #{e.message}"
+ Kafkr.log "An error occurred: #{e.message}"
exit(1)
rescue Interrupt
- puts "\nLog server shutting down gracefully..."
+ Kafkr.log "\nLog server shutting down gracefully..."
server.stop if server.respond_to?(:stop)
exit(0)
end