mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 22:57:16 -04:00
Merge pull request #226 from nuvan/stompfix
Fixed Stomp input plugin subscription method.
This commit is contained in:
commit
c217522eb8
1 changed files with 7 additions and 0 deletions
|
@ -58,6 +58,13 @@ class LogStash::Inputs::Stomp < LogStash::Inputs::Base
|
||||||
e = to_event(msg.body, @stomp_url)
|
e = to_event(msg.body, @stomp_url)
|
||||||
@output_queue << e if e
|
@output_queue << e if e
|
||||||
end
|
end
|
||||||
|
#In the event that there is only Stomp input plugin instances
|
||||||
|
#the process ends prematurely. The above code runs, and return
|
||||||
|
#the flow control to the 'run' method below. After that, the
|
||||||
|
#method "run_input" from agent.rb marks 'done' as 'true' and calls
|
||||||
|
#'finish' over the Stomp plugin instance.
|
||||||
|
#'Sleeping' the plugin leves the instance alive.
|
||||||
|
sleep
|
||||||
end
|
end
|
||||||
|
|
||||||
public
|
public
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue