MDB not receiving msgs
echofloripa Mar 21, 2002 6:52 PMI have a MDB succefully deployed, but when I try to send messages (no error) my MDB is not receiving the msgs, as it woul'd print statements to System.out...
Here goes my mdb code and deployment desc, besides the client:
jboss.xml
<?xml version="1.0" encoding="Cp1252"?>
<enterprise-beans>
<message-driven>
<ejb-name>ProcessadorDeMovimentacao</ejb-name>
<destination-jndi-name>queue/Queue</destination-jndi-name>
</message-driven>
</enterprise-beans>
ejb-jar.xml
<?xml version="1.0"?>
<!DOCTYPE ejb-jar PUBLIC "-//Sun Microsystems, Inc.//DTD Enterprise JavaBeans 1.1//EN" "http://java.sun.com/j2ee/dtds/ejb-jar_1_1.dtd">
<ejb-jar>
Message-Driven Beans
<enterprise-beans>
<message-driven>
<ejb-name>ProcessadorDeMovimentacao</ejb-name>
<ejb-class>cobranca.ProcessadorDeMovimentacao</ejb-class>
<message-selector></message-selector>
<transaction-type>Bean</transaction-type>
<acknowledge-mode>Auto-acknowledge</acknowledge-mode>
<message-driven-destination>
<destination-type>javax.jms.Queue</destination-type>
</message-driven-destination>
<subscription-durability>NonDurable</subscription-durability>
<resource-ref>
<res-ref-name>jdbc/OracleDS</res-ref-name>
<res-type>javax.sql.DataSource</res-type>
<res-auth>Container</res-auth>
</resource-ref>
</message-driven>
</enterprise-beans>
<assembly-descriptor>
</assembly-descriptor>
</ejb-jar>
MDB code
public class ProcessadorDeMovimentacao implements MessageDrivenBean
{
private MessageDrivenContext messageContext;
public void ejbCreate()
{
System.out.println("MessageLogger.ejbCreate()");
}
public void onMessage(Message message)
{
System.out.println("Received message: " + message);
try
{
...
client code :
InitialContext ctx=new InitialContext();
// Lookup a JMS connection factory
QueueConnectionFactory conFactory =(QueueConnectionFactory) ctx.lookup("QueueConnectionFactory");
// Create a JMS connection
QueueConnection connection = conFactory.createQueueConnection();
connection.start();
// Create a JMS session object
QueueSession session = connection.createQueueSession(true,0);
// Lookup a JMS queue
Queue queue= (Queue) ctx.lookup("queue/Queue");
// Create a JMS sender
QueueSender sender = session.createSender(queue);
Enumeration enum=vetor.elements();
ObjectMessage message=null;
while(enum.hasMoreElements())
{
Movimento mov=(Movimento) enum.nextElement();
message=session.createObjectMessage(mov);
sender.send(message);
}
...
jndi file
### JBossNS properties
java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory
java.naming.provider.url=jnp://localhost:1099
java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces
What it could be??
obs: i configured a queue in jboss.jcml
Regards...
Emerson