微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Google Pub Sub 未确认消息需要超过一分钟才能再次使用

如何解决Google Pub Sub 未确认消息需要超过一分钟才能再次使用

在 Google pub sub 中,未确认的消息需要超过一分钟的时间才能使用。在控制台中,我将 ackDeadline 配置为 10 秒。所以它假设在 10 秒后重新使用,但大约需要 1 分 3 秒。

公共类 StudentUpdateEventConsumer1 {

@Autowired
private PubSubTemplate pubSubTemplate;

@Autowired
private ApplicationConfig applicationConfig;

@Bean
public MessageChannel studentUpdateEventInputChannel() {
    return new PublishSubscribeChannel();
}

@Bean
public PubSubInboundChannelAdapter studentUpdateEventMessageChannelAdapter(
        @Qualifier("studentUpdateEventInputChannel") MessageChannel inputChannel,PubSubTemplate pubSubTemplate) {
    PubSubInboundChannelAdapter adapter =
            new PubSubInboundChannelAdapter(pubSubTemplate,"pub-sub-test-topic-sub-1");
    adapter.setoutputChannel(inputChannel);
    adapter.setAckMode(AckMode.MANUAL);
    adapter.setPayloadType(Student.class);
    return adapter;
}

@ServiceActivator(inputChannel = "studentUpdateEventInputChannel")
public void messageReceiver(
        Student payload,@Header(GcpPubSubHeaders.ORIGINAL_MESSAGE) BasicAckNowledgeablePubsubMessage message) throws InterruptedException {
    log.info("Message arrived via an inbound channel adapter from pub-sub-test-topic-sub-1! Payload: {}",payload);
    // message.ack();
}

}

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。