2017-07-03 9 views
0

私はパブとして、サブとしてGoogle pub-sub(java)を使用しています。キューのメカニズムを使用するようにGoogle Pubsubを設定するにはどうすればよいですか?

キューメカニズムを有効にする方法が見つかりませんでした。加入者がアップする前に、パブリッシャがメッセージを送信した場合の意味

は、その後、メッセージは失われ、加入者がフェッチするのを待つされていません。

多分私はチャネルを作成する? Googleクラウドパブ/サブで

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(); 
    } 
} 

答えて

0

メッセージがメッセージを受信するためにそのサブスクリプションに加入者のためのために出版された前に、サブスクリプションが作成されている必要があります。サブスクリプションが作成されると、発行されたすべてのメッセージは、そのサブスクリプションに対応するサブスクライバに配信されます。個々のメッセージは最大7日間配信を試みるために保持されます。通常、Cloud consoleを介してサブスクリプションを作成します。

+0

キューイングメカニズムを設定する方法はありませんか?加入者がダウンした場合に?メッセージを失いたくない –

+0

購読者が購読を作成した後にダウンした場合でも、購読者が戻ってもメッセージは保持され、配信されます。サブスクリプションとサブスクライバの区別は重要です。サブスクリプションは、メッセージが公開される前に作成する必要があります。新しいサブスクリプションを作成して、作成前に公開されたメッセージを受信する方法はありません。購読者は、昇降することができ、加入者が戻ったとき(最大7日間)メッセージが保持され、配信されます。 –

関連する問題