Method: Fluent::PostgresqlQueryBasedFlydataInput#shutdown

Defined in:
lib/flydata/fluent-plugins/in_postgresql_query_based_flydata.rb

#shutdown ⇒ Object 



57
58
59
60
61
62
63
 
# File 'lib/flydata/fluent-plugins/in_postgresql_query_based_flydata.rb', line 57

def shutdown
  if @thread and @thread.alive?
    @client.stop_request
    @thread.join
  end
  super
end