You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Nathan Mittler (JIRA)" <ji...@apache.org> on 2008/08/09 17:44:52 UTC
[jira] Updated: (AMQCPP-189) the message producer core dump during
sending lots of messages
[ https://issues.apache.org/activemq/browse/AMQCPP-189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Nathan Mittler updated AMQCPP-189:
----------------------------------
Fix Version/s: 2.2.1
> 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: Sub-task
> 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
> Fix For: 2.2.1
>
> 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.