JMS

Virtual Machine Man Membro desde: 07/06/2005 16:17:56 Mensagens: 730 Offline

Estou tentando seguir o exemplo do Capítulo 2 do livro Java Message Service, mas estou recebendo o seguinte erro:

C:\>java Chat TopicCF topic1 Joao
Exception in thread "main" java.lang.NoClassDefFoundError: Chat (wrong name: ch0
2/Chat)
        at java.lang.ClassLoader.defineClass1(Native Method)
        at java.lang.ClassLoader.defineClassCond(ClassLoader.java:631)
        at java.lang.ClassLoader.defineClass(ClassLoader.java:615)
        at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:14
1)
        at java.net.URLClassLoader.defineClass(URLClassLoader.java:283)
        at java.net.URLClassLoader.access$000(URLClassLoader.java:58)
        at java.net.URLClassLoader$1.run(URLClassLoader.java:197)
        at java.security.AccessController.doPrivileged(Native Method)
        at java.net.URLClassLoader.findClass(URLClassLoader.java:190)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:306)
        at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:247)
Could not find the main class: Chat.  Program will exit.

O pior é que, aparentemente, está tudo bem!

Estou usando o JDK 1.6.0.25, Eclipse Indigo e ActiveMQ 5.5.0. Defini uma variável de ambiente ACTIVEMQ_HOME com o valor até \apache-activemq-5.5.0 e adicionei à variável CLASSPATH o valor %ACTIVEMQ_HOME%\activemq-all-5.5.0.jar.

Mantive a entrada .; junto com o restante do CLASSPATH.

A listagem - "copiada e colada" do livro - é esta:

package ch02;

import java.io.*;
import javax.jms.*;
import javax.naming.*;

public class Chat implements javax.jms.MessageListener{
    private TopicSession pubSession;
    private TopicPublisher publisher;
    private TopicConnection connection;
    private String username;

/* Constructor used to Initialize Chat */
    public Chat(String topicFactory, String topicName, String username) 
        throws Exception {
    	
    	// Obtain a JNDI connection using the jndi.properties file
        InitialContext ctx = new InitialContext();

// Look up a JMS connection factory
        TopicConnectionFactory conFactory = 
        	(TopicConnectionFactory)ctx.lookup(topicFactory);

// Create a JMS connection
        TopicConnection connection = conFactory.createTopicConnection();

// Create two JMS session objects
        TopicSession pubSession = connection.createTopicSession(
        	false, Session.AUTO_ACKNOWLEDGE);        
        TopicSession subSession = connection.createTopicSession(
        	false, Session.AUTO_ACKNOWLEDGE);

// Look up a JMS topic
        Topic chatTopic = (Topic)ctx.lookup(topicName);

// Create a JMS publisher and subscriber
        TopicPublisher publisher = 
            pubSession.createPublisher(chatTopic);
        TopicSubscriber subscriber = 
            subSession.createSubscriber(chatTopic, null, true);

// Set a JMS message listener
        subscriber.setMessageListener(this);

// Intialize the Chat application variables
        this.connection = connection;
        this.pubSession = pubSession;
        this.publisher = publisher;
        this.username = username;

// Start the JMS connection; allows messages to be delivered
        connection.start( );
    }

/* Receive Messages From Topic Subscriber */
    public void onMessage(Message message) {
        try {
            TextMessage textMessage = (TextMessage) message;
            String text = textMessage.getText( );
            System.out.println(text);
        } catch (JMSException jmse){ jmse.printStackTrace( ); }
    }

/* Create and Send Message Using Publisher */
    protected void writeMessage(String text) throws JMSException {
        TextMessage message = pubSession.createTextMessage( );
        message.setText(username+": "+text);
        publisher.publish(message);
    }

/* Close the JMS Connection */
    public void close( ) throws JMSException {
        connection.close( );
    }

/* Run the Chat Client */
    public static void main(String [] args){
        try{
            if (args.length!=3)
                System.out.println("Factory, Topic, or username missing");

// args[0]=topicFactory; args[1]=topicName; args[2]=username
            Chat chat = new Chat(args[0],args[1],args[2]);

// Read from command line
            BufferedReader commandLine = new 
              java.io.BufferedReader(new InputStreamReader(System.in));

// Loop until the word "exit" is typed
            while(true){
                String s = commandLine.readLine( );
                if (s.equalsIgnoreCase("exit")){
                    chat.close( ); // close down connection
                    System.exit(0);// exit program
                } else 
                    chat.writeMessage(s);
            }
        } catch (Exception e){ e.printStackTrace( ); }
    }
}

O arquivo jndi.properties, também "copiado e colado" do livro, é este:

E o arquivo activemq.xml, onde adicionei apenas a tag <destinations>, é este:

<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="locations">
            <value>file:${activemq.base}/conf/credentials.properties</value>
        </property>      
    </bean>

<destinations>
		<topic name = "topic1" physicalName = "jms.topic1" />
	</destinations>
	
    <broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.base}/data" destroyApplicationContextOnStop="true">
 
        <destinationPolicy>
            <policyMap>
              <policyEntries>
                <policyEntry topic=">" producerFlowControl="true" memoryLimit="1mb">
                  <pendingSubscriberPolicy>
                    <vmCursor />
                  </pendingSubscriberPolicy>
                </policyEntry>
                <policyEntry queue=">" producerFlowControl="true" memoryLimit="1mb">
                </policyEntry>
              </policyEntries>
            </policyMap>
        </destinationPolicy> 
 
        <managementContext>
            <managementContext createConnector="false"/>
        </managementContext>

Ao rodar o comando %ACTIVEMQ_HOME%\bin\activemq.bat, consigo "subir" o servidor numa boa! Inclusive, quando aponto o navegador para http://localhost:8161/admin/, consigo carregar o Console Administrativo!

A única coisa que não consigo é rodar o exemplo!

Alguém faz ideia do que eu devo fazer para conseguir rodar este exemplo?

O problema é esse:
O local onde você está executando a classe não contém a classe Chat. A classe foi criada dentro do pacote "ch02" e você está executando direto do "C:\"

Virtual Machine Man Membro desde: 07/06/2005 16:17:56 Mensagens: 730 Offline

num é isso não! eu só evitei colar aqui o caminho todo, até a classe...

Notícias, artigos e o maior fórum brasileiro sobre Java