如何解决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 举报,一经查实,本站将立刻删除。