pubsub: make Publisher log less chatty#1749
pubsub: make Publisher log less chatty#1749pongad merged 1 commit intogoogleapis:masterfrom pongad:publisher-log-level
Conversation
|
Changes Unknown when pulling b28bffa on pongad:publisher-log-level into ** on GoogleCloudPlatform:master**. |
| setupDurationBasedPublishAlarm(); | ||
| } else if (currentAlarmFuture != null) { | ||
| logger.log(Level.INFO, "Cancelling alarm"); | ||
| logger.log(Level.FINER, "Cancelling alarm, no more messages"); |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
lesv
left a comment
There was a problem hiding this comment.
@jabubake @garrettjonesgoogle @pongad I find I disagree w/ Garrett -- What I'd really want in many of these places is a logOnce primitive, but that's not part of any of the loggers.
| setupDurationBasedPublishAlarm(); | ||
| } else if (currentAlarmFuture != null) { | ||
| logger.log(Level.INFO, "Cancelling alarm"); | ||
| logger.log(Level.FINER, "Cancelling alarm, no more messages"); |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
|
|
||
| if (bundleToSend != null) { | ||
| logger.log(Level.INFO, "Scheduling a bundle for immediate sending."); | ||
| logger.log(Level.FINER, "Scheduling a bundle for immediate sending."); |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| if (hasBundlingBytes() && messageSize >= getMaxBundleBytes()) { | ||
| logger.log( | ||
| Level.INFO, "Message exceeds the max bundle bytes, scheduling it for immediate send."); | ||
| Level.FINER, "Message exceeds the max bundle bytes, scheduling it for immediate send."); |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| @Override | ||
| public void run() { | ||
| logger.log(Level.INFO, "Sending messages based on schedule."); | ||
| logger.log(Level.FINER, "Sending messages based on schedule."); |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| if (!activeAlarm.getAndSet(true)) { | ||
| long delayThresholdMs = getBundlingSettings().getDelayThreshold().getMillis(); | ||
| logger.log(Level.INFO, "Setting up alarm for the next {0} ms.", delayThresholdMs); | ||
| logger.log(Level.FINER, "Setting up alarm for the next {0} ms.", delayThresholdMs); |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
|
LGTM, since @lesv thinks |
* chore(main): release 3.21.2-SNAPSHOT * chore: generate libraries at Mon Jan 13 17:03:24 UTC 2025 --------- Co-authored-by: release-please[bot] <55107282+release-please[bot]@users.noreply.github.com> Co-authored-by: cloud-java-bot <[email protected]>
…uth2-http to v1.35.0 (#1749)
* chore(main): release 3.21.2-SNAPSHOT * chore: generate libraries at Mon Jan 13 17:03:24 UTC 2025 --------- Co-authored-by: release-please[bot] <55107282+release-please[bot]@users.noreply.github.com> Co-authored-by: cloud-java-bot <[email protected]>
…uth2-http to v1.35.0 (#1749)
Co-authored-by: release-please[bot] <55107282+release-please[bot]@users.noreply.github.com>
…o v1.125.3 (#1749) * chore(deps): update dependency com.google.cloud:google-cloud-pubsub to v1.125.3 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
…o v1.125.3 (#1749) * chore(deps): update dependency com.google.cloud:google-cloud-pubsub to v1.125.3 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
Fixes #1681.