mirror of
https://github.com/Kingsrook/qqq.git
synced 2025-07-18 05:01:07 +00:00
CTLE-421: minor bug fixes from demo
This commit is contained in:
@ -319,8 +319,14 @@ public abstract class AbstractTableSyncTransformStep extends AbstractTransformSt
|
|||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
////////////////////////////////////////////////////////////////
|
||||||
|
// if we received a record to store add to the output records //
|
||||||
|
////////////////////////////////////////////////////////////////
|
||||||
recordToStore = populateRecordToStore(runBackendStepInput, recordToStore, sourceRecord);
|
recordToStore = populateRecordToStore(runBackendStepInput, recordToStore, sourceRecord);
|
||||||
runBackendStepOutput.addRecord(recordToStore);
|
if(recordToStore != null)
|
||||||
|
{
|
||||||
|
runBackendStepOutput.addRecord(recordToStore);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
////////////////////////////////////////////////
|
////////////////////////////////////////////////
|
||||||
|
@ -75,6 +75,7 @@ import org.apache.http.HttpStatus;
|
|||||||
import org.apache.http.client.methods.CloseableHttpResponse;
|
import org.apache.http.client.methods.CloseableHttpResponse;
|
||||||
import org.apache.http.client.methods.HttpGet;
|
import org.apache.http.client.methods.HttpGet;
|
||||||
import org.apache.http.client.methods.HttpPost;
|
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.client.methods.HttpRequestBase;
|
||||||
import org.apache.http.entity.AbstractHttpEntity;
|
import org.apache.http.entity.AbstractHttpEntity;
|
||||||
import org.apache.http.entity.StringEntity;
|
import org.apache.http.entity.StringEntity;
|
||||||
@ -320,8 +321,8 @@ public class BaseAPIActionUtil
|
|||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
String url = buildTableUrl(table);
|
String url = buildTableUrl(table);
|
||||||
HttpPost request = new HttpPost(url);
|
HttpPut request = new HttpPut(url);
|
||||||
request.setEntity(recordsToEntity(table, recordList));
|
request.setEntity(recordsToEntity(table, recordList));
|
||||||
|
|
||||||
QHttpResponse response = makeRequest(table, request);
|
QHttpResponse response = makeRequest(table, request);
|
||||||
|
Reference in New Issue
Block a user