Constructor and Description |
---|
ParametrizedUriEmitter(ParametrizedUriEmitterConfig config,
org.asynchttpclient.AsyncHttpClient client,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
ParametrizedUriEmitter(ParametrizedUriEmitterConfig config,
org.asynchttpclient.AsyncHttpClient client,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
UriExtractor uriExtractor) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
emit(Event event) |
void |
flush() |
void |
forEachEmitter(BiConsumer<URI,HttpPostEmitter> action) |
void |
start() |
String |
toString() |
public ParametrizedUriEmitter(ParametrizedUriEmitterConfig config, org.asynchttpclient.AsyncHttpClient client, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)
public ParametrizedUriEmitter(ParametrizedUriEmitterConfig config, org.asynchttpclient.AsyncHttpClient client, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, UriExtractor uriExtractor)
public void close() throws IOException
close
in interface Emitter
close
in interface Closeable
close
in interface AutoCloseable
IOException
public void flush() throws IOException
flush
in interface Emitter
flush
in interface Flushable
IOException
public void forEachEmitter(BiConsumer<URI,HttpPostEmitter> action)
Copyright © 2011–2018. All rights reserved.