2017-07-03 168 views
0

我使用Google pub-sub(java)作为pub和sub。如何配置谷歌pubsub使用队列机制?

我找不到启用队列机制的方法。

如果出版商发送消息之前,用户达含义,

则消息不会丢失,并等待用户来获取。

也许当我创建频道?

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

在谷歌Cloud发布/订阅,订阅必须已出版前的消息,以便对订阅用户接收消息创建。在创建订阅之后,发布的任何消息都将传递给为该订阅提供的订阅者。个人消息保留七天以内的试图交付。通常,您可以通过Cloud console创建订阅。

+0

有没有办法配置排队机制?如果用户下降?我不想丢失消息 –

+0

如果订阅者在订阅创建后关闭,则当订阅者返回时,邮件仍将保留并发送。订阅和订阅者之间的区别在这里很重要。订阅是在发布消息之前创建的。无法创建新的订阅并接收其创建之前发布的消息。当用户回来时(最多7天),用户可以上下移动并留言和留言。 –