input {
    stomp {
        destination => "/topic/myevents"
        host => "rabbitmq"
        password => "guest"
        user => "guest"
        vhost => "/"
        debug => true
        port => 61613
     }
}

filter {
    ruby {
        code => 'require "open3"
        cmd = "/bin/events_filter.py {input should go here}"
             stdin, stdout, stderr = Open3.popen3(cmd)
        '
    }
}

output {
    file {
        path => "~/events.txt"
    }
}