You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/01/24 07:46:52 UTC
[GitHub] [pulsar] wangshuyu opened a new issue #9294: ReconsumeLaterAsync : Asking for help.
wangshuyu opened a new issue #9294:
URL: https://github.com/apache/pulsar/issues/9294
`c#
var msg = await consumer.ReceiveAsync();
var body = Encoding.UTF8.GetString(msg.Data.ToArray());
if (msg.Properties.Count > 0)//retry
{
//retry is error, What should I do here?
_ = consumer.ReconsumeLaterAsync(msg, DateTimeToTimeStamp(DateTime.Now.AddSeconds(20)));
}
else
{
//success
_ = consumer.ReconsumeLaterAsync(msg, DateTimeToTimeStamp(DateTime.Now.AddSeconds(10)));
}
`
以上代码,执行重试消息后, 会发生错误,这里我该如何处理呢?
想实现一个消息延时递增处理.
类似: 1s 5s 10s 30s .... 2h....10h
In the above code, after executing the retrial message, an error will occur. What should I do here?
Want to achieve a message delay incremental processing.
example: 1s 5s 10s 30s .... 2h....10h
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] codelipenghui commented on issue #9294: ReconsumeLaterAsync : Asking for help.
Posted by GitBox <gi...@apache.org>.
codelipenghui commented on issue #9294:
URL: https://github.com/apache/pulsar/issues/9294#issuecomment-770228617
@wangshuyu Is this the last comment that works for you? I will close this issue first since no update on this issue. Feel free to reopen it if you still have some doubt about this issue.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] codelipenghui commented on issue #9294: ReconsumeLaterAsync : Asking for help.
Posted by GitBox <gi...@apache.org>.
codelipenghui commented on issue #9294:
URL: https://github.com/apache/pulsar/issues/9294#issuecomment-767263383
When the error occurs you should not acknowledge the original message.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] codelipenghui closed issue #9294: ReconsumeLaterAsync : Asking for help.
Posted by GitBox <gi...@apache.org>.
codelipenghui closed issue #9294:
URL: https://github.com/apache/pulsar/issues/9294
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] codelipenghui commented on issue #9294: ReconsumeLaterAsync : Asking for help.
Posted by GitBox <gi...@apache.org>.
codelipenghui commented on issue #9294:
URL: https://github.com/apache/pulsar/issues/9294#issuecomment-767263383
When the error occurs you should not acknowledge the original message.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org