localSolution = createMLPSolution(peerSolution, cdsClient);
}
else {
+ log.info(EELFLoggerDelegate.debugLogger, "Solution Id : " + peerSolution.getSolutionId()
+ + " exists locally, updating local catalog ");
localSolution = updateMLPSolution(peerSolution, localSolution, cdsClient);
}
* Was there an error ?
*/
@JsonProperty(value = JSONTags.TAG_RESPONSE_ERROR)
- //private Boolean error;
private String error;
/**
*/
@JsonProperty(value = JSONTags.TAG_RESPONSE_CONTENT)
private T content;
-/*
- public Boolean isError() {
- return this.error;
- }
-
- public void setError(Boolean isError) {
- this.error = isError;
- }
-*/
+
public String getError() {
return this.error;
}
private JsonResponse<T> response = new JsonResponse();
public JsonResponseBuilder() {
- this.response.setError(Boolean.FALSE.toString());
+ this.response.setError(null);
}
public JsonResponseBuilder<T> withMessage(String theMessage) {
}
public JsonErrorResponseBuilder<T> withError(Throwable theError) {
- this.response.setMessage(theError.toString());
+ this.response.setError(theError.toString());
return this;
}
for (MLPPeer mlpPeer : mlpPeers) {
log.info(EELFLoggerDelegate.debugLogger, "checkPeer : " + mlpPeer);
+ if (mlpPeer.isSelf())
+ continue;
+
// cancel peer tasks for inactive peers
if (PeerStatus.Active != PeerStatus.forCode(mlpPeer.getStatusCode())) {
// cancel all peer sub tasks for this peer
private static Pattern cdsNotFoundPattern = null;
{
try {
- cdsNotFoundPattern = Pattern.compile("No (.*) for ID (.*)");
+ cdsNotFoundPattern = Pattern.compile("No (.*) with ID (.*)");
}
catch (PatternSyntaxException psx) {
throw new RuntimeException("Invalid error pattern", psx);