Description
retryTopic := topicName + "-" + options .SubscriptionName + RetryTopicSuffix
dlqTopic := topicName + "-" + options .SubscriptionName + DlqTopicSuffix
oldRetryTopic := tn .Domain + "://" + tn .Namespace + "/" + options .SubscriptionName + RetryTopicSuffix
oldDlqTopic := tn .Domain + "://" + tn .Namespace + "/" + options .SubscriptionName + DlqTopicSuffix
if r , err := client .lookupService .GetPartitionedTopicMetadata (oldRetryTopic ); err == nil &&
r != nil &&
r .Partitions > 0 {
retryTopic = oldRetryTopic
}
if r , err := client .lookupService .GetPartitionedTopicMetadata (oldDlqTopic ); err == nil &&
r != nil &&
r .Partitions > 0 {
dlqTopic = oldDlqTopic
}
if options .DLQ == nil {
options .DLQ = & DLQPolicy {
MaxDeliveries : MaxReconsumeTimes ,
DeadLetterTopic : dlqTopic ,
RetryLetterTopic : retryTopic ,
}
} else {
if options .DLQ .DeadLetterTopic == "" {
options .DLQ .DeadLetterTopic = dlqTopic
}
if options .DLQ .RetryLetterTopic == "" {
options .DLQ .RetryLetterTopic = retryTopic
}
}
Reactions are currently unavailable
You can’t perform that action at this time.
pulsar-client-go/pulsar/consumer_impl.go
Lines 147 to 178 in cc18590