我的activemq中有一个配置,不将消息转发到.DLQ队列。
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry queue=">">
<!--
Tell the dead letter strategy not to process expired messages
我创建了一个程序,根据序列号从死信队列中读取消息,并复制死信消息的内容,并将其作为一个新消息发送到活动队列,其中包含死信消息的内容以及相同的messageId和其他属性。稍后,我还从DLQ中删除了相同的消息。
public static async Task<string> GetDeadLetterMessagesAsync(string connectionString,
string queueName, long seqNum, int countDLQMessages)
{
//creating a service bus client