Navigation Menu

Skip to content

Commit

Permalink
Call serf command correctly
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Jun 27, 2014
1 parent eecad74 commit 2ea22d6
Showing 1 changed file with 10 additions and 2 deletions.
12 changes: 10 additions & 2 deletions lib/droonga/serf.rb
Expand Up @@ -58,13 +58,13 @@ def load_status

def send_event(name, event, payload)
serf = new(nil, name)
serf.run("event", JSON.generate(payload))
serf.send_event(event, payload)
serf.shutdown
end

def send_query(name, query, payload)
serf = new(nil, name)
serf.run("query", JSON.generate(payload))
serf.send_query(query, payload)
serf.shutdown
end
end
Expand Down Expand Up @@ -107,6 +107,14 @@ def shutdown
logger.trace("shutdown: done")
end

def send_event(event, payload)
run("event", event, JSON.generate(payload))
end

def send_query(query, payload)
run("query", query, JSON.generate(payload))
end

private
def ensure_serf
@serf = find_system_serf
Expand Down

0 comments on commit 2ea22d6

Please sign in to comment.