I am designing a queue based system for decoupling publisher of certain messages from their consumers. I have an additional requirement - when a publisher pushes a new message and if an earlier message of similar kind is already in queue and is yet to be processed(ie picked by consumer) , then the older message has to be deduped off before the new message is pushed into the queue; this is to save on cost of processing a message which we know is getting obsolete. I am exploring on the technology to be used to implement such a queue. Is Azure Service bus an option? Does it allow modifying attributes of specific messages in the queue? Also, any suggestion on what would be the best technology to implement such a queue?
azure service bus - does it allow modifying attributes of messages in queue
192 views Asked by Aadith Ramia At
1
There are 1 answers
Related Questions in AZURE
- How to update to the latest external Git in Azure Web App?
- I need an azure product that executes my intensive ffmpeg command then dies, and i only get charged for the delta. Any Tips?
- Inject AsyncCollector into a service
- mutual tls authentication between app service and function app
- Azure Application Insights Not Displaying Custom Logs for Azure Functions with .NET 8
- Application settings for production deployment slot in Azure App Services
- Encountered an error (ServiceUnavailable) from host runtime on Azure Function App
- Implementing Incremental consent when using both application and delegated permissions
- Invalid format for email address in WordPress on Azure app service
- Producer Batching Service Bus Vs Kafka
- Integrating Angular External IP with ClusterIP of .NET microservices on AKS
- Difficulty creating a data pipeline with Fabric Datafactory using REST
- Azure Batch for Excel VBA
- How to authenticate only Local and Guest users in Azure AD B2C and add custom claims in token?
- Azure Scale Sets and Parallel Jobs
Related Questions in AZURESERVICEBUS
- Inject AsyncCollector into a service
- Producer Batching Service Bus Vs Kafka
- Azure Queue Functions | Trigger when multiple queue functions executions with a specific message property ends
- Azure service bus - processing multiple messages in parallel (MaxConcurrentCallsPerSession)
- Value cannot be null ( parameter envolope)
- Error indexing method 'IntegrationFunction' Can't convert from type 'Microsoft.Azure.EventHubs.EventData
- Handling multiple return values in an Azure function
- Adding custom message properties when creating Service Bus Topic messages with Node.js
- Throttling consumption of Servicebus messages with azure functions
- Azure Service Bus With Spring Integration Executor Channel Error Handling
- Resubmitting messages from deadletter on Azure service bus on Topic queue with partitioning and duplicate detection enabled
- How to maintain control of numerous event racing scenarios in a platform of growing complexity?
- Exception is ocurring while Implementing Azure Service bus at Receiver End
- Azure - What causes a ServiceBus Topic to be "partitioned"
- Recommended way to Limit Azure Function Service bus Trigger Concurrent message processing when using App Service Plan
Related Questions in AZURE-SERVICEBUS-QUEUES
- Azure service bus - processing multiple messages in parallel (MaxConcurrentCallsPerSession)
- Recommended way to Limit Azure Function Service bus Trigger Concurrent message processing when using App Service Plan
- Add Retry Policy V2 Model Python Service Bus Queue Trigger
- duplicate runs with built in service bus trigger in logic apps standard workflows
- Why to use await keyword on Azure service bus processor class StartProcessingAsync method?
- Azure service Bus geo-recovery automation using az bash commands
- What's the isolated-process equivalent to in-process ServiceBusSender bindings in Azure functions?
- C# - Azure Service Bus deployed in VM suddenly hangs and stops processing messages
- How do I add a message back onto the queue from a Service Bus triggered Python Azure Function without raising an exception?
- How does the maxMessageCount work in service bus trigger?
- Messages to Azure Service Bus produce successful requests, but no messages in the queue
- Design architecture for integrating with a 3rd party payment provider
- Sequential Number Generation Issue in Loop Using Queues
- Logic app workflow failing with error "VNetPrivatePortNotConfigured"
- How to create 1 instance of Azure Function per Azure Service Queue message
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
Try using sessions: https://code.msdn.microsoft.com/windowsazure/Brokered-Messaging-Session-41c43fb4
This way the second message has the same session ID, and the client will fetch all messages with the same session ID. The client must have some logic to discard the oldest one.