Блог

Где вы инициализируете переменную d, потому что кажется, что d находится не в той же области. Где вы инициализируете переменную d, потому что кажется, что d находится не в той же области. Где вы инициализируете переменную d, потому что кажется, что d находится не в той же области.

=============================================================

 package com.pubsubpract;  import com.google.api.core.ApiFuture; import com.google.api.core.ApiFutures; import com.google.api.gax.batching.BatchingSettings; import com.google.cloud.pubsub.v1.Publisher; import com.google.protobuf.ByteString; import com.google.pubsub.v1.PubsubMessage; import com.google.pubsub.v1.TopicName; import java.io.IOException; import java.util.ArrayList; import java.util.List; import java.util.concurrent.ExecutionException; import java.util.concurrent.TimeUnit; import org.threeten.bp.Duration;  public class BatchPublish {  public static void main(String... args) throws Exception {  // TODO(developer): Replace these variables before running the sample.  String projectId = "lively-cumulus-328013";  String topicId = "test";   publishWithBatchSettingsExample(projectId, topicId);  }   public static void publishWithBatchSettingsExample(String projectId, String topicId)  throws IOException, ExecutionException, InterruptedException {  TopicName topicName = TopicName.of(projectId, topicId);  Publisher publisher = null;  Listlt;ApiFuturelt;Stringgt;gt; messageIdFutures = new ArrayListlt;gt;();   try {  // Batch settings control how the publisher batches messages  long requestBytesThreshold = 5000L; // default : 1 byte  long messageCountBatchSize = 100L; // default : 1 message   Duration publishDelayThreshold = Duration.ofMillis(200000); // default : 1 ms   // Publish request get triggered based on request size, messages count amp; time since last  // publish, whichever condition is met first.  BatchingSettings batchingSettings =  BatchingSettings.newBuilder()  .setElementCountThreshold(messageCountBatchSize)  .setRequestByteThreshold(requestBytesThreshold)  .setDelayThreshold(publishDelayThreshold)  .build();   // Create a publisher instance with default settings bound to the topic  publisher = Publisher.newBuilder(topicName).setBatchingSettings(batchingSettings).build();   // schedule publishing one message at a time : messages get automatically batche  String message = "message " ;  ByteString data = ByteString.copyFromUtf8(message);  PubsubMessage pubsubMessage = PubsubMessage.newBuilder().setData(data).build();   // Once published, returns a server-assigned message id (unique within the topic)  // Thread.sleep(200000);  ApiFuturelt;Stringgt; messageIdFuture = publisher.publish(pubsubMessage);  messageIdFutures.add(messageIdFuture);  } finally {  // Wait on any pending publish requests.  Listlt;Stringgt; messageIds = ApiFutures.allAsList(messageIdFutures).get();   System.out.println("Published "   messageIds.size()   " messages with batch settings.");   if (publisher != null) {  // When finished with the publisher, shutdown to free up resources.  publisher.shutdown();  publisher.awaitTermination(1, TimeUnit.MINUTES);  }  }  } }  

====================================================