ActiveMQ délai d'attente à la connexion
J'ai le problème suivant:
J'essaie de me connecter à un courtier ActiveMQ (qui est maintenant à la baisse) en utilisant le morceau de code suivant
connectionFactory = new ActiveMQConnectionFactory(this.url + "?timeout=2000");
connection = connectionFactory.createConnection();
connection.start();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
LOGGER.info("Connected to " + this.url);
Le problème est que le délai d'attente n'a aucun effet
connection.start()
est bloqué pour toujours.
J'ai inspecté ActiveMQ journal et trouvé les informations suivantes:
2013-12-20 01:49:03,149 DEBUG [ActiveMQ Task-1] (FailoverTransport.java:786) - urlList connectionList:[tcp://localhost:61616?timeout=2000], from: [tcp://localhost:61616?timeout=2000]
2013-12-20 01:49:03,149 DEBUG [ActiveMQ Task-1] (FailoverTransport.java:1040) - Connect fail to: tcp://localhost:61616?timeout=2000, reason: java.lang.IllegalArgumentException: Invalid connect parameters: {timeout=2000}
Le paramètre de délai d'expiration est indiquée ici http://activemq.apache.org/cms/configuring.html
Personne n'a une idée de comment passer timeout argument ActiveMQConnectionFactory?
Ou comment définir un délai d'attente de connexion.start() ?
Merci!!!!
Mise à jour: j'ai trouvé ceci sur Stackoverflow: ActiveMQ - CreateSession basculement délai d'attente après une connexion est repris . J'ai essayé, mais l'exception suivante est générée:
javax.jms.JMSException: Could not create Transport. Reason: java.lang.IllegalArgumentException: Invalid connect parameters: {transport.timeout=5000}
at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:35)
- Je utiliser ActiveMQ 5.8.0 de repo maven
OriginalL'auteur nucandrei | 2013-12-20
Vous devez vous connecter pour publier un commentaire.
Il semble que votre url n'est pas valide encore dans les deux cas, lorsque vous tentez de définir la propriété timeout.
Si vous essayez d'avoir un basculement de l'URL, on dirait que vous êtes puisqu'il est dans le Basculement de code, alors vous êtes probablement à la recherche pour initialReconnectDelay (et éventuellement maxReconnectAttempts qui permettrait de lever une exception si le serveur est toujours en baisse après le nombre de tentatives est atteint).
OriginalL'auteur Andrew