Package org.ikasan.flow.visitorPattern.invoker

Class ConcurrentSplitterFlowElementInvoker.SplitFlowCallback

java.lang.Object

org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterFlowElementInvoker.SplitFlowCallback

All Implemented Interfaces:

com.google.common.util.concurrent.FutureCallback<ConcurrentSplitterFlowElementInvoker.SplitFlowElement>

Enclosing class:

ConcurrentSplitterFlowElementInvoker

protected class ConcurrentSplitterFlowElementInvoker.SplitFlowCallback
extends java.lang.Object
implements com.google.common.util.concurrent.FutureCallback<ConcurrentSplitterFlowElementInvoker.SplitFlowElement>

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.concurrent.atomic.AtomicInteger	count
protected org.ikasan.spec.flow.FlowInvocationContext	flowInvocationContext
protected java.util.List<java.lang.Object>	subFlowPayloads

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SplitFlowCallback(java.util.List<java.lang.Object> subFlowPayloads, org.ikasan.spec.flow.FlowInvocationContext flowInvocationContext, java.util.concurrent.atomic.AtomicInteger count)

Method Summary

Modifier and Type	Method	Description
void	onFailure(java.lang.Throwable thrown)
void	onSuccess(ConcurrentSplitterFlowElementInvoker.SplitFlowElement splitFlowElement)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

subFlowPayloads

protected java.util.List<java.lang.Object> subFlowPayloads

flowInvocationContext

protected org.ikasan.spec.flow.FlowInvocationContext flowInvocationContext

count

protected java.util.concurrent.atomic.AtomicInteger count

Constructor Detail

SplitFlowCallback

protected SplitFlowCallback(java.util.List<java.lang.Object> subFlowPayloads,
                            org.ikasan.spec.flow.FlowInvocationContext flowInvocationContext,
                            java.util.concurrent.atomic.AtomicInteger count)

Method Detail

onSuccess

public void onSuccess(ConcurrentSplitterFlowElementInvoker.SplitFlowElement splitFlowElement)

Specified by:

onSuccess in interface com.google.common.util.concurrent.FutureCallback<ConcurrentSplitterFlowElementInvoker.SplitFlowElement>

onFailure

public void onFailure(java.lang.Throwable thrown)

Specified by:

onFailure in interface com.google.common.util.concurrent.FutureCallback<ConcurrentSplitterFlowElementInvoker.SplitFlowElement>