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()) {