Skip to content

Commit 791636c

Browse files
TCBroadbarclayadam
authored andcommitted
Added duplicate message detection options
1 parent b5b2a36 commit 791636c

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

src/HangFire.Azure.ServiceBusQueue/ServiceBusManager.cs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,10 @@ private static void CreateQueueIfNotExists(string prefixedQueue, NamespaceManage
8787

8888
Logger.InfoFormat("Creating new queue {0}", prefixedQueue);
8989

90-
var description = new QueueDescription(prefixedQueue);
90+
var description = new QueueDescription(prefixedQueue)
91+
{
92+
RequiresDuplicateDetection = true
93+
};
9194

9295
if (options.Configure != null)
9396
{

src/HangFire.Azure.ServiceBusQueue/ServiceBusQueueJobQueue.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ public void Enqueue(IDbConnection connection, string queue, string jobId)
7272
{
7373
var client = _manager.GetClient(queue);
7474

75-
using (var message = new BrokeredMessage(jobId))
75+
using (var message = new BrokeredMessage(jobId) { MessageId = jobId })
7676
{
7777
_manager.Options.RetryPolicy.Execute(() => client.Send(message));
7878
}

0 commit comments

Comments
 (0)