@@ -126,8 +126,6 @@ public void send(URI url, byte[] payload) throws InterruptedException {
126126 void runOnce (Map .Entry <BoundedQueue .Key , Payload > item ) throws InterruptedException {
127127 Payload payload = item .getValue ();
128128 final URI url = baseUri .resolve (payload .url );
129- logger .log (
130- Level .INFO , "sending {0} bytes to {1}" , new Object [] {payload .bytes .length , url });
131129
132130 HttpRequest .Builder builder =
133131 HttpRequest .newBuilder (url ).POST (BodyPublishers .ofByteArray (payload .bytes ));
@@ -147,11 +145,16 @@ void runOnce(Map.Entry<BoundedQueue.Key, Payload> item) throws InterruptedExcept
147145 res .body ();
148146
149147 logger .log (
150- Level .INFO , "response {0}: {1}" , new Object [] {res .statusCode (), res .body ()});
148+ Level .FINER ,
149+ "sending {0} bytes to {1}: {2} {3}" ,
150+ new Object [] {payload .bytes .length , url , res .statusCode (), res .body ()});
151151
152152 handleResponse (res .statusCode (), item );
153153 } catch (IOException ex ) {
154- logger .log (Level .WARNING , "error sending request: {0}" , ex .toString ());
154+ logger .log (
155+ Level .WARNING ,
156+ "error sending {0} bytes to {1}: {2}" ,
157+ new Object [] {payload .bytes .length , url , ex .toString ()});
155158 handleTransportError (item );
156159 } catch (InterruptedException ex ) {
157160 // Wouldn't be retried, but will show up as a leftover in a telemetry snapshot.
@@ -203,7 +206,7 @@ void increaseBackoff() {
203206 void backoff () throws InterruptedException {
204207 if (delay > 0 ) {
205208 int sleep = (int ) (250.0 * delay * (0.5 + rng .nextDouble ()));
206- logger .log (Level .INFO , "backoff={0}, sleeping {1}ms" , new Object [] {delay , sleep });
209+ logger .log (Level .FINEST , "backoff={0}, sleeping {1}ms" , new Object [] {delay , sleep });
207210 Thread .sleep (sleep );
208211 }
209212 }
0 commit comments