in taverna-workflowmodel-extensions/src/main/java/org/apache/taverna/workflowmodel/processor/dispatch/layers/ErrorBounce.java [198:282]
public void injectPropertiesFor(final String owningProcess) {
MonitorableProperty<Integer> errorsReflectedProperty = new MonitorableProperty<Integer>() {
@Override
public Date getLastModified() {
return new Date();
}
@Override
public String[] getName() {
return new String[] { "dispatch", "errorbounce", "reflected" };
}
@Override
public Integer getValue() throws NoSuchPropertyException {
ErrorBounceState ebs = state.get(owningProcess);
if (ebs == null)
return 0;
return ebs.getErrorsReflected();
}
};
dispatchStack.receiveMonitorableProperty(errorsReflectedProperty,
owningProcess);
MonitorableProperty<Integer> errorsTranslatedProperty = new MonitorableProperty<Integer>() {
@Override
public Date getLastModified() {
return new Date();
}
@Override
public String[] getName() {
return new String[] { "dispatch", "errorbounce", "translated" };
}
@Override
public Integer getValue() throws NoSuchPropertyException {
ErrorBounceState ebs = state.get(owningProcess);
if (ebs == null)
return 0;
return ebs.getErrorsTranslated();
}
};
dispatchStack.receiveMonitorableProperty(errorsTranslatedProperty,
owningProcess);
MonitorableProperty<Integer> totalTranslatedTranslatedProperty = new MonitorableProperty<Integer>() {
@Override
public Date getLastModified() {
return new Date();
}
@Override
public String[] getName() {
return new String[] { "dispatch", "errorbounce",
"totalTranslated" };
}
@Override
public Integer getValue() throws NoSuchPropertyException {
return totalTranslatedErrors;
}
};
dispatchStack.receiveMonitorableProperty(
totalTranslatedTranslatedProperty, owningProcess);
MonitorableProperty<Integer> totalReflectedTranslatedProperty = new MonitorableProperty<Integer>() {
@Override
public Date getLastModified() {
return new Date();
}
@Override
public String[] getName() {
return new String[] { "dispatch", "errorbounce",
"totalReflected" };
}
@Override
public Integer getValue() throws NoSuchPropertyException {
return totalReflectedErrors;
}
};
dispatchStack.receiveMonitorableProperty(
totalReflectedTranslatedProperty, owningProcess);
}