2017-05-04 6 views
0

Ich schreibe einen Qpid-Client, der eine Nachricht sendet. Der Beispielcode, die ich verwende ist:Klasse kann nicht instanziiert werden: org.apache.qpid.jndi.PropertiesFileInitialContextFactory

private void runTest() throws Exception { 
    Properties properties = new Properties(); 
    properties.load(this.getClass().getResourceAsStream("helloworld.properties")); 
    Context context = new InitialContext(properties);        

    ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("qpidConnectionFactory");    
    Connection connection = connectionFactory.createConnection();     
    connection.start();                

    Session session = connection.createSession(true, Session.SESSION_TRANSACTED); 
    Queue queue = (Queue) context.lookup("myqueue");        

    MessageConsumer messageConsumer = session.createConsumer(queue);    
    MessageProducer messageProducer = session.createProducer(queue);    

    TextMessage message = session.createTextMessage("Hello world!");     
    messageProducer.send(message); 
    session.commit(); 

    message = (TextMessage)messageConsumer.receive();        
    session.commit(); 
    System.out.println(message.getText()); 

    connection.close();                
    context.close();                 
} 

Die begleitende config:

java.naming.factory.initial = org.apache.qpid.jndi.PropertiesFileInitialContextFactory 
connectionfactory.qpidConnectionFactory = amqp://guest:[email protected]/?brokerlist='tcp://localhost:61111' 
queue.myqueue = queue1 

Der Fehler, ich bin immer ist:

Exception in thread "main" javax.naming.NoInitialContextException: Cannot instantiate class: org.apache.qpid.jndi.PropertiesFileInitialContextFactory [Root exception is java.lang.ClassNotFoundException: org.apache.qpid.jndi.PropertiesFileInitialContextFactory] 
    at javax.naming.spi.NamingManager.getInitialContext(NamingManager.java:674) 
    at javax.naming.InitialContext.getDefaultInitCtx(InitialContext.java:313) 
    at javax.naming.InitialContext.init(InitialContext.java:244) 
    at javax.naming.InitialContext.<init>(InitialContext.java:216) 
    at Hello.runTest(Hello.java:19) 
    at Hello.main(Hello.java:13) 
Caused by: java.lang.ClassNotFoundException: org.apache.qpid.jndi.PropertiesFileInitialContextFactory 
    at java.net.URLClassLoader.findClass(URLClassLoader.java:381) 
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424) 
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331) 
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357) 
    at java.lang.Class.forName0(Native Method) 
    at java.lang.Class.forName(Class.java:348) 
    at com.sun.naming.internal.VersionHelper12.loadClass(VersionHelper12.java:72) 
    at com.sun.naming.internal.VersionHelper12.loadClass(VersionHelper12.java:61) 
    at javax.naming.spi.NamingManager.getInitialContext(NamingManager.java:672) 
    ... 5 more 

Sieht aus wie es nicht in der Lage ist, zu initialisieren der Kontext für die Eigenschaftendatei

Ich habe eine ActiveMQ-Instanz lokal auf Port 61111 ausgeführt. Die Eigenschaftendatei befindet sich tatsächlich in meinem CLASSPATH. Was könnte ich hier noch vermissen?

+0

haben Sie alle notwendigen Bibliotheken korrekt in Ihrem lib-Ordner? – Stultuske

+0

Die einzige Bibliothek, über die sich meine IDE beschwerte, war 'java.jmx. *'. Also habe ich sie hinzugefügt. –

+1

Welcher Qpid JMS-Client verwenden Sie? Dies scheint ein älterer Client zu sein und nicht der neueste offizielle Qpid JMS-Client: http://qpid.apache.org/components/jms/index.html –

Antwort

0

Versuchen Sie java.naming.factory.initial = org.apache.qpid.jms.jndi.JmsInitialContextFactory

Verwandte Themen