activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Timothy Bish (JIRA)" <j...@apache.org>
Subject [jira] Commented: (AMQCPP-189) the message producer core dump during sending lots of messages
Date Sun, 17 Aug 2008 19:03:52 GMT

    [ https://issues.apache.org/activemq/browse/AMQCPP-189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=45013#action_45013
] 

Timothy Bish commented on AMQCPP-189:
-------------------------------------

Item one is now complete and in trunk, new options are available on the URI for controlling
send timeout values.  See: http://activemq.apache.org/cms/configuring.html.

The result of this is that now the async transport will continue to build up messages for
send, eventually filling all space on the machine if let run long enough, so take care with
trunk at this time.



> 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.


Mime
View raw message