![]() With a 1 MiB TCP send buffer that's more than "one or two messages", unless of course your messages are very large. If you really understand TCP as well as you say you do, you will understand that, in the absence of consumer flow control, it's TCP flow control that determines how many messages are "lost in the ether". Not all messaging use-cases are concerned with high performance so the default buffer may well be appropriate. On faster networks it is recommended to set this to a higher figure e.g. The question is how does flow control work when using a STOMP protocol client? I have read everything I could find regarding the HornetQ STOMP implementation in the docs and on Google. This determines how many messages can be queued to be sent to a consumer.įair enough, I had not read that part of the documentation in detail. It's completely configurable and it's default value is 1 MiB. ![]() ![]() This is the total size of messages that can be sent to the consumer without the consumer requesting more credits. If you read the chapter on flow control, you will see that each consumer maintains a window. The missing messages are never received by the active consumer no matter how long it is left running Approximately every other message is received by the consumer started in step 4) unclean shutdown)ĥ) Start a producer application that submits several thounsand messages to the queue Of course, the reason for starting this thread in the first place was to seek advice on configuration and problem solving.ġ) Delete HQ journal and binding files from diskģ) Start a STOMP consumer and then terminate the process (i.e. Perhaps there is something wrong with our HQ or Stomp client configuration, but that is not at all obvious at this point. Specifically, the following sequence of events results in lost messages that are not requeued even after expiration of the TTL. We are seeing message loss with the configuration I have described. They are in the process of delivery, and will happily get requeued if they are not acked and the session closes.
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |