lib/logstash/outputs/elasticsearch_http.rb in logstash-output-elasticsearch_http-1.0.0 vs lib/logstash/outputs/elasticsearch_http.rb in logstash-output-elasticsearch_http-2.0.0
- old
+ new
@@ -92,10 +92,10 @@
# shards have been written. If sync (default), index requests
# will wait until the primary and the replica shards have been
# written.
config :replication, :validate => ['async', 'sync'], :default => 'sync'
- def_delegators :@elasticsearch_output, :teardown, :register, :receive
+ def_delegators :@elasticsearch_output, :close, :register, :receive
def initialize(options = {})
super(options)
@logger = Cabin::Channel.get(LogStash)