ActiveMQ rifiutato

Question

Sto cercando di utilizzare activemq nella mia richiesta, ma continuo a ricevere un errore quando provo e collego al localhost:

log4j:WARN No appenders could be found for logger (org.springframework.core.env.StandardEnvironment). 
log4j:WARN Please initialize the log4j system properly. 
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info. 
Exception in thread "main" org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during JMS processing; nested exception is javax.jms.JMSException: Could not connect to broker URL: tcp://localhost:61616. Reason: java.net.ConnectException: Connection refused 
    at org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:316) 
    at org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:168) 
    at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:469) 
    at org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:534) 
    at org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:526) 
    at sender.MessageSender.sendMessage(MessageSender.java:16) 
    at sender.SenderMain.main(SenderMain.java:13) 
Caused by: javax.jms.JMSException: Could not connect to broker URL: tcp://localhost:61616. Reason: java.net.ConnectException: Connection refused 
    at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:35) 
    at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:293) 
    at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:238) 
    at org.apache.activemq.ActiveMQConnectionFactory.createConnection(ActiveMQConnectionFactory.java:184) 
    at org.springframework.jms.support.JmsAccessor.createConnection(JmsAccessor.java:184) 
    at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:456) 
    ... 4 more 
Caused by: java.net.ConnectException: Connection refused 
    at java.net.PlainSocketImpl.socketConnect(Native Method) 
    at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:351) 
    at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:213) 
    at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:200) 
    at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:432) 
    at java.net.Socket.connect(Socket.java:529) 
    at org.apache.activemq.transport.tcp.TcpTransport.connect(TcpTransport.java:504) 
    at org.apache.activemq.transport.tcp.TcpTransport.doStart(TcpTransport.java:467) 
    at org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:55) 
    at org.apache.activemq.transport.AbstractInactivityMonitor.start(AbstractInactivityMonitor.java:132) 
    at org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58) 
    at org.apache.activemq.transport.WireFormatNegotiator.start(WireFormatNegotiator.java:72) 
    at org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58) 
    at org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58) 
    at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:273) 
    ... 8 more 

C'è un file che deve essere eseguito per avviarlo (mq attivo) e questo è un file .bat su macchine Windows. Quando lo esegui, si avvia e lo lascia in esecuzione nel prompt dei comandi.

A casa ho un mac e utilizzando il mac equivalente il terminale si limita a stampare:

Last login: Mon Oct 29 19:57:15 on ttys000 
(null):~ rickilambert$ /Users/rickilambert/Downloads/apache-activemq-5.7.0/bin/macosx/activemq ; exit; 
Usage: /Users/rickilambert/Downloads/apache-activemq-5.7.0/bin/macosx/activemq { console | start | stop | restart | status | dump } 
logout 

[Process completed] 

Qualcuno può per favore mi aiuti a ottenere questa cosa installato e funzionante?

Answer 1

L'applicazione non è in grado di connettersi a activemq. Verifica che il tuo activemq sia in esecuzione e in ascolto su localhost 61616.

Puoi provare a utilizzare: netstat -a per verificare se il processo activemq è stato avviato. Oppure provate verificare se è possibile accedere alla pagina di amministrazione utilizzando actvemq: localhost: 8161/admin/queues.jsp

su Mac avrà inizio la sua activemq utilizzando:

$ACTMQ_HOME/bin/activemq start 

Oppure, se il file di configurazione (ActiveMQ. xml) se si trova in un altro luogo è possibile utilizzare:

$ACTMQ_HOME/bin/activemq start xbean:file:${location_of_your_config_file} 

nel tuo caso l'eseguibile è sotto: bin/macosx/activemq quindi è necessario utilizzare: $ACTMQ_HOME/bin/macosx/activemq start

Answer 2

ho incontrato un problema simile quando stavo usando il sotto per ottenere il collegamento fabbrica fabbrica ConnectionFactory = new
ActiveMQConnectionFactory("admin","admin","tcp://:61616");

sua risolti quando ho cambiato al di sotto

ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://:61616");

Il sotto poi ha mostrato che la mia dimensione D è in aumento .. http://:8161/admin/queues.jsp

Answer 3

Avevo anche problemi simili. Nel mio caso brokerUrl non è stato configurato correttamente. Ecco, questo è così che ho ricevuto seguente errore:

Cause: Error While attempting to add new Connection to the pool: nested exception is javax.jms.JMSException: Could not connect to broker URL : tcp://localhost:61616. Reason: java.net.ConnectException: Connection refused 

& ho risolto che segue.

ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(); 

    connectionFactory.setBrokerURL("tcp://hostname:61616"); 
    connectionFactory.setUserName("admin"); 
    connectionFactory.setPassword("admin");