Když jsem dostal zprávu z fronty a pokud výjimka byla vyvolána, chci, aby si zprávu znovu. Tak jsem se vytvořit můj spotřebitelů s dql fronty:
spring:
cloud:
stream:
bindings:
to-send-output:
destination: to-send-event
producer:
required-groups:
- to-send-event-group
to-send-input:
destination: to-send-event
group: to-send-event-group
consumer:
max-attempts: 1
requeueRejected: true
rabbit:
bindings:
#forever retry
to-send-input:
consumer:
autoBindDlq: true
dlqTtl: 5000
dlqDeadLetterExchange:
maxConcurrency: 300
frameMaxHeadroom: 25000 #added this as in documentation
Dodal jsem, majetek frameMaxHeadroom: 25000
jak se píše v dokumentaci, ale to stále nefunguje.
Můj springCloudVersion="Hoxton.RELEASE"
.
Moje závislost:
dependencies {
...
implementation "org.springframework.cloud:spring-cloud-starter-stream-rabbit"
...
}
V repozitáři na githubu vidím frameMaxHeadroom
majetek ve vlastnictví souboru.
UPD: vidím, že kód snižuje trasování zásobníku o hodnotu jsem nastavil (z proměnné frameMaxHeadroom
). Očekával jsem, že jsem nebyl klesá trasování zásobníku, ale zvyšuje hodnotu pro záhlaví pro spotřebitele, jak je napsáno v dokumentaci. Proč to není práce, jak jsem čekat?
x-exception-stacktrace
. A nemůžu zvětšit prostor pro všechny ostatní hlavičky. Je to pravda?