* The method completely replaces the original response body with "body replaced". * * @param processingResponseBuilder the builder used to construct the {@link ProcessingResponse}. * @param body the {@link HttpBody} object representing the original response body. */ @Override public void onResponseBody(ProcessingResponse.Builder processingResponseBuilder, HttpBody body) { // Replace the body with "body replaced" addBodyMutations(processingResponseBuilder.getResponseBodyBuilder(), "body replaced", null, null); } /** * Main method to start the gRPC callout server with a custom configuration * using the {@link ServiceCallout.Builder}. *
* This method initializes the server with default or custom configurations, * starts the server, and keeps it running until manually terminated. * The server processes incoming gRPC requests for HTTP manipulations. *
* *Usage:
*{@code
* ServiceCallout.Builder builder = new ServiceCallout.Builder()
* .setIp("111.222.333.444") // Customize IP
* .setPort(8443) // Set the port for secure communication
* .setEnablePlainTextPort(true) // Enable an plaintext communication port
* .setServerThreadCount(4); // Set the number of server threads
* }
*
* @param args Command-line arguments, not used in this implementation.
* @throws Exception If an error occurs during server startup or shutdown.
*/
public static void main(String[] args) throws Exception {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
callouts/java/service-callout/src/main/java/example/BasicCalloutServer.java [114:155]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
@Override
public void onRequestBody(ProcessingResponse.Builder processingResponseBuilder, HttpBody body) {
// Modify the body by appending "-added-body" and ensure no clearBody action
addBodyMutations(processingResponseBuilder.getRequestBodyBuilder(), body.getBody().toStringUtf8() + "-added-body", null, null);
}
/**
* Handles the response body by replacing it with a static value.
* * The method completely replaces the original response body with "body replaced". * * @param processingResponseBuilder the builder used to construct the {@link ProcessingResponse}. * @param body the {@link HttpBody} object representing the original response body. */ @Override public void onResponseBody(ProcessingResponse.Builder processingResponseBuilder, HttpBody body) { // Replace the body with "body replaced" addBodyMutations(processingResponseBuilder.getResponseBodyBuilder(), "body replaced", null, null); } /** * Main method to start the gRPC callout server with a custom configuration * using the {@link ServiceCallout.Builder}. *
* This method initializes the server with default or custom configurations, * starts the server, and keeps it running until manually terminated. * The server processes incoming gRPC requests for HTTP manipulations. *
* *Usage:
*{@code
* ServiceCallout.Builder builder = new ServiceCallout.Builder()
* .setIp("111.222.333.444") // Customize IP
* .setPort(8443) // Set the port for secure communication
* .setEnablePlainTextPort(true) // Enable an plaintext communication port
* .setServerThreadCount(4); // Set the number of server threads
* }
*
* @param args Command-line arguments, not used in this implementation.
* @throws Exception If an error occurs during server startup or shutdown.
*/
public static void main(String[] args) throws Exception {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -