I'm using JBoss2.2.2_Tomcat3.2.2 binary distribution. I've created a
MDB that can receive TextMessages just fine. I've recently added an
ObjectMessage and I receive the following error message.
[QueueBean] Transaction rolled back; nested exception is:
java.lang.ClassCastException: java.lang.String
[QueueBean] Transaction rolled back; nested exception is:
java.lang.ClassCastException: java.lang.String
[Container factory] Exception in JMSCI message listener: :
java.rmi.ServerException: Transaction rolled back; nested exception is:
java.lang.ClassCastException: java.lang.String
[Container factory] java.rmi.ServerException: Transaction rolled back;
nested exception is: java.lang.ClassCastException:
java.lang.String
[Container factory] java.lang.ClassCastException: java.lang.String
[Container factory] at
test.bean.QueueBean.onMessage(QueueBean.java:75)
[Container factory] at java.lang.reflect.Method.invoke(Native
Method)
[Container factory] Exception in JMSCI message listener: :
java.rmi.ServerException: Transaction rolled back; nested exception
is: java.lang.ClassCastException: java.lang.String
[Container factory] at
org.jboss.ejb.MessageDrivenContainer$ContainerInterceptor.invoke(MessageDrivenContainer.java:383)
[Container factory] at
org.jboss.ejb.plugins.MessageDrivenTxInterceptorBMT.invoke(MessageDrivenTxInterceptorBMT.java:83)
[Container factory] at
org.jboss.ejb.plugins.MessageDrivenInstanceInterceptor.invoke(MessageDrivenInstanceInterceptor.java:58)
[Container factory] at
org.jboss.ejb.plugins.SecurityInterceptor.invoke(SecurityInterceptor.java:190)
[Container factory] at
org.jboss.ejb.plugins.LogInterceptor.invoke(LogInterceptor.java:195)
[Container factory] at
org.jboss.ejb.MessageDrivenContainer.invoke(MessageDrivenContainer.java:264)
[Container factory] at
org.jboss.ejb.plugins.jms.JMSContainerInvoker.invoke(JMSContainerInvoker.java:151)
[Container factory] at
org.jboss.ejb.plugins.jms.JMSContainerInvoker$MessageListenerImpl.onMessage(JMSContainerInvoker.java:448)
[Container factory] at
org.jbossmq.SpyMessageConsumer.deliverMessage(SpyMessageConsumer.java:294)
[Container factory] at
org.jbossmq.SpySession.run(SpySession.java:236)
[Container factory] at
org.jboss.jms.asf.StdServerSession.run(StdServerSession.java:131)
[Container factory] at
org.jboss.jms.asf.ThreadPool$Worker.run(ThreadPool.java:128)
[Container factory] java.rmi.ServerException: Transaction rolled back;
nested exception is:
java.lang.ClassCastException: java.lang.String
The object that I'm putting in the message is Serializable. Here is the
client code piece that sends the message to the queue.
session = getQueueSession();
Queue queue = (Queue)context.lookup(dest);
QueueSender sender = session.createSender(queue);
/*
System.out.println("TestQueue: " + dest + " Sending 10 messages
1-10");
for (int i = 1; i < 11; i++) {
TextMessage message = session.createTextMessage();
message.setText("Queue Message " + dest + " nr " + i);
sender.send(queue, message);
}
*/
for (int i = 1; i < 3; i++) {
ObjectMessage message = session.createObjectMessage();
Request aRequest = getRequest(i);
message.setObject("Queue Message " + dest + " nr " +
aRequest.toString());
sender.send(queue, message);
}
I've commented out the TextMessages simply to debug. They still work.
The QueueBean (the MDB) has the following code:
public class QueueBean implements MessageDrivenBean, MessageListener{
private static String cName = "QueueBean";
private static String cNameLog = cName + ".";
private MessageDrivenContext ctx = null;
public QueueBean() {
System.out.println(cName + " ctor called.");
}
public void setMessageDrivenContext(MessageDrivenContext ctx)
throws EJBException {
this.ctx = ctx;
}
public void ejbCreate() {
System.out.println(cNameLog + "ejbCreate(): called");
}
public void ejbRemove() {
ctx=null;
}
public void onMessage(Message message) {
try
{
System.out.println(message.toString());
if(message instanceof TextMessage)
{
TextMessage textMessage = (TextMessage) message;
String text = (String) textMessage.getText();
System.out.println("onMessage(): got TextMessage text=<" + text
+ ">");
}
else if(message instanceof ObjectMessage)
{
ObjectMessage objectMessage = (ObjectMessage) message;
Request aRequest = (Request) objectMessage.getObject();
System.out.println("onMessage(): got ObjectMessage " +
"aRequest.toString()=<" +
aRequest.toString() + ">");
}
}
catch(JMSException ex)
{
ex.printStackTrace();
}
}
}
The ejb-jar.xml is:
<ejb-jar>
<enterprise-beans>
<message-driven>
<ejb-name>QueueBean</ejb-name>
<ejb-class>test.bean.QueueBean</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>
</message-driven>
</enterprise-beans>
</ejb-jar>
The jboss.xml is:
<jboss>
<enterprise-beans>
<message-driven>
<ejb-name>QueueBean</ejb-name>
<configuration-name>Standard Message Driven
Bean</configuration-name>
<destination-jndi-name>queue/testQueue</destination-jndi-name>
</message-driven>
</enterprise-beans>
</jboss>
This there some way to get the ObjectMessage? Do I need to let the
Consumer know about the Object? I have the Serializable class in the
jar file when I deploy it.
Please help I'm new to MDB.
Thanks in advance,
Steve
begin:vcard
n:Wilkinson;Steve
tel;cell:303-881-1568
tel;fax:720-946-0138
tel;work:303-881-1568
x-mozilla-html:FALSE
org:Elkhorn Creek Software, Inc.
adr:;;PO Box 40520;Denver;CO;80204;US
version:2.1
email;internet:[EMAIL PROTECTED]
title:Author/Architect/President
fn:Steve Wilkinson
end:vcard
