class StickyElephant::Handler::Query

Public Instance Methods

process() click to toggle source
# File lib/sticky_elephant/handler/query.rb, line 4
def process
  log(msg: "#{payload}", level: :info)
  report_query(payload.to_s)

  socket.write(
    PostgresSimulator.new(
      extract_query_from(payload)
    )
  )
end

Private Instance Methods

extract_query_from(payload) click to toggle source
# File lib/sticky_elephant/handler/query.rb, line 17
def extract_query_from(payload)
  payload.to_s(with_type: false)
end