Acerca de que activemq reescriba el método de caducidad del mensaje y no implemente el método messageExpired. ¿Cuál es el motivo para reescribirlo?
1. Persistencia en el archivo
ActiveMQ admite este método de forma predeterminada, siempre que el mensaje esté configurado para persistir como el mensaje que se enviará.
Abra el archivo de configuración en el directorio de instalación:
D:\ActiveMQ\apache-activemq\conf\activemq.xml Encontrará los elementos de configuración predeterminados en más de 80 líneas:
lt;persistenceAdaptergt;
lt;kahaDB directorio="${activemq.data}/kahadb"/gt;
lt;/persistenceAdaptergt;
Tenga en cuenta que kahaDB utilizado aquí es un almacén de mensajes de transacciones basado en archivos, que es un almacén de mensajes confiable, de alto rendimiento y escalable.
kahaDB utiliza un único registro de transacciones para la indexación, usando solo un índice para todos los destinos, y se ha probado para admitir 10,000 conexiones activas (una para cada conexión) si se usa en un entorno de producción separado). Este rendimiento es suficiente para la mayoría de las necesidades.
Luego cambia el segundo parámetro al enviar el mensaje a:
MsgDeliveryMode.Persistent
Hay dos formas de guardar el mensaje
PERSISTENTE: Guardar en el disco, el mensaje se eliminará después de que el consumidor lo use.
NON_PERSISTENT: Se guarda en la memoria, la información se borra después del consumo.
Nota: Acumular demasiada información puede provocar un desbordamiento de la memoria.
Luego abra el lado del productor para enviar el mensaje:
wps30F4.tmp
No inicie el lado del consumidor y visualícelo en la interfaz de administración:
wps3105.tmp
Se descubre que hay un mensaje en espera. Si no hay persistencia en este momento, el mensaje se perderá después de detener y reiniciar ActiveMQ. Ahora lo modificaremos. a la persistencia del archivo. El consumidor aún podrá recibir mensajes después de reiniciar ActiveMQ.
wps3106.tmp.