Azure ServiceBus Scheduled message

stefandv · May 20, 2019, 5:20pm

I would need to use the ScheduledEnqueueTimeUtc property on the Microsoft.Azure.ServiceBus.Message. Are there any possibilities available in the current code to set this property?
I would think that current code:

github.com

ServiceStack/ServiceStack.Azure/blob/69e907a15fad7a057205a8351341c1155a5a84f9/src/ServiceStack.Azure/Messaging/ServiceBusMqMessageProducer.cs#L63


        public virtual void Publish(string queueName, IMessage message)
        {
            queueName = queueName.SafeQueueName();
            message.ReplyTo = message.ReplyTo.SafeQueueName();


            var sbClient = parentFactory.GetOrCreateClient(queueName);
            using (JsConfig.With(new Text.Config { IncludeTypeInfo = true }))
            {
                var msgBody = JsonSerializer.SerializeToString(message, typeof(IMessage));
#if NETSTANDARD2_0
                var msg = new Microsoft.Azure.ServiceBus.Message()
                {
                    Body = msgBody.ToUtf8Bytes(),
                    MessageId = message.Id.ToString()
                };
                sbClient.SendAsync(msg).Wait();
#else
                var msg = new BrokeredMessage(msgBody) { MessageId = message.Id.ToString() };


                sbClient.Send(msg);
#endif

need to be extended with a possible hook that gives the Microsoft.Azure.ServiceBus.Message with some context in order to alter some properties.
Or would it be possible to replace the ServiceBusMqMessageProducer class with my own implementation?

mythz · May 20, 2019, 6:59pm

I’ve added a new PublishMessageFilter you can use this commit.

This change is available from v5.5.1 that’s now available on MyGet.

stefandv · May 21, 2019, 5:41am

Okay thanks!
Then I can make a new object inheriting from IMessage where these properties are set, and then in the PublishMessageFilter I can map these upon the correct object.