Consumir mensajes con MDB en jms

[luisfm]

Buenas noches queridos amigos,

Tengo un problema con un mdb. Tengo el cliente que envía los mensajes a una cola creada en el servidor weblogic 10.3, efectivamente los envía, pero debo consumirlo por medio del mdb y no me lo consume, el código del mdb es el siguiente:


package sv.com.tigo.suscripcion.ejb;

import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.ejb.MessageDrivenBean;
import javax.ejb.MessageDrivenContext;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

/**
* @author fmarin
*
*/
@MessageDriven(mappedName = "queue/SuscriptionQueue",activationConfig = {
@ActivationConfigProperty(propertyName="destinatio nType", propertyValue="javax.jms.Queue"),
@ActivationConfigProperty(propertyName="destinatio n", propertyValue="queue/SuscriptionQueue")
}
)
public class MotorPeticionesPruebaMDB implements MessageDrivenBean, MessageListener {
/**
*
*/
private static final long serialVersionUID = 1L;

public void setMessageDrivenContext(MessageDrivenContext aContext) {
}

public void ejbCreate() { }
public void ejbRemove() { }

public void onMessage(Message aMessage) {
try {
TextMessage txtMessage = (TextMessage) aMessage;
String mensaje;
mensaje = txtMessage.getText();
System.out.println(mensaje);
} catch (JMSException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}
}

el cliente es:

package sv.com.tigo.suscripcion.ejb;

import java.util.Hashtable;

import javax.ejb.EJB;
import javax.ejb.Stateless;
import javax.jms.Queue;

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

/**
* @author fmarin
*
*/
@Stateless (mappedName="SuscriptionRequest")
public class SuscriptionRequestEJB implements SuscriptionRequestEJBLocal, SuscriptionRequestEJBRemote{

public final static String JNDI_FACTORY="weblogic.jndi.WLInitialContextFactor y";
public final static String PROVIDER_URL_URL="t3://localhost:7001";

public final static String JMS_FACTORY="suscriptionRequestConection";
public final static String QUEUE="SuscriptionQueue";

public void SolicitudSuscripcion(String campo) {

try{

System.out.println(JMS_FACTORY+""+QUEUE);
//Obtenemos el InitialContext
Hashtable env = new Hashtable();
env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
env.put(Context.PROVIDER_URL, PROVIDER_URL_URL);
InitialContext ctx = new InitialContext(env);

//Buscamos el factory y la conexion a la cola
QueueConnectionFactory qconFactory = (QueueConnectionFactory) ctx.lookup(JMS_FACTORY);
QueueConnection qcon = qconFactory.createQueueConnection();

//Buscamos la cola
QueueSession qsession = qcon.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = (Queue) ctx.lookup(QUEUE);

//Creamos el mensaje
TextMessage msg = qsession.createTextMessage();
msg.setText(campo);

//Enviamos el mensaje
QueueSender qsender = qsession.createSender(queue);
qsender.send(msg);

//cerramos todo
qsender.close();
qsession.close();
qcon.close();

}catch (Exception e) {
System.out.println("Error haciendo la prueba de inserción a la cola"+e);
}

}

}


SOLICITO SU AYUDA!!!!!!!

GRACIAS!!!!