File tree Expand file tree Collapse file tree 1 file changed +9
-2
lines changed
src/Insurello.RabbitMqClient Expand file tree Collapse file tree 1 file changed +9
-2
lines changed Original file line number Diff line number Diff line change @@ -52,8 +52,12 @@ module MqClient =
5252 | Json of string
5353 | Binary of byte array
5454
55+ type CorrelationId =
56+ | Generate
57+ | Id of string
58+
5559 type PublishMessage =
56- { CorrelationId: string
60+ { CorrelationId: CorrelationId
5761 Headers: Map < string , string >
5862 Content: Content }
5963
@@ -431,7 +435,10 @@ module MqClient =
431435 ( ContentType = contentTypeStringFromContent message.Content,
432436 Persistent = true ,
433437 MessageId = messageId,
434- CorrelationId = message.CorrelationId,
438+ CorrelationId =
439+ ( match message.CorrelationId with
440+ | Generate -> " "
441+ | Id correlationId -> correlationId),
435442 Headers =
436443 ( message.Headers
437444 |> Map.map ( fun _ v -> v :> obj )
You can’t perform that action at this time.
0 commit comments