5
votes

If there is an out of the box way to put a message into msmq with a defined expiration time out. under expiration I mean the following scenario:

  • a message sender sends messages into a queue quite frequently
message 1 published at 1:00
message 2 published at 1:02
message 3 published at 1:04
  • a message reciever takes a message from the queue and runs a time expencive procedure

message 1 recieved at 1:00 and processed at 1:05

  • by the application logic it make sence to process messages which are not older a particular time frame

we shold process messages that are not older than 1 min so uder this requirement I wish that message 2 would disappeared from the queue

Questions:

  • can I archive that by an out of the box functionality?
  • if not? what would is the best practice to do this?
  • is msmq is correct technology for this use case in principle? Which one would suit the requrement better?
3
you are using queues for some particular reason/restriction ? what other means of sharing data do you have ? - Mauricio Gracia Gutierrez
The idea of using queue come from the point that there are several senders that send messages in parallel, but a message processing is rather sequential - Yaugen Vlasau

3 Answers

6
votes

The Message class has a TimeToBeReceived property (see MSDN). I think it should meet your requirement.

Also, it seems to me that your system cannot consume messages at the same pace as it produces them. It's difficult to tell without knowing further details about the system, but it may be worth exploring the possibility of consuming the messages in parallel (if you are not already doing that).

0
votes

If you have access to the source code of both Producer/Consumer you could share a Queue but in memory and use LINQ to filter the message that are in the expected time frame and process them

0
votes

The System.Messaging.Message class has a property for TimeToBeReceived which will cause the message to be ignores (or posted to the bad letter queue) if it times out.

The only issue is that you have to be sure that the time on the client-side is synchronised with the time on the server side.