[
https://issues.apache.org/jira/browse/QPID-2295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12793902#action_12793902
]
Alan Conway edited comment on QPID-2295 at 12/23/09 3:04 PM:
-------------------------------------------------------------
I can reproduce the problem with the test case provided, I'm looking into it.
I only see the error with debug log output going to my terminal, if logging is
turned down or redirected to a file I don't see the problem. Something to do
with slowing down the clients.
was (Author: aconway):
I can reproduce the problem with the test case provided, I'm looking into
it.
> Clustered broker crashes with inconsistency error
> -------------------------------------------------
>
> Key: QPID-2295
> URL: https://issues.apache.org/jira/browse/QPID-2295
> Project: Qpid
> Issue Type: Bug
> Components: C++ Broker
> Affects Versions: 0.6
> Environment: RHEL 5.4 on VMWare, 32 bit
> Reporter: Sandy Pratt
> Assignee: Alan Conway
> Attachments: qpid-driver.diff, qpid-driver.zip
>
>
> When running two brokers in a cluster, one of them will fail with a message
> like the following:
> 2009-12-17 14:04:23 error qpid/amqp_0_10/SessionHandler.cpp:97: Execution
> exception: invalid-argument:
> [email protected]: confirmed < (805+0) but
> only sent < (800+0) (qpid/SessionState.cpp:151)
> 2009-12-17 14:04:23 critical qpid/cluster/ErrorCheck.cpp:87:
> cluster(10.59.174.211:3060 READY/error) local error 126323 did not occur on
> member 10.59.174.186:32003: invalid-argument:
> [email protected]: confirmed < (805+0) but
> only sent < (800+0) (qpid/SessionState.cpp:151)
> 2009-12-17 14:04:23 error ./qpid/cluster/PollableQueue.h:58: Error delivering
> frames: local error did not occur on all cluster members : invalid-argument:
> [email protected]: confirmed < (805+0) but
> only sent < (800+0) (qpid/SessionState.cpp:151)
> (qpid/cluster/ErrorCheck.cpp:89)
> 2009-12-17 14:04:23 notice qpid/cluster/Cluster.cpp:369:
> cluster(10.59.174.211:3060 LEFT/error) leaving cluster na1m-dev1
> 2009-12-17 14:04:23 notice qpid/broker/Broker.cpp:340: Shut down
> ...
> 2009-12-17 14:25:00 error qpid/amqp_0_10/SessionHandler.cpp:97: Execution
> exception: invalid-argument:
> [email protected]: confirmed < (742+0) but
> only sent < (729+0) (qpid/SessionState.cpp:151)
> 2009-12-17 14:25:00 critical qpid/cluster/ErrorCheck.cpp:87:
> cluster(10.59.174.211:3874 READY/error) local error 151214 did not occur on
> member 10.59.174.186:32003: invalid-argument:
> [email protected]: confirmed < (742+0) but
> only sent < (729+0) (qpid/SessionState.cpp:151)
> 2009-12-17 14:25:00 error ./qpid/cluster/PollableQueue.h:58: Error delivering
> frames: local error did not occur on all cluster members : invalid-argument:
> [email protected]: confirmed < (742+0) but
> only sent < (729+0) (qpid/SessionState.cpp:151)
> (qpid/cluster/ErrorCheck.cpp:89)
> 2009-12-17 14:25:00 notice qpid/cluster/Cluster.cpp:369:
> cluster(10.59.174.211:3874 LEFT/error) leaving cluster na1m-dev1
> 2009-12-17 14:25:00 notice qpid/broker/Broker.cpp:340: Shut down
> qpidd.conf looks like this:
> data-dir=/usr/local/adobe/qpid-data
> #no-module-dir=1
> #load-module=/usr/local/adobe/qpid/lib/qpid/daemon/cluster.so
> #load-module=/usr/local/adobe/qpid/lib/qpid/daemon/msgstore.so
> cluster-mechanism=PLAIN
> #cluster-mechanism=ANONYMOUS
> cluster-name="na1m-dev1"
> cluster-username="na1mdev1"
> cluster-password="***"
> log-to-file=/usr/local/adobe/qpid-data/qpidd.log
> log-source=1
> trace=0
> auth=1
> #acl-file=/usr/local/adobe/qpid-data/qpidd.acl
> wait=60
> The client is the Java JMS client from 0.6beta1. The connection strings are
> as follows:
> connectionfactory.qpidConnectionFactory =
> amqp://na1mdev1:*...@test/?brokerlist='tcp://na1m-dev1.services.adobe.com:443?ssl='true',connectdelay='1000',connecttimeout='5000'',failover='roundrobin?cyclecount='999''
> destination.recvQueue=direct:////test-prattrs?durable='true'
> destination.sendQueue=direct:////test-prattrs?durable='true'
> Qpid was built from trunk at the following revision:
> [prat...@localhost qpid]$ svn info
> Path: .
> URL: http://svn.apache.org/repos/asf/qpid/trunk/qpid
> Repository Root: http://svn.apache.org/repos/asf
> Repository UUID: 13f79535-47bb-0310-9956-ffa450edef68
> Revision: 891406
> Node Kind: directory
> Schedule: normal
> Last Changed Author: aconway
> Last Changed Rev: 891395
> Last Changed Date: 2009-12-16 11:31:20 -0800 (Wed, 16 Dec 2009)
> The messaging store was built from trunk at the following revision:
> [prat...@localhost cpp]$ svn info
> Path: .
> URL: http://anonsvn.jboss.org/repos/rhmessaging/store/trunk/cpp
> Repository Root: http://anonsvn.jboss.org/repos/rhmessaging
> Repository UUID: 06e15bec-b515-0410-bef0-cc27a458cf48
> Revision: 3750
> Node Kind: directory
> Schedule: normal
> Last Changed Author: kpvdr
> Last Changed Rev: 3747
> Last Changed Date: 2009-12-16 10:24:45 -0800 (Wed, 16 Dec 2009)
> I'll work on packaging up driver code for external consumption. Basically
> though, what I'm doing to drive qpid is establishing 8 send and 8 receiving
> connections, with either a producer or consumer on each one, and a separate
> thread for each. Message bodies are randomly generated 1000 character
> strings. Each sender thread sends 1000 or these messages, for a total of
> 8000 messages sent. All the messages get through because the primary
> survives in good health. The total length of the sending period for each of
> the above failures was about 20 seconds, at a rate of about 450 messages per
> second.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
