public class Emitter extends Emitter
Emitter.EmitterBuilderbufferOption, byteLimitGet, byteLimitPost, call, context, emitterTick, emptyLimit, hostnameVerifier, httpMethod, isRunning, JSON, POST_STM_BYTES, POST_WRAPPER_BYTES, requestCallback, requestSecurity, sendLimit, sslSocketFactory, timeUnit, uri, uriBuilder| 构造器和说明 |
|---|
Emitter(Emitter.EmitterBuilder builder)
Constructs the Emitter Object.
|
| 限定符和类型 | 方法和说明 |
|---|---|
void |
add(DataLoad payload)
Adds a payload to the EventStore and
then attempts to start the emitter
if it is not currently running.
|
void |
add(DataLoad payload,
boolean attemptEmit) |
void |
flush()
Attempts to start the emitter if it
is not currently running.
|
boolean |
getEmitterStatus() |
Store |
getEventStore() |
void |
shutdown()
Resets the `isRunning` truth to false.
|
buildRequests, close, getBufferOption, getByteLimitGet, getByteLimitPost, getEmitterTick, getEmitterUri, getEmptyLimit, getHttpMethod, getRequestCallback, getRequestSecurity, getSendLimit, isSuccessfulSend, performSyncEmit, requestSender, setBufferOption, setEmitterUri, setHttpMethod, setRequestSecuritypublic Emitter(Emitter.EmitterBuilder builder)
builder - the base emitter builder.public void add(DataLoad payload)
public void add(DataLoad payload, boolean attemptEmit)
public void flush()
public Store getEventStore()
getEventStore 在类中 Emitterpublic boolean getEmitterStatus()
getEmitterStatus 在类中 Emitter