problemwith MessageDriven Bean

[blv krishna]

hi gurus,

i have a problem with MDB. my scenario is i need two JMS Queues and two listners for the queues. for that i have created two connection factories and two destination resources in glasshfish admin console.

Connection Factories:1.jms/testfact1
2.jms/testfact2

Destination Resources 1.jms/testdest1
2.jms/testdest2

MDB 1:

@MessageDriven(mappedName = "jms/testdest1", activationConfig = {
@ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
})


public class MDB1 MessageListener {

public void onMessage(Message message) {
try {
TextMessage text=(TextMessage)message;
System.out.println("message has received-->"+text.getText());
} catch (Exception ex) {
Logger.getLogger(TestMessageDrivenBean.class.getName()).log(Level.SEVERE, null, ex);
}
}

MDB 2:

@MessageDriven(mappedName = "jms/testdest2", activationConfig = {
@ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
})


public class MDB2 MessageListener {

public void onMessage(Message message) {
try {
TextMessage text=(TextMessage)message;
System.out.println("message has received-->"+text.getText());
} catch (Exception ex) {
Logger.getLogger(TestMessageDrivenBean.class.getName()).log(Level.SEVERE, null, ex);
}
}

Client 1

public class ProcessQueueJMS implements ProcessInvokerRemote {

@Resource(mappedName = "jms/testfact1")
private ConnectionFactory connectionFactory;
@Resource(mappedName = "jms/testdest1")
private Queue queue;

public void run(String str){


Connection connection = connectionFactory.createConnection();
javax.jms.Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
javax.jms.MessageProducer messageProducer = session.createProducer(queue);
ObjectMessage message = session.session.createTextMessage();
message.setText(str);
message.setJMSType(obj[0].toString());
messageProducer.send(message);

}
}



Client 2

public class ProcessQueueJMS11 implements ProcessInvokerRemote {

@Resource(mappedName = "jms/testfact2")
private ConnectionFactory connectionFactory;
@Resource(mappedName = "jms/testdest2")
private Queue queue;

public void run(String str){


Connection connection = connectionFactory.createConnection();
javax.jms.Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
javax.jms.MessageProducer messageProducer = session.createProducer(queue);
ObjectMessage message = session.session.createTextMessage();
message.setText(str);
message.setJMSType(obj[0].toString());
messageProducer.send(message);

}
}

PROBLEM IS WHEN I EXECUTE CLINT1 , SOMETIMES THE MDB1 IS RECEIVING THE MESSAGE AND SOME TIMES MDB2 IS RECEIVING MESSAGE. SAME WITH CLIENT 2 ALSO.......PLEASE HELP ME TWO RESOLVE THIS PROBLEM

REGARDS
GURU...

[David Newton]

Please UseCodeTags when posting code or configuration. Unformatted code and configuration is very difficult to read. You can edit your post to include them by using the button.

I've also moved this to the JEE forum.

[blv krishna]

David Newton wrote:Please UseCodeTags when posting code or configuration. Unformatted code and configuration is very difficult to read. You can edit your post to include them by using the button.

I've also moved this to the JEE forum.

i have solved the problem by own

thanks

Guru....

[Greg Schultz]

So what was the fix?

[blv krishna]

Greg Schultz wrote:So what was the fix?

problem is all resource destinations are having the same physical destinations. so i have created the separete physical destination for each resource destination.

regards
Guru..