public class Pipeline<M> extends java.lang.Object implements Lifecycle
Modifier and Type | Class and Description |
---|---|
static class |
Pipeline.State |
Modifier and Type | Method and Description |
---|---|
void |
addStateListener(java.lang.Runnable runnable,
Pipeline.State... states) |
java.util.Map<java.lang.String,java.util.Collection<RuntimeStage.ThrowableAndMessage<M>>> |
getErrors()
Collect errors from the stages
|
java.lang.String |
getInstanceId() |
MetricRegistry |
getMetrics() |
java.lang.String |
getPipelineId() |
java.util.Map<java.lang.String,java.lang.Object> |
getProperties() |
long |
getRunningTimeMs() |
java.util.List<RuntimeStage<M>> |
getStages() |
<any> |
getStartTime() |
Pipeline.State |
getState() |
boolean |
isInState(Pipeline.State... states) |
boolean |
isTerminalState() |
boolean |
maybeStop() |
long |
send(java.util.Iterator<M> messages,
Context requestContext) |
void |
send(M message,
Context requestContext) |
void |
send(M message,
java.util.Map<java.lang.String,java.lang.String> requestProperties) |
void |
send(M message,
java.util.Map<java.lang.String,java.lang.String> requestProperties,
StageCallback<M> callback) |
void |
sendEndOfBatch(Context requestContext)
for use when messages are being sent through the non iterators method when a downstream consumer needs to know
that the last pipeline message has been sent
|
void |
start() |
void |
stop() |
public java.lang.String getInstanceId()
public java.lang.String getPipelineId()
public Pipeline.State getState()
public MetricRegistry getMetrics()
public <any> getStartTime()
public java.util.Map<java.lang.String,java.lang.Object> getProperties()
public java.util.List<RuntimeStage<M>> getStages()
public long getRunningTimeMs()
public java.util.Map<java.lang.String,java.util.Collection<RuntimeStage.ThrowableAndMessage<M>>> getErrors()
public boolean maybeStop()
public void send(M message, java.util.Map<java.lang.String,java.lang.String> requestProperties)
public void send(M message, java.util.Map<java.lang.String,java.lang.String> requestProperties, StageCallback<M> callback)
public long send(java.util.Iterator<M> messages, Context requestContext)
messages
- - Iterator of pipeline messagesrequestContext
- public void sendEndOfBatch(Context requestContext)
requestContext
- public void addStateListener(java.lang.Runnable runnable, Pipeline.State... states)
public boolean isInState(Pipeline.State... states)
public boolean isTerminalState()