activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "dj (JIRA)" <j...@apache.org>
Subject [jira] Created: (AMQCPP-189) the message producer core dump during sending lots of messages
Date Wed, 30 Jul 2008 02:48:00 GMT
the message producer core dump during sending lots of  messages
---------------------------------------------------------------

                 Key: AMQCPP-189
                 URL: https://issues.apache.org/activemq/browse/AMQCPP-189
             Project: ActiveMQ C++ Client
          Issue Type: Bug
          Components: Example Code
    Affects Versions: 2.2
         Environment: Linux version 2.6.18-8.el5 (mockbuild@builder4.centos.org) (gcc version
4.1.1 20070105 (Red Hat 4.1.1-52)) #1 SMP Thu Mar 15 19:57:35 EDT 2007

ActiveMQ 5.1.0

            Reporter: dj
            Assignee: Nathan Mittler
            Priority: Blocker
         Attachments: example.zip

i set up the 5.1 broker on 192.168.10.64:61616, then i edit the example file (SimpleProducer.cpp)
changed the numMessages from 2000 to 10000,  after that i made the executable target and i
run it.
but the program always core dump when it sent 4846 messages, it seems to send 4846 messages
at most!
i didn't run message consumer during the period


 std::string brokerURI =
        "tcp://192.168.10.64:61616"
        "?wireFormat=openwire"
        "&transport.useAsyncSend=true"
//        "&transport.commandTracingEnabled=true"
//        "&transport.tcpTracingEnabled=true";
        "&wireFormat.tightEncodingEnabled=true";

    //============================================================
    // Total number of messages for this producer to send.
    //============================================================
    unsigned int numMessages = 10000;

    //============================================================
    // This is the Destination Name and URI options.  Use this to
    // customize where the Producer produces, to have the producer
    // use a topic or queue set the 'useTopics' flag.
    //============================================================
    std::string destURI = "mm.mq";

-----------------------------------------------------------------------------------------------------------------------------------------


core dump description below:
...
Sent message #4847 from thread -1208858928
No valid response received for command: Begin Class = ActiveMQTextMessage
Begin Class = ActiveMQMessageBase
 Value of ackHandler = 0
 Value of redeliveryCount = 0
 Value of properties = Begin Class PrimitiveMap:
map[Integer] = 4846
End Class PrimitiveMap:

Begin Class = Message
 Value of Message::ID_MESSAGE = 0
 Value of ProducerId is Below:
Begin Class = ProducerId
 Value of ProducerId::ID_PRODUCERID = 123
 Value of ConnectionId = 484e5a07-8fda-f925-266f-f7fe809c44b9
 Value of Value = 0
 Value of SessionId = 0
No Data for Class BaseDataStructure
End Class = ProducerId

 Value of Destination is Below:
Begin Class = ActiveMQQueue
Begin Class = ActiveMQDestination
 Value of exclusive = false
 Value of ordered = false
 Value of advisory = false
 Value of orderedTarget = coordinator
 Value of physicalName = mm.mq
 Value of options = Begin Class activemq::util::Properties:
End Class activemq::util::Properties:

No Data for Class BaseDataStructure
End Class = ActiveMQDestination
End Class = ActiveMQQueue

 Value of TransactionId is Below:
   Object is NULL
 Value of OriginalDestination is Below:
   Object is NULL
 Value of MessageId is Below:
Begin Class = MessageId
 Value of MessageId::ID_MESSAGEID = 110
 Value of ProducerId is Below:
Begin Class = ProducerId
 Value of ProducerId::ID_PRODUCERID = 123
 Value of ConnectionId = 484e5a07-8fda-f925-266f-f7fe809c44b9
 Value of Value = 0
 Value of SessionId = 0
No Data for Class BaseDataStructure
End Class = ProducerId

 Value of ProducerSequenceId = 4846
 Value of BrokerSequenceId = 0
No Data for Class BaseDataStructure
End Class = MessageId

 Value of OriginalTransactionId is Below:
   Object is NULL
 Value of GroupID = 
 Value of GroupSequence = 0
 Value of CorrelationId = 
 Value of Persistent = 0
 Value of Expiration = 0
 Value of Priority = 4
 Value of ReplyTo is Below:
   Object is NULL
 Value of Timestamp = 1217384921228
 Value of Type = 
 Value of Content[0] = , check broker.
        FILE: activemq/transport/filters/ResponseCorrelator.cpp, LINE: 151
        FILE: activemq/transport/filters/ResponseCorrelator.cpp, LINE: 159
        FILE: activemq/connector/openwire/OpenWireFormatNegotiator.cpp, LINE: 106
        FILE: activemq/connector/openwire/OpenWireConnector.cpp, LINE: 1454
        FILE: activemq/connector/openwire/OpenWireConnector.cpp, LINE: 866
        FILE: activemq/core/ActiveMQSession.cpp, LINE: 670
        FILE: activemq/core/ActiveMQProducer.cpp, LINE: 190
        FILE: activemq/core/ActiveMQProducer.cpp, LINE: 145
        FILE: activemq/core/ActiveMQProducer.cpp, LINE: 105
-----------------------------------------------------
Finished with the example.

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


Mime
View raw message