blob: 1a00fa4ce3b446fa93969e2d51ff67b307bed751 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
|
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
*/
package org.apache.tools.ant.taskdefs;
import org.apache.tools.ant.BuildException;
import org.apache.tools.ant.Project;
import org.apache.tools.ant.Task;
import org.apache.tools.ant.TaskContainer;
import org.apache.tools.ant.util.StringUtils;
/**
* Retries the nested task a set number of times
* @since Ant 1.7.1
*/
public class Retry extends Task implements TaskContainer {
/**
* task to execute n times
*/
private Task nestedTask;
/**
* set retryCount to 1 by default
*/
private int retryCount = 1;
/**
* The time to wait between retries in milliseconds, default to 0.
*/
private int retryDelay = 0;
/**
* set the task
* @param t the task to retry.
*/
public synchronized void addTask(Task t) {
if (nestedTask != null) {
throw new BuildException(
"The retry task container accepts a single nested task"
+ " (which may be a sequential task container)");
}
nestedTask = t;
}
/**
* set the number of times to retry the task
* @param n the number to use.
*/
public void setRetryCount(int n) {
retryCount = n;
}
/**
* set the delay between retries (in milliseconds)
* @param retryDelay the time between retries.
* @since Ant 1.8.3
*/
public void setRetryDelay(int retryDelay) {
if (retryDelay < 0) {
throw new BuildException("retryDelay must be a non-negative number");
}
this.retryDelay = retryDelay;
}
/**
* perform the work
* @throws BuildException if there is an error.
*/
public void execute() throws BuildException {
StringBuffer errorMessages = new StringBuffer();
for (int i = 0; i <= retryCount; i++) {
try {
nestedTask.perform();
break;
} catch (Exception e) {
errorMessages.append(e.getMessage());
if (i >= retryCount) {
StringBuffer exceptionMessage = new StringBuffer();
exceptionMessage.append("Task [").append(nestedTask.getTaskName());
exceptionMessage.append("] failed after [").append(retryCount);
exceptionMessage.append("] attempts; giving up.").append(StringUtils.LINE_SEP);
exceptionMessage.append("Error messages:").append(StringUtils.LINE_SEP);
exceptionMessage.append(errorMessages);
throw new BuildException(exceptionMessage.toString(), getLocation());
}
String msg;
if (retryDelay > 0) {
msg = "Attempt [" + i + "]: error occurred; retrying after " + retryDelay + " ms...";
} else {
msg = "Attempt [" + i + "]: error occurred; retrying...";
}
log(msg, e, Project.MSG_INFO);
errorMessages.append(StringUtils.LINE_SEP);
if (retryDelay > 0) {
try {
Thread.sleep(retryDelay);
} catch (InterruptedException ie) {
// Ignore Exception
}
}
}
}
}
}
|
