@@ -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,11 @@ 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 , "sending {0} bytes to {1}: {2} {3} " , new Object [] { payload . bytes . length , url , res .statusCode (), res .body () });
151149
152150 handleResponse (res .statusCode (), item );
153151 } catch (IOException ex ) {
154- logger .log (Level .WARNING , "error sending request : {0 }" , ex .toString ());
152+ logger .log (Level .WARNING , "error sending {0} bytes to {1} : {2 }" , new Object [] { payload . bytes . length , url , ex .toString () } );
155153 handleTransportError (item );
156154 } catch (InterruptedException ex ) {
157155 // Wouldn't be retried, but will show up as a leftover in a telemetry snapshot.
@@ -203,7 +201,7 @@ void increaseBackoff() {
203201 void backoff () throws InterruptedException {
204202 if (delay > 0 ) {
205203 int sleep = (int ) (250.0 * delay * (0.5 + rng .nextDouble ()));
206- logger .log (Level .INFO , "backoff={0}, sleeping {1}ms" , new Object [] {delay , sleep });
204+ logger .log (Level .FINEST , "backoff={0}, sleeping {1}ms" , new Object [] {delay , sleep });
207205 Thread .sleep (sleep );
208206 }
209207 }
0 commit comments