Wie kann ich Google Pubsub zur Verwendung von Warteschlangenmechanismus konfigurieren?

Question

Ich benutze Google Pub-Sub (Java) als Pub und als Sub.

Ich konnte keinen Weg finden, Warteschlangen Mechanismus zu aktivieren.

Bedeutung, wenn Verleger-Nachrichten sendet, bevor die Teilnehmer nach oben ist,

dann Nachrichten nicht verloren gehen und warten, bis die Teilnehmer zu holen.

Vielleicht, wenn ich den Kanal erstelle?

public void init(final String projectId, final InputStream inputStream) throws IOException { 
    this.projectId = projectId; 
    if (inputStream != null) { 
     final CredentialsProvider credentialsProvider = 
       FixedCredentialsProvider 
         .create(ServiceAccountCredentials.fromStream(inputStream)); 

     channelProvider = TopicAdminSettings.defaultChannelProviderBuilder() 
       .setCredentialsProvider(credentialsProvider) 
       .build(); 
    } else { 
     channelProvider = TopicAdminSettings.defaultChannelProviderBuilder() 
       .build(); 
    } 
} 

Answer 1

In Google Cloud Pub/Sub, muss das Abonnement erstellt wurde, bevor die Nachricht für einen Teilnehmer an diesem Abonnement, um veröffentlicht wurde, die Nachricht zu empfangen. Nachdem das Abonnement erstellt wurde, werden alle veröffentlichten Nachrichten an einen Abonnenten gesendet, der für dieses Abonnement aufkommt. Einzelne Nachrichten bleiben für eine versuchte Zustellung für bis zu sieben Tage erhalten. Normalerweise würde man das Abonnement über die Cloud console erstellen.