---

pongad · web-flow · commit 30e4766beb22 · 2017-03-15T11:08:56.000+11:00
yaml --- r: 5471 b: refs/heads/master c: ca51fe9 h: refs/heads/master i: 5469: 8b60006 5467: 880abda 5463: c16080d 5455: 414cb8e 5439: 06edfa0
diff --git a/[refs] b/[refs]
@@ -1,5 +1,5 @@
 ---
-refs/heads/master: 48b324e5b9f8127fde8811b15104a42581c05df0
+refs/heads/master: ca51fe908b837b8b7fcc8dad171a96070a6e15b1
 refs/heads/travis: dae77e558b884bc1b165155482d76c8e40b0fca4
 refs/heads/gh-pages: 4936f6d1c43be1ab76229d2743bae07f4b4124b3
 refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444
diff --git a/trunk/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Publisher.java b/trunk/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Publisher.java
@@ -236,7 +236,7 @@ && hasBundlingBytes()
       if (!messagesBundle.isEmpty()) {
         setupDurationBasedPublishAlarm();
       } else if (currentAlarmFuture != null) {
-        logger.log(Level.INFO, "Cancelling alarm");
+        logger.log(Level.FINER, "Cancelling alarm, no more messages");
         if (activeAlarm.getAndSet(false)) {
           currentAlarmFuture.cancel(false);
         }
@@ -248,7 +248,7 @@ && hasBundlingBytes()
     messagesWaiter.incrementPendingMessages(1);
 
     if (bundleToSend != null) {
-      logger.log(Level.INFO, "Scheduling a bundle for immediate sending.");
+      logger.log(Level.FINER, "Scheduling a bundle for immediate sending.");
       final OutstandingBundle finalBundleToSend = bundleToSend;
       executor.execute(
           new Runnable() {
@@ -263,7 +263,7 @@ public void run() {
     // be sent in its own bundle immediately.
     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.");
       executor.execute(
           new Runnable() {
             @Override
@@ -280,13 +280,13 @@ public void run() {
   private void setupDurationBasedPublishAlarm() {
     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);
       currentAlarmFuture =
           executor.schedule(
               new Runnable() {
                 @Override
                 public void run() {
-                  logger.log(Level.INFO, "Sending messages based on schedule.");
+                  logger.log(Level.FINER, "Sending messages based on schedule.");
                   activeAlarm.getAndSet(false);
                   publishAllOutstanding();
                 }
