diff --git a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/AbstractTableSyncTransformStep.java b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/AbstractTableSyncTransformStep.java index 5b1bc1b7..367bea56 100644 --- a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/AbstractTableSyncTransformStep.java +++ b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/AbstractTableSyncTransformStep.java @@ -319,8 +319,14 @@ public abstract class AbstractTableSyncTransformStep extends AbstractTransformSt continue; } + //////////////////////////////////////////////////////////////// + // if we received a record to store add to the output records // + //////////////////////////////////////////////////////////////// recordToStore = populateRecordToStore(runBackendStepInput, recordToStore, sourceRecord); - runBackendStepOutput.addRecord(recordToStore); + if(recordToStore != null) + { + runBackendStepOutput.addRecord(recordToStore); + } } //////////////////////////////////////////////// diff --git a/qqq-backend-module-api/src/main/java/com/kingsrook/qqq/backend/module/api/actions/BaseAPIActionUtil.java b/qqq-backend-module-api/src/main/java/com/kingsrook/qqq/backend/module/api/actions/BaseAPIActionUtil.java index e32ede54..c2617519 100644 --- a/qqq-backend-module-api/src/main/java/com/kingsrook/qqq/backend/module/api/actions/BaseAPIActionUtil.java +++ b/qqq-backend-module-api/src/main/java/com/kingsrook/qqq/backend/module/api/actions/BaseAPIActionUtil.java @@ -75,6 +75,7 @@ import org.apache.http.HttpStatus; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpGet; import org.apache.http.client.methods.HttpPost; +import org.apache.http.client.methods.HttpPut; import org.apache.http.client.methods.HttpRequestBase; import org.apache.http.entity.AbstractHttpEntity; import org.apache.http.entity.StringEntity; @@ -320,8 +321,8 @@ public class BaseAPIActionUtil { try { - String url = buildTableUrl(table); - HttpPost request = new HttpPost(url); + String url = buildTableUrl(table); + HttpPut request = new HttpPut(url); request.setEntity(recordsToEntity(table, recordList)); QHttpResponse response = makeRequest(table, request);