activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Wayne1285 <WayneSIr...@hotmail.com>
Subject EOFException
Date Mon, 03 Apr 2006 06:20:25 GMT

I am using ActiveMQ 4.0-RC1, persisitng to MySQL 5.0  running Java 1.5

I have opened a connection to a Broker on a server from a client and created
a session.  The connection registers in the JMX browser on the server.  When
I try to send a simple text message, I receive an EOFException.  I have
tested this with a Broker on the client and it works fine.

Here is a portion of the log
========================================
DEBUG  JmsCommunicator.connect() session=ActiveMQSession
{id=ID:irwin-3800-3505-1144043685484-1:0:1,started=false} -- 12:54:46.125
 DEBUG  JmsCommunicator.sendMessage() message=ActiveMQTextMessage {commandId
= 0, responseRequired = false, messageId = null, originalDestination = null,
originalTransactionId = null, producerId = null, destination = null,
transactionId = null, expiration = 0, timestamp = 0, arrival = 0,
correlationId = null, replyTo = null, persistent = false, type = null,
priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content = null, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties =
null, readOnlyProperties = false, readOnlyBody = false, text = Message 1} --
12:54:46.140
 DEBUG  JmsCommunicator.getMessageSender()
destination=queue://playerActivity -- 12:54:46.140
 DEBUG  JmsCommunicator.getMessageSender() sender=ActiveMQMessageProducer {
value=ID:irwin-3800-3505-1144043685484-1:0:1:1 } -- 12:54:46.156
 DEBUG  Sending message: ActiveMQTextMessage {commandId = 0,
responseRequired = false, messageId =
ID:irwin-3800-3505-1144043685484-1:0:1:1:1, originalDestination = null,
originalTransactionId = null, producerId =
ID:irwin-3800-3505-1144043685484-1:0:1:1, destination =
queue://playerActivity, transactionId =
TX:ID:irwin-3800-3505-1144043685484-1:0:1, expiration = 0, timestamp =
1144043686156, arrival = 0, correlationId = null, replyTo = null, persistent
= true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 0, properties = null, readOnlyProperties = true, readOnlyBody = true,
text = Message 1} -- 12:54:46.156
 ERROR  JmsCommunicator.onException() javax.jms.JMSException:
java.io.EOFException-java.io.EOFException - java.io.EOFException --
12:54:47.171
  WARN  JmsCommunicator.disconnectFromJMSServer() Did not close up-loader
cleanly. javax.jms.JMSException: Cannot write to the stream any more it has
already been closed -- 12:54:47.171
  WARN  JmsCommunicator.disconnectFromJMSServer() Did not close session
cleanly. javax.jms.JMSException: Cannot write to the stream any more it has
already been closed -- 12:54:47.171
  WARN  JmsCommunicator.disconnectFromJMSServer() Did not close connection
cleanly. javax.jms.JMSException: Cannot write to the stream any more it has
already been closed -- 12:54:47.171
==============================================

Here is the relevant code
==============================================
    public void sendMessage(String _message) throws CommunicatorException {

        if (m_session == null) {
            throw new IllegalStateException(
                    "Connection not established.  Call connect() before
sendMessage()");
        }

        String tryingTo = "";
        try {
            tryingTo = "prepare the content for sending";
            TextMessage message = m_session.createTextMessage(_message);
            s_logger.debug("JmsCommunicator.sendMessage() message=" +
message);

            tryingTo = "send the content";
            getMessageSender().send(message);
            m_session.commit();
            s_logger.debug("JmsCommunicator.sendMessage() Sent message. '" +
message.getText()
                    + "'");
            m_sentCount++;

        } catch (JMSException e) {
            throw new CommunicatorException("Could not sendMessage. Trying
to " + tryingTo + ". "
                    + e);
        }
    }

    protected MessageProducer getMessageSender() throws
CommunicatorException {
        // If already setup, just return it.
        if (m_messageSender != null) {
            return m_messageSender;
        }

        if (m_session == null) {
            throw new IllegalStateException(
                    "Connection not established.  Call connect() before
getMessageSender()");
        }

        // Create a new message sender.
        String tryingTo = "";
        try {
            tryingTo = "create queue " + getSendQueueName();
            Destination destination =
m_session.createQueue(getSendQueueName());
            s_logger.debug("JmsCommunicator.getMessageSender() destination="
+ destination);

            m_messageSender = m_session.createProducer(destination);
            m_messageSender.setDeliveryMode(DeliveryMode.PERSISTENT);
            s_logger.debug("JmsCommunicator.getMessageSender() sender=" +
m_messageSender);
            return m_messageSender;
        } catch (JMSException e) {
            throw new CommunicatorException("Could not getMessageSender().
Trying to " + tryingTo
                    + ".", e);
        }
    }
=================================================


--
View this message in context: http://www.nabble.com/EOFException-t1385203.html#a3720526
Sent from the ActiveMQ - User forum at Nabble.com.


Mime
View raw message