[jira] Work stopped: (AMQCPP-189) the message producer core dump during sending lots of messages

["Timothy Bish (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/activemq/browse/AMQCPP-189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Work on AMQCPP-189 stopped by Timothy Bish.

> 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: Timothy Bish
>            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.