@@ -199,13 +199,15 @@ public Receive createReceive() {
199
199
final int attempt = rejected .getAttempt ();
200
200
final Response response = rejected .getResponse ();
201
201
if (_retryableStatusCodes .contains (response .getStatusCode ()) && attempt < _sink .getMaximumAttempts ()) {
202
+ final byte [] requestBodyBytes = rejected .getRequestEntry ().getRequest ().getByteData ();
203
+ // CHECKSTYLE.OFF: IllegalInstantiation - This is ok for String from byte[]
204
+ final String requestBody = requestBodyBytes == null ? null : new String (requestBodyBytes , Charsets .UTF_8 );
205
+ // CHECKSTYLE.ON: IllegalInstantiation
202
206
POST_RETRY_LOGGER .warn ()
203
207
.setMessage ("Attempt rejected" )
204
208
.addData ("sink" , _sink )
205
209
.addData ("status" , response .getStatusCode ())
206
- // CHECKSTYLE.OFF: IllegalInstantiation - This is ok for String from byte[]
207
- .addData ("request" , new String (rejected .getRequestEntry ().getRequest ().getByteData (), Charsets .UTF_8 ))
208
- // CHECKSTYLE.ON: IllegalInstantiation
210
+ .addData ("request" , requestBody )
209
211
.addData ("response" , response .getResponseBody ())
210
212
.addContext ("actor" , self ())
211
213
.log ();
@@ -294,12 +296,16 @@ private void processRejectedRequest(final PostRejected rejected) {
294
296
responseStatusClass == i ? 1 : 0 );
295
297
}
296
298
299
+ final byte [] requestBodyBytes = rejected .getRequestEntry ().getRequest ().getByteData ();
300
+ // CHECKSTYLE.OFF: IllegalInstantiation - This is ok for String from byte[]
301
+ final String requestBody = requestBodyBytes == null ? null : new String (requestBodyBytes , Charsets .UTF_8 );
302
+ // CHECKSTYLE.ON: IllegalInstantiation
297
303
POST_ERROR_LOGGER .warn ()
298
304
.setMessage ("Post rejected" )
299
305
.addData ("sink" , _sink )
300
306
.addData ("status" , responseStatusCode )
301
307
// CHECKSTYLE.OFF: IllegalInstantiation - This is ok for String from byte[]
302
- .addData ("request" , new String ( rejected . getRequestEntry (). getRequest (). getByteData (), Charsets . UTF_8 ) )
308
+ .addData ("request" , requestBody )
303
309
// CHECKSTYLE.ON: IllegalInstantiation
304
310
.addData ("response" , responseBody )
305
311
.addContext ("actor" , self ())
0 commit comments