Verbindung fehlgeschlagen zu einem HornetQ-Thema eingebettet in einem JBOSS EAP 6.2

Question

Ich versuche, eine Remoteverbindung zu einem Thema herzustellen, das auf einem in einem JBOSS EAP 6.2 eingebetteten HornetQ konfiguriert ist. Ich habe verschiedene Ansätze tryied so zu tun, aber alle gaben mir den gleichen Fehler:

javax.jms.JMSException: Failed to create session factory 
at org.hornetq.jms.client.HornetQConnectionFactory.createConnectionInternal(HornetQConnectionFactory.java:676) 
at org.hornetq.jms.client.HornetQConnectionFactory.createTopicConnection(HornetQConnectionFactory.java:196) 
at TesteTags.main(TesteTags.java:82) 
Caused by: HornetQConnectionTimedOutException[errorType=CONNECTION_TIMEDOUT message=HQ119013: Timed out waiting to receive cluster topology. Group:null] 
at org.hornetq.core.client.impl.ServerLocatorImpl.createSessionFactory(ServerLocatorImpl.java:950) 
at org.hornetq.jms.client.HornetQConnectionFactory.createConnectionInternal(HornetQConnectionFactory.java:672) 
... 2 more 

Ich folgte die Informationen auf diesem Schnellstart: Jboss Eap Quickstart: helloworld-jms

meinen Code folgen:

try { 
    final Properties env = new Properties(); 
    env.put(Context.INITIAL_CONTEXT_FACTORY,"org.jboss.naming.remote.client.InitialContextFactory"); 
    env.put(Context.URL_PKG_PREFIXES, "org.jboss.ejb.client.naming"); 
    env.put(Context.PROVIDER_URL, "remote://localhost:4447"); 
    env.put(Context.SECURITY_PRINCIPAL, "testuser"); 
    env.put(Context.SECURITY_CREDENTIALS, "testpassword"); 

    Context context = new InitialContext(env); 
    TopicConnectionFactory factory = (TopicConnectionFactory) context.lookup("jms/RemoteConnectionFactory"); 
    Topic topic = (Topic) context.lookup("jms/topic/myTopic"); 


    Connection connection = factory.createTopicConnection("testuser", "testpassword"); // The Error occurred here 
    connection.start(); 
    Session session = connection.createSession(false, TopicSession.AUTO_ACKNOWLEDGE); 
    MessageProducer producer = session.createProducer(topic); 

    Message message = session.createTextMessage("My Test Message"); 

    producer.send(message); 

    System.out.println("It Worked!"); 
} catch (Exception e) { 
    System.out.println("It Failed!"); 
    e.printStackTrace(); 
} 

I verwende ein Standalone-Full-Ha-Profil mit den Standardkonfigurationen.

Mache ich etwas falsch an meinem Code? Oder gibt es eine andere Konfiguration als die Standardeinstellungen, die ich tun muss?

Answer 1

Nach vielen Recherchen und Tests, löste ich das Problem. Zuerst änderte ich die Abhängigkeit der Jboss-as-jms-client-bom-7.2.0 dazu:

<dependency> 
    <groupId>org.jboss.as</groupId> 
    <artifactId>jboss-as-jms-client-bom</artifactId> 
    <version>7.1.2.Final</version> 
    <type>pom</type> 
</dependency> 

Auch ich meinen Code diesen anderen Ansatz zu verwenden, geändert zu dem Server verbinden:

Connection connection = null; 
Session session = null; 
Formatter formatter = new Formatter(); 
Map<String, Object> connectionParams = new HashMap<String, Object>(); 
connectionParams.put(TransportConstants.PORT_PROP_NAME, 5445); 
connectionParams.put(TransportConstants.HOST_PROP_NAME, "localhost"); 

TransportConfiguration transportConfiguration = new TransportConfiguration(
    NettyConnectorFactory.class.getName(), connectionParams); 

try { 
    HornetQConnectionFactory cf = HornetQJMSClient 
     .createConnectionFactoryWithHA(JMSFactoryType.CF, transportConfiguration); 

    connection = cf.createConnection("testuser", "testpassword"); 

    connection.start(); 
    session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 

    Topic topicTarifas = session.createTopic("tarifas.01101"); 
    MessageProducer producer = session.createProducer(topicTarifas); 

    Message message = session.createTextMessage("My Test Message"); 

    producer.send(message); 

    System.out.println("It Worked!"); 
} catch (Exception e) { 
    System.out.println("It Failed!"); 
    e.printStackTrace(); 
} 

Hope this für jemand anderen nützlich sein kann :)

Answer 2

Haben Sie Ihren Client-Code mit den gleichen HornetQ-Bibliotheken kompiliert, die mit der von Ihnen verwendeten Version von JBoss EAP geliefert werden? Sie müssen wissen, dass es ein Problem mit der Versionskompatibilität gibt, das die Interoperabilität verschiedener HornetQ-Versionen nicht zulässt.