is the JBoss close connection exception the root cause of ma
Hello folks, I have this command, a highly modified version of what
is written in the JBoss docs.
It seems to successfully publish messages. Note that transactions are not used in this example. However, the server console shows debug output, an exception in closing a connection. Below is my class. Even lower is a partial listing of the debug output.
In my humble opinion, this close exception seems like an error. But I can be wrong. Is this exception, thrown within the server, intentional? I know that sometimes, exception handling is an actual part of business logic, and perhaps in this situation it is used to communicate state.
I would truly appreciate help in this knowledge. I notice that many other post that they are having errors using JMS with transactions. This very well could be the root of the cause. Perhaps, nothing is wrong with the transaction, and the cause is that this close is causing a rollback. Who knows. This is mere speculation.
package infonet.jms;
import javax.jms.JMSException;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicPublisher;
import javax.jms.TopicSession;
import javax.jms.TextMessage;
import javax.naming.InitialContext;
import javax.naming.NamingException;
/**
* Publishes a text message to the given topic.
*/
public class PublisherCommand
{
/** topic JNDI Name */
private String topicJndiName = null;
/** The message text */
private String text = null;
/**
* Retrieves the message text that will be sent.
* @return the message.
*/
public String getText()
{
return text;
}
/**
* Sets the message to that will be sent.
* @param text The message text to send.
*/
public void setText(String text)
{
this.text = text;
}
/**
* Retrieves the topic JNDI name.
* @return the topic JNDI name.
*/
public String getTopicJndiName()
{
return topicJndiName;
}
/**
* Sets the topic JNDI name.
* @param topicJndiName the topic JNDI name.
*/
public void setTopicJndiName(String topicJndiName)
{
this.topicJndiName = topicJndiName;
}
/**
* Publishes the text message to a topic.
*/
public void execute() throws JMSException,NamingException
{
if (topicJndiName==null || text==null)
throw new IllegalArgumentException("topic and text must be set");
TopicConnection con = null;
try
{
InitialContext ctx = new InitialContext();
TopicConnectionFactory tcf = (TopicConnectionFactory) ctx.lookup("ConnectionFactory");
con = tcf.createTopicConnection();
Topic topic = (Topic) ctx.lookup(topicJndiName);
TopicSession session = con.createTopicSession(false,TopicSession.AUTO_ACKNOWLEDGE);
con.start();
TopicPublisher publisher = session.createPublisher(topic);
TextMessage message = session.createTextMessage(text);
publisher.publish(message);
}
finally
{
if (con!=null)
con.close();
}
}
/**
* Runs this command for test purposes
* @param args none requred.
* @throws Exception
*/
public static void main(String args[]) throws Exception
{
System.out.println("Begin Publsher Command, now=" + System.currentTimeMillis());
PublisherCommand publisher = new PublisherCommand();
publisher.setTopicJndiName("topic/tmipMQ");
publisher.setText("A text msg, now=" + System.currentTimeMillis());
try
{
publisher.execute();
}
catch (JMSException e)
{
e.printStackTrace();
}
catch (NamingException e)
{
e.printStackTrace();
}
System.out.println("End Publisher Command");
System.exit(0);
}
}
And then the log output:
2005-05-06 08:32:20,668 DEBUG [org.jboss.mq.il.uil2.SocketManager] Begin ReadTask.run
2005-05-06 08:32:20,668 DEBUG [org.jboss.mq.il.uil2.SocketManager] Begin WriteTask.run
2005-05-06 08:32:20,698 DEBUG [org.jboss.mq.il.uil2.SocketManager] Created ObjectOutputStream
2005-05-06 08:32:20,748 DEBUG [org.jboss.mq.il.uil2.SocketManager] Created ObjectInputStream
2005-05-06 08:32:20,838 DEBUG [org.jboss.mq.il.uil2.ServerSocketManagerHandler] Setting up the UILClientIL Connection
2005-05-06 08:32:20,838 DEBUG [org.jboss.mq.il.uil2.ServerSocketManagerHandler] The UILClientIL Connection is set up
2005-05-06 08:32:21,208 DEBUG [org.jboss.mq.il.uil2.SocketManager] End WriteTask.run
2005-05-06 08:32:21,208 DEBUG [org.jboss.mq.il.uil2.ServerSocketManagerHandler] Exiting on IOE
java.io.EOFException
at java.io.ObjectInputStream$BlockDataInputStream.readByte(ObjectInputStream.java:2603)
at java.io.ObjectInputStream.readByte(ObjectInputStream.java:845)
at org.jboss.mq.il.uil2.SocketManager$ReadTask.run(SocketManager.java:285)
at java.lang.Thread.run(Thread.java:534)
2005-05-06 08:32:21,218 DEBUG [org.jboss.mq.il.uil2.SocketManager] End ReadTask.run
Thank you.
