Response class for indicating the result of processing each message. Use static methods: ok(), failure(), fallback(), serve(), onSuccess()
ok()
failure()
fallback()
serve()
onSuccess()
// Successsink.Response.ok(datum.id)// Failuresink.Response.failure(datum.id, 'Error message')// Fallback for retrysink.Response.fallback(datum.id) Copy
// Successsink.Response.ok(datum.id)// Failuresink.Response.failure(datum.id, 'Error message')// Fallback for retrysink.Response.fallback(datum.id)
Static
Create a failure response for a datum.
The ID of the failed datum
Error message describing the failure
A failure Response
Create a fallback response for retry.
The ID of the datum to retry
A fallback Response
Create a success response for a datum.
The ID of the processed datum
A success Response
Create an onSuccess response with an optional message.
The ID of the datum
Optional
Optional message to include
An onSuccess Response
Create a serve response with a payload.
The payload to serve
A serve Response
Response class for indicating the result of processing each message. Use static methods:
ok(),failure(),fallback(),serve(),onSuccess()Example