Home > Enterprise >  The accumulation of activemq message, ask why
The accumulation of activemq message, ask why

Time:09-19

Our system use ActiveMQ interaction effect between the two systems,

The question now is, each send a few messages (number), there is a message is mq on the pending,

Queue consumers don't always read the news,

After a long time, the amount of the pending slow growth,



What message will be MQ to stay, can't take?

CodePudding user response:

Is the latest version? Is it possible to is its own a bug
This look at

CodePudding user response:

Could you tell me the original poster is which model? Point-to-point or publish/subscribe pattern
Point-to-point: message data is persisted, each message can be consumed, not listening to the QUEUE address can also be consumption, data is not lost, one-on-one accepting strategy, to ensure data integrity, a message by only one consumer spending; Message consumer spending time queue is not locked by news provider, that is to say, only news provider to perform the session. The close () after the consumer will perform the onMessage () method,
The publish/subscribe pattern: subscribe to a topic of consumers can only consume news released since its subscription; A message can be multiple consumer spending,

CodePudding user response:

Is point to point mode,

CodePudding user response:

The
reference 3 floor paragenius response:
is point to point mode,

You this problem is the problem of the code, must be the Receiver part deal with the problem,
Queue name

Number Of Pending Messages is how many Messages in the queue waiting for the queue

How many Number Of Consumers is the queue consumer

Messages are Enqueued queue consists of many information

Messages Dequeued stand out is the queue has how many message
Combining the ActiveMQ's official website and is advised to refer to the realization of the online code, screening test,

CodePudding user response:

Reference: http://blog.163.com/chengwei_1104/blog/static/53645274201382315625329/

CodePudding user response:

If the queue, go looking for consumption of the problem, the normal queue unless blocked, there will be no part consumed part retained, unless the consumer short has a problem, declined;
If the topic, see if you distribute to determine distribution of consumers;

CodePudding user response:

Problem solved, please? I also have four message card in pending,

CodePudding user response:

reference 5 floor FENGQIYUNRAN reply:
reference: http://blog.163.com/chengwei_1104/blog/static/53645274201382315625329/

Can't see
  • Related