Kann keine ActiveMQ-Warteschlange erstellen oder eine Nachricht mit Java senden

Question

Ich bin neu in ActiveMQ. Ich verwende den ActiveMQ-Server unter Windows mit den Standardeinstellungen auf dem lokalen Computer. Ich habe versucht, eine einfache Warteschlange zu erstellen, um das Senden einer Nachricht zu testen.

public class Foo { 

    public static void main(String[] args) { 
     new Foo().send(); 
    } 

    public void send(){  
     try { 
      ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://localhost:61616"); 
      Connection connection = connectionFactory.createConnection(); 
      connection.start(); 

      Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 
      Destination destination = session.createQueue("TESTQUEUE"); 
      MessageProducer producer = session.createProducer(destination); 
      producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); 

      TextMessage message = session.createTextMessage("MESSAGE123"); 
      producer.send(message); 

      session.close(); 
      connection.close(); 

     } catch (JMSException ex) { 
      Logger.getLogger(Foo.class.getName()).log(Level.SEVERE, null, ex); 
     } 
    }  
} 

Dieser Code scheint nicht, etwas zu tun, wenn ich versuche, es zu überprüfen, indem Sie auf ActiveMQ Admin-Seite anmelden und die Warteschlange überprüfen. (localhost: 8161/admin/queues.jsp) Die Warteschlange wird nicht erstellt. Anschließend wurde versucht, eine Warteschlange manuell über die Verwaltungsseite zu erstellen, und die Nachricht wird nicht an die Warteschlange gesendet, obwohl die Warteschlange erstellt wurde.

Wenn ich den Server mit den Befehlen activemq producer und activemq consumer teste, wird die Warteschlange erstellt und die Nachrichten werden an die Warteschlange übergeben und aus der Warteschlange gelesen. Ich bin mir sicher, dass mit dem Server nichts falsch ist.

Wenn ich den Code ausführen dies ist die Terminal-Ausgabe

WARN | Memory Usage for the Broker (1024mb) is more than the maximum available for the JVM: 887 mb - resetting to 70% of maximum available: 621 mb 
INFO | Using Persistence Adapter: KahaDBPersistenceAdapter[C:\Users\Prashan\Desktop\Test\activemq-data\localhost\KahaDB] 
INFO | JMX consoles can connect to service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi 
INFO | KahaDB is version 6 
INFO | Recovering from the journal @1:3712 
INFO | Recovery replayed 1 operations from the journal in 0.01 seconds. 
INFO | PListStore:[C:\Users\Prashan\Desktop\Test\activemq-data\localhost\tmp_storage] started 
INFO | Apache ActiveMQ 5.13.2 (localhost, ID:CAPSULE-5179-1461559222267-0:1) is starting 
INFO | Apache ActiveMQ 5.13.2 (localhost, ID:CAPSULE-5179-1461559222267-0:1) started 
INFO | For help or more information please see: http://activemq.apache.org 
WARN | Store limit is 102400 mb (current store usage is 0 mb). The data directory: C:\Users\Prashan\Desktop\Test\activemq-data\localhost\KahaDB only has 6947 mb of usable space. - resetting to maximum available disk space: 6947 mb 
WARN | Temporary Store limit is 51200 mb (current store usage is 0 mb). The data directory: C:\Users\Prashan\Desktop\Test\activemq-data\localhost\tmp_storage only has 6947 mb of usable space. - resetting to maximum available disk space: 6947 mb 
INFO | Connector vm://localhost started 
INFO | Connector vm://localhost stopped 
INFO | Apache ActiveMQ 5.13.2 (localhost, ID:CAPSULE-5179-1461559222267-0:1) is shutting down 
INFO | PListStore:[C:\Users\Prashan\Desktop\Test\activemq-data\localhost\tmp_storage] stopped 
INFO | Stopping async queue tasks 
INFO | Stopping async topic tasks 
INFO | Stopped KahaDB 
INFO | Apache ActiveMQ 5.13.2 (localhost, ID:CAPSULE-5179-1461559222267-0:1) uptime 1.918 seconds 
INFO | Apache ActiveMQ 5.13.2 (localhost, ID:CAPSULE-5179-1461559222267-0:1) is shutdown 

Answer 1

Sie sind einen eingebetteten Broker tatsächlich zu schaffen, und die Nachricht wird gesendet. Sie sollten eine Verbindung zu Ihrem lokalen Computer-Broker herstellen: tcp://localhost:61616" anstelle von vm://....