[
https://issues.apache.org/activemq/browse/AMQCPP-150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omar Bashir updated AMQCPP-150:
-------------------------------
Attachment: CppQueueReceiver.cpp
CppQueueTransmitterOrig.cpp
Hi,
Thank you very much for your reply. I am afraid that I may not be able to
give you the original application for a number of reasons but attached are
a couple of test noddies that replicate the suggested behaviour but only on
activemq-cpp-2.1. If these replicate the problem on activemq 2.1 but not on
trunk, then its probably resolved in the trunk.
I am also not sure if I will be allowed to use trunk for the application I
am writing so I will probably have to code around this problem for the time
being. Is it possible to know the date of the next release.
I shall be grateful for your comments and suggestions.
Best Wishes.
Omar Bashir
(See attached file: CppQueueTransmitterOrig.cpp)
(See attached file: CppQueueReceiver.cpp)
"Timothy Bish
(JIRA)"
<[EMAIL PROTECTED]> To
[EMAIL PROTECTED]
25/10/2007 14:28 cc
Subject
[jira] Commented: (AMQCPP-150)
ActiveMQ-CPP consumer client
hanging after receiving 32767
messages.
[
https://issues.apache.org/activemq/browse/AMQCPP-150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#action_40506
]
Timothy Bish commented on AMQCPP-150:
-------------------------------------
I tried to reproduce this issue:
Running a 4.1.1 broker and ActiveMQ-CPP built from trunk. Platform is
Fedora 7.
I modified the example to not output anything to speed it up a bit, and to
send and receive 1,000,000 messages. It ran to completion without any
errors on client or broker.
My recommendations are to try and run with trunk to see if the problem goes
away. And also to try and provide sample code that demonstrates the
problem.
it a large burst of messages (100 per second). I realised that the client
hangs after receiving 32767 messages and the broker has a log message
dispatched message: MessageAck ...
still behaved the same way. Behaviour remained the same when I reduced
message frequency to one per second. I am using ActiveMQ-CPP-2.1 and
ActiveMQ broker 4.1.1.
disappeared. Then I ran both the Java and C++ consumers concurrently both
listening to the same queue, the C++ client froze after 16 messages whereas
the Java client continued to receive and process messages.
messages, reconnects and then starts transmitting again. The problem
disappears with this configuration. Both Java and C++ clients have now
received in excess of 230k messages and are still running perfectly well.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
EDF TRADING IS MOVING
>From 5 November 2007 we can be reached at our new address:
80 Victoria Street, 3rd Floor, Cardinal Place, London, SW1E 5JL
Phone and fax numbers will remain the same.
*********************************************************************
This communication contains confidential information, some or all of which may
be privileged. It is for the intended recipient only and others must not
disclose, distribute, copy, print or rely on this communication. If an
addressing or transmission error has misdirected this communication, please
notify the sender by replying to this e-mail and then delete the e-mail. E-mail
sent to EDF Trading may be monitored by the company. Thank you.
EDF Trading Markets Limited
71 High Holborn, London WC1V 6ED
A Company registered in England No. 4255974.
Switchboard: 020 7061 4000
EDF Trading Markets Limited is a member of the EDF Trading Limited Group and is
authorised and regulated by the Financial Services Authority.
VAT number: GB 735 5479 07
*********************************************************************
> ActiveMQ-CPP consumer client hanging after receiving 32767 messages.
> --------------------------------------------------------------------
>
> Key: AMQCPP-150
> URL: https://issues.apache.org/activemq/browse/AMQCPP-150
> Project: ActiveMQ C++ Client
> Issue Type: Bug
> Affects Versions: 2.1
> Environment: Ubuntu 6.10
> Reporter: Omar Bashir
> Assignee: Nathan Mittler
> Attachments: CppQueueReceiver.cpp, CppQueueTransmitterOrig.cpp
>
>
> I was stress-testing an ActiveMQ-CPP consumer client by transmitting to it a
> large burst of messages (100 per second). I realised that the client hangs
> after receiving 32767 messages and the broker has a log message
> INFO PrefetchSubscription - Could not correlate acknowledgment with
> dispatched message: MessageAck ...
> I changed the size of the message from 40 bytes to over 600 bytes but it
> still behaved the same way. Behaviour remained the same when I reduced
> message frequency to one per second. I am using ActiveMQ-CPP-2.1 and ActiveMQ
> broker 4.1.1.
> I replaced the C++ consumer with the Java consumer and the problem
> disappeared. Then I ran both the Java and C++ consumers concurrently both
> listening to the same queue, the C++ client froze after 16 messages whereas
> the Java client continued to receive and process messages.
> Now, I have the C++ producer client that disconnects after sending 32000
> messages, reconnects and then starts transmitting again. The problem
> disappears with this configuration. Both Java and C++ clients have now
> received in excess of 230k messages and are still running perfectly well.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
