Apache ActiveMQ est un courtier de messages open source (sous licence Apache 2.0) qui implémente entièrement Java Message Service 1.1 (JMS). Il fournit des «fonctionnalités d'entreprise» comme le clustering, plusieurs magasins de messages et la possibilité d'utiliser n'importe quelle base de données en tant que fournisseur de persistance JMS en plus de la persistance de la VM, du cache et du journal.

Plus à propos activemq...

Im essayant d'envoyer un message à ActiveMQ en utilisant Apache.NMS.AMQP. mais j'ai une erreur {"The type initializer for 'Apache.NMS.AMQP.Meta.NmsConnectionInfo' threw an exception."} System.Exception {System.TypeInitializationException} En ce qui concerne cette ligne: IConnectionFactory factor....
9 mars 2021 à 16:03
J'ai un problème avec la configuration d'ActiveMQ 5.12.0. J'utilise ceci dans /conf/activemq.xml: <transportConnector name="openwire" uri="tcp://localhost:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/> <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnectio....
4 mars 2021 à 21:04
J'ai une fonction Lambda qui est déclenchée par Amazon MQ exécutant ActiveMQ. Je souhaite que ma fonction Lambda accuse réception du message une fois qu'il a été traité afin qu'ActiveMQ puisse le supprimer .......
Je rencontre un problème lors de l'écriture d'un test de base qui publie un message dans une file d'attente point-point. Lors de l'utilisation d'un bean @JmsListener, le message est consommé. Lorsque vous n'utilisez pas de @JmsListener et que vous utilisez un consommateur obtenu de connectionFactor....
2 mars 2021 à 19:55
Je souhaite développer un petit microservice d'intégration, qui implémente la communication entre deux systèmes existants. Le système A a des sujets Apache Kafka qui produisent et consomment des messages. Le système B a une API REST et est capable d'appeler des rappels d'API REST. La solution que j'....
Existe-t-il un exemple de code source fonctionnel de Spring AMQP + ActiveMQ (expéditeur + récepteur) sans dépendre de l'API JMS? Remarque: la raison de cette question est que Spring est déjà répertorie JMS comme protocole de transport obsolète pour la communication à distance (seuls les appels AMQP ....
25 févr. 2021 à 08:18
Un serveur ActiveMQ fonctionne sur la machine CentOS. Je peux me connecter et consommer des messages avec TCP et HTTP à l'aide du client OpenWire JMS. Cependant, quand j'ai essayé avec le client STOMP de test ActiveMQ, il lève cette exception sur connection.receieve; java.net.SocketTimeoutExceptio....
12 févr. 2021 à 18:42
Je suis tellement coincé à ce sujet. Je souhaite m'abonner à un sujet ActiveMQ. ActiveMQ fonctionne sur la machine Centos, PAS LOCALHOST . Je peux consommer des messages avec les protocoles TCP, http. Code; public static void main(String[] args) throws JMSException { PropertyUtils.loadProper....
12 févr. 2021 à 17:08
ActiveMQ peut-il ajouter une file d'attente en mémoire au lieu d'un disque, et si oui, quelle est la configuration pour le faire. Ceci est le my activemq.xml et la version ActiveMQ est 5.14.3. J'ai besoin de savoir Que dois-je configurer exactement ici ou dans tout autre fichier de configuration pou....
11 févr. 2021 à 14:21
Combien de files d'attente peuvent être créées dans ActiveMQ? Y a-t-il une limitation dans ActiveMQ 5.14? Pour le moment, vous pouvez mettre à jour Ballerina vers la version Swan Lake (qui est de toute façon la dernière); la façon de procéder est indiquée ici. Ensuite, vous pourrez exécuter le co....
10 févr. 2021 à 15:24
J'utilise la file d'attente composite d'ActiveMQ devant les files d'attente physiques en raison de la possibilité de définir les autorisations différemment du côté du producteur et du consommateur. Et cela fonctionne comme prévu. Je souhaite également utiliser une file d'attente composite devant de....
6 févr. 2021 à 14:03
L'attribut dispatchAsync de l'élément networkConnector est true par défaut. Je pense que cela signifie un transfert asynchrone entre les courtiers. Cela signifie-t-il que les messages peuvent être perdus?....
1 févr. 2021 à 09:57
J'ai une question concernant les modèles de conception réalisables pour ActiveMQ. J'ai un client de base de données monothread basé sur ActiveMQ - les appelants créent une file d'attente de réponse temporaire, JMS "envoie" une requête SQL à la file d'attente correcte et attend une réponse sur la fi....
30 janv. 2021 à 00:49
J'ai l'application A qui publie des messages dans les files d'attente ActiveMQ q1 et q2 et j'ai deux consommateurs c1 et c2 connectés q1 et q2 séparément. Le format de message pour c1 et c2 est différent, c'est pourquoi j'utilise deux files d'attente séparées. Est-il possible d'utiliser un seul suj....
27 janv. 2021 à 04:49
J'ai créé une file d'attente. Le producteur publie en continu dans la file d'attente JMS. Cependant, le traitement du message prend un certain temps aux consommateurs et la file d'attente se remplit après un certain temps. Comment cette situation peut-elle être gérée à la fois du côté des producte....
26 janv. 2021 à 04:02
J'écris un script python en utilisant la bibliothèque python stomp pour me connecter et m'abonner à une file d'attente de messages ActiveMQ. Mon code est très similaire aux exemples de la documentation "Traiter avec déconnecte "avec l'ajout de la minuterie placée dans une boucle pour un auditeur de....
22 janv. 2021 à 04:15
Nous avons une application Spring Boot et nous utilisons apache camel comme cadre pour le traitement des messages. Nous essayons d'optimiser au mieux les paramètres de notre application pour faire la mise en file d'attente des messages sur le .......
17 janv. 2021 à 23:18
Je peux voir les messages dans les files d'attente mais pas dans les sujets. Je ne trouve aucun moyen de créer un abonné ad hoc non durable pour essayer de surveiller ces messages non plus. Toute solution?....
12 janv. 2021 à 14:03
J'utilise ActiveMQ 5.16.0 téléchargé depuis Apache. Je vois que quelques-uns des jars sont des versions plus anciennes qui ont des vulnérabilités, par exemple: com.google.guava_guava 19.0 core_jackson-databind 2.9.10.4 shiro-core .......
7 janv. 2021 à 20:52
J'utilise JMS ObjectMessage avec ActiveMQ pour transférer des POJO sérialisables dans leur fonction setObject (). Sur mon client: ObjectMessage omsg = getSession (). CreateObjectMessage (); omsg.setObject (.......
7 janv. 2021 à 17:10
ActiveMQ 5.15 peut-il fonctionner avec JMS 2.0, selon la documentation officielle, il utilise JMS 1.1. Quelles sont les implications de l'utilisation d'ActiveMQ 5.15 avec JMS 2.0. Si ActiveMQ 5.15 + JMS 2.0 n'est pas une solution, alors .......
5 janv. 2021 à 07:40
Est-il possible pour Artemis de pousser des messages vers une API / consommateur REST, plutôt que le consommateur en tirant parti. Je peux implémenter un auditeur côté consommateur, mais j'essaie de voir si Artemis peut pousser .......
23 déc. 2020 à 15:05
J'utilise DefaultMessageListenerContainer pour consommer les messages de la file d'attente ActiveMQ comme ci-dessous. Avec cette implémentation, existe-t-il un mécanisme d'interrogation, l'écouteur interroge-t-il la file d'attente pour voir si .......
Dans ActiveMQ 5.15.6, ils ont activé la vérification du nom d'hôte TLS et je vois mon application échouer après la mise à niveau. Dans leur documentation, ils ont mentionné avoir corrigé la validation TLS côté serveur par .......
20 déc. 2020 à 04:45
Nous migrons de Mule 3 vers Mule 4 et dans l'une de nos fonctionnalités, nous devons publier des messages dans un sujet et en aval un autre composant mule consomme de la file d'attente qui est reliée au sujet. Rien de spécial ici. Pour nous assurer que nous sommes en mesure de suivre le flux via....
20 déc. 2020 à 02:16