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 ([EMAIL PROTECTED]) (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.
