changed error handling when adding records
diff --git a/core/org.eclipse.smila.connectivity.bulkbuilder/code/src/org/eclipse/smila/connectivity/bulkbuilder/ConnectivityManagerImpl.java b/core/org.eclipse.smila.connectivity.bulkbuilder/code/src/org/eclipse/smila/connectivity/bulkbuilder/ConnectivityManagerImpl.java
index 2400624..04eec4b 100644
--- a/core/org.eclipse.smila.connectivity.bulkbuilder/code/src/org/eclipse/smila/connectivity/bulkbuilder/ConnectivityManagerImpl.java
+++ b/core/org.eclipse.smila.connectivity.bulkbuilder/code/src/org/eclipse/smila/connectivity/bulkbuilder/ConnectivityManagerImpl.java
@@ -22,6 +22,7 @@
import org.eclipse.smila.jobmanager.JobManager;
import org.eclipse.smila.jobmanager.JobRunInfo;
import org.eclipse.smila.jobmanager.JobState;
+import org.eclipse.smila.utils.MaybeRecoverableException;
/**
* JobManager/Bulkbuilder based implementation of ConnectivityManager interface.
@@ -68,17 +69,16 @@
for (final Record record : records) {
try {
_bulkbuilder.addRecord(jobName, record);
- } catch (final BulkbuilderException e) {
+ } catch (final MaybeRecoverableException e) {
final String msg = "Error while adding record with id '" + record.getId() + "' to bulkbuilder";
if (e.isRecoverable()) {
- throw new ConnectivityException(msg, e, false);
- } else {
_log.warn(msg, e);
exceptionMap.put(record.getId(), e);
+ } else {
+ throw new ConnectivityException(msg, e, false);
}
} catch (final Exception e) {
- _log.warn("Error while adding record with id '" + record.getId() + "' to bulkbuilder", e);
- exceptionMap.put(record.getId(), e);
+ throw new ConnectivityException(e, false);
}
}
if (!exceptionMap.isEmpty()) {