EJB3.0 Como usar MDB

Question

Ei, sou novo em codificação em j2ee.Minha dúvida é em relação ao MDB.Já configurei meu servidor weblogic 11g.e a fila foi configurada.

Eu escrevi o código do cliente que é um cliente java se que envia uma mensagem para a fila.

import java.util.Hashtable;
import java.util.Properties;

import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;

public class MyMDBClient {

    /**
     * @param args
     */
    public static void main(String[] args) {
         QueueConnection cnn = null;
            QueueSender sender = null;
            QueueSession session = null;
            InitialContext ctx;
            Hashtable ht = new Hashtable();

            try {
                ht.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");
                ht.put(Context.PROVIDER_URL,"t3://localhost:7001");

                ctx = new InitialContext(ht);
                Queue queue = (Queue) ctx.lookup("jms/testQueue");
                QueueConnectionFactory factory = (QueueConnectionFactory) ctx.lookup("jms/connectionFactory");
                cnn = factory.createQueueConnection();
                session = cnn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
                TextMessage msg = session.createTextMessage();
                msg.setText("helloworld");
                sender = session.createSender(queue);
                sender.send(msg);

                System.out.println("Message sent successfully to remote queue.");
                session.close(); // this is important.
            } catch (Exception e) {
                e.printStackTrace();
            }
    }
}

Posso ver a mensagem na fila no meu console administrativo do weblogic.

no entanto, meu mdb no servidor não é invocado.

Alguém pode me dizer o que está errado.Prefiro que a solução esteja em anotações java.obrigado a todos por lerem isso.

aqui está o código do meu servidor:

/**
 * import
 *
 */

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

import weblogic.ejbgen.*;


/**
 * Message-Driven Bean implementation class for: MyMDB
 *
 */
@MessageDriven(ejbName="mdb", destinationType="javax.jms.queue",destinationJndiName="jms/testQueue"  )
public class mdb implements MessageListener {

    /**
     * Default constructor. 
     */
    public mdb() {
    }

    /**
     * @see MessageListener#onMessage(Message)
     */
    public void onMessage(Message message) {
        TextMessage tmsg = null;
        tmsg = (TextMessage) message; 

        System.out.println("----------------");
        System.out.println("Received message : ");        
        try {
            System.out.println(tmsg.getText());
        } catch (JMSException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }   

        System.out.println("----------------");        
    }
}

Answer 1

Aqui está um exemplo das anotações que tenho em um MDB que está funcionando:

@MessageDriven(
    messageListenerInterface = javax.jms.MessageListener.class,
    name = "EventQueueListenerMDB",
    mappedName = Constants.EVENT_QUEUE_JNDI,
    activationConfig = {
            @ActivationConfigProperty(
                    propertyName = "connectionFactoryJndiName",
                    propertyValue = Constants.CONNECTION_FACTORY_JNDI),
            @ActivationConfigProperty(
                    propertyName = "destinationType",
                    propertyValue = "javax.jms.Queue")
    })

Além disso, parece que você tem javax.jms.queue e não javax.jms.Queue.