Quando un consumer smaltisce una Queue o una Subscription fornita da un namespace Service Bus, può ricevere messaggi che in alcune circostanze non vuole processare immediatamente (quindi rimuovere).
I motivi per cui il motore voglia aspettare il processamento possono essere molteplici: si aspetta messaggi in un certo ordine, ma non essendo garantito dalla coda questo non è successo, oppure vuole accumulare una serie di messaggi per poi combinare le informazioni tra di loro ed eseguire operazioni.
In questi casi viene in aiuto il metodo Defer della classe BrokeredMessage, il quale permette, se il lock sul messaggio è ancora valido, di tenere da parte il messaggio e di non renderlo più visibile, nonostante risieda sulla coda. E' compito poi del consumer tenere da parte il SequenceNumber, sempre diponsibile sul messaggio, per poterne poi farne richiesta con il metodo Receive.
Di seguito quindi un esempio che accumula tre messaggi, facendone il Defer, per poi andare a recuperarli.
// Creo il client della coda var client = messagingFactory.CreateQueueClient("myQueue"); List<long> numbers = new List<long>(); // Accumulo tre sequence number dei messaggi while (numbers.Count < 3) { // Ricevo il messaggio disponibile BrokeredMessage bm = client.Receive(); // Applico una condizione per decidere se farne il Defer o meno if (true) { numbers.Add(bm.SequenceNumber); bm.Defer(); } else { bm.Delete(); } } // Sfoglio tutti i sequence number messi da parte foreach (long n in numbers) { // Chiedo esplicitamente un messaggio BrokeredMessage bm = client.Receive(n); // Cancello il messaggio bm.Delete(); // Faccio qualcosa con il messaggio // ... }
Da notare come nella seconda parte del motore, al metodo Receive venga passato esplicitamente il sequence number dei messaggi di cui si è fatto il Defer.
Per ulteriori informazioni su Queue, i Topic e le Subscription si veda l'articolo
https://www.winfxitalia.com/articoli/windows-azure/sms-windows-phone-azure-queue.aspx
Commenti
Per inserire un commento, devi avere un account.
Fai il login e torna a questa pagina, oppure registrati alla nostra community.
Approfondimenti
Evitare la script injection nelle GitHub Actions
Ottimizzare la latenza in Blazor 8 tramite InteractiveAuto render mode
Configurare policy CORS in Azure Container Apps
Utilizzare Tailwind CSS all'interno di React: primi componenti
Migliora la resilienza delle applicazioni con .NET e Azure Container Apps
Utilizzare l'operatore GroupBy come ultima istruzione di una query LINQ in Entity Framework
Implementare il throttling in ASP.NET Core
Eseguire le GitHub Actions offline
Migrare una service connection a workload identity federation in Azure DevOps
Gestire undefined e partial nelle reactive forms di Angular
Determinare lo stato di un pod in Kubernetes
Cambiare la chiave di partizionamento di Azure Cosmos DB
I più letti di oggi
- Impostare un elemento come ridimensionabile tramite CSS
- Proteggersi dagli attacchi di Open Redirect in ASP.NET Core MVC
- Personalizzare l'errore del rate limiting middleware in ASP.NET Core
- Accedere alla console di una Azure Container App
- Modificare i metadati nell'head dell'HTML di una Blazor Web App
- Gli oggetti CallOut di Expression Blend 4.0
- SQL Server 2005 December CTP
- Sfruttare le nuove tipologie di input di HTML5 con ASP.NET 4.0
- Upload da una pagina web con Dundas Upload