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();
}
}
キューイングメカニズムを設定する方法はありませんか?加入者がダウンした場合に?メッセージを失いたくない –
購読者が購読を作成した後にダウンした場合でも、購読者が戻ってもメッセージは保持され、配信されます。サブスクリプションとサブスクライバの区別は重要です。サブスクリプションは、メッセージが公開される前に作成する必要があります。新しいサブスクリプションを作成して、作成前に公開されたメッセージを受信する方法はありません。購読者は、昇降することができ、加入者が戻ったとき(最大7日間)メッセージが保持され、配信されます。 –