Class SizeBasedRoutingOperation
- java.lang.Object
-
- com.boomi.connector.util.ContextualOperation
-
- com.boomi.connector.util.BaseOperation
-
- com.boomi.connector.util.BaseUpdateOperation
-
- com.boomi.connector.sample.resource.SizeBasedRoutingOperation
-
- All Implemented Interfaces:
Operation
public class SizeBasedRoutingOperation extends BaseUpdateOperation
Sample operation that demonstrates how to process input documents differently based on the size of the input document. This is conceptually similar to howSizeLimitedUpdateOperation
implementations work but this examples still processes documents whose size exceeds the limit where the size limited operations would automatically treat "large" documents as application errors. Note: "large" documents (generally anything over 1MB) should not be held in memory and should be processed using streams.
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
SizeBasedRoutingOperation(OperationContext context)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
executeUpdate(UpdateRequest request, OperationResponse response)
Actual implementation of this CREATE, UPDATE, or UPSERT Operation.-
Methods inherited from class com.boomi.connector.util.BaseUpdateOperation
execute
-
Methods inherited from class com.boomi.connector.util.ContextualOperation
getConnection, getContext
-
-
-
-
Constructor Detail
-
SizeBasedRoutingOperation
protected SizeBasedRoutingOperation(OperationContext context)
-
-
Method Detail
-
executeUpdate
protected void executeUpdate(UpdateRequest request, OperationResponse response)
Description copied from class:BaseUpdateOperation
Actual implementation of this CREATE, UPDATE, or UPSERT Operation.- Specified by:
executeUpdate
in classBaseUpdateOperation
- Parameters:
request
- request given toBaseUpdateOperation.execute(com.boomi.connector.api.OperationRequest, com.boomi.connector.api.OperationResponse)
, downcast to the correct typeresponse
- response given toBaseUpdateOperation.execute(com.boomi.connector.api.OperationRequest, com.boomi.connector.api.OperationResponse)
-
-