$:.unshift File.dirname(__FILE__) + '/../../lib/'
require 'rubygems'
require 'q4m'
require 'json'

q = Q4M.connect :connect_info => ['DBI:Mysql:database=test_q4m', 'root', '']
table = 'example_json_queue_monitor'

puts '[client] write message:'
input = gets
data = {:message => input, :time => Time.now}
q.insert(table, :v => data.to_json)