[AMQCPP-189] the message producer core dump during sending lots of messages

• Type: Sub-task
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 2.2
• Fix Version/s: 2.2.1
• Component/s: Example Code

Environment

Linux version 2.6.18-8.el5 ([e-mail]) (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

• Assignee: Timothy A. Bish
• Reporter: dj
• Created: 30/Jul/08 02:47
• Updated: 24/Aug/08 20:00
• Resolved: 24/Aug/08 20:00

Description

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.