summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Remove possible double closing of connection on connect failureAndrew Stitcher2010-01-211-7/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901552 13f79535-47bb-0310-9956-ffa450edef68
* Fix a potential RDMA connect failure raceAndrew Stitcher2010-01-211-3/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901551 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1879 Don't use a thread for every new client ConnectionAndrew Stitcher2010-01-217-220/+196
| | | | | | | | | | | - By default the max number of threads now used for network io is the number of cpus available. - This can be overridden with the QPID_MAX_IOTHREADS environment variable or the config file - The client threads are initialised (via a singleton) when first used in a Connection::open() git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901550 13f79535-47bb-0310-9956-ffa450edef68
* Small refactor of AsynchConnector to have a more regular structureAndrew Stitcher2010-01-211-9/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901548 13f79535-47bb-0310-9956-ffa450edef68
* Split out AsynchConnecter::start from constructor (like other AsynchIO classes)Andrew Stitcher2010-01-215-24/+36
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901547 13f79535-47bb-0310-9956-ffa450edef68
* Made the getSSF() member functions of Connectors private as they can't be ↵Andrew Stitcher2010-01-213-3/+3
| | | | | | | | used from outside the connector anyway except via the virtual in the parent class. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901546 13f79535-47bb-0310-9956-ffa450edef68
* Log detailed error if unexpected socket write error (don't throw anymore)Andrew Stitcher2010-01-211-1/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901545 13f79535-47bb-0310-9956-ffa450edef68
* Fixed "Cluster-safe assertions" not to break the build (CMake)Andrew Stitcher2010-01-211-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901544 13f79535-47bb-0310-9956-ffa450edef68
* The commit contains fixes for QPID-2351, QPID-2350 and some ground work for ↵Rajith Muditha Attapattu2010-01-2113-93/+351
| | | | | | | | | | | | | | QPID-2352 - Modified Connection.java to add more than one ConnectionListener. This was done to facilitate the SASL encryption patch - QPID-2352. - Changed the access modifier for getSaslClient method to "public" to allow the SaslClient to be retrieved by the SASL encryption code -QPID-2352. - Introduced ConnectionSettings object to hold all the configuration options. Previous constructor methods remains unchanged. - Modified the ClientDelegate to handle heartbeat and idelTimeout value properly. - Added support to specify config options via the connection URL - QPID-2351 - Added support to handle the heartbeat/idle_timeout options properly in the 0-10 code - QPID-2350. However once QPID-2343 is completed, the code will be further simplified. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901506 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-2350Rajith Muditha Attapattu2010-01-201-0/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901448 13f79535-47bb-0310-9956-ffa450edef68
* only import the subprocess module when neededRafael H. Schloming2010-01-201-1/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901378 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2349 : Fixed Protocol Version negotiation. The Negotiated protocol ↵Martin Ritchie2010-01-206-8/+19
| | | | | | | | | version was not given to the ProtocolSession. Once this is done the correct delegate is enabled on connection. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901341 13f79535-47bb-0310-9956-ffa450edef68
* Cluster-safe assertions.Alan Conway2010-01-207-4/+147
| | | | | | | | | Assert that replicated data structures are modified in a cluster-safe context - in cluster delivery thread or during update. Assertions added to Queue.cpp and SemanticState.cpp. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901282 13f79535-47bb-0310-9956-ffa450edef68
* added java address parser (QPID-1831)Rafael H. Schloming2010-01-2011-0/+1239
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901268 13f79535-47bb-0310-9956-ffa450edef68
* fixed generics warnings; added join methodRafael H. Schloming2010-01-201-2/+24
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901267 13f79535-47bb-0310-9956-ffa450edef68
* modified address test suite to work against external address parserRafael H. Schloming2010-01-202-12/+110
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901257 13f79535-47bb-0310-9956-ffa450edef68
* Provide access to a sessions connection.Gordon Sim2010-01-204-0/+33
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901247 13f79535-47bb-0310-9956-ffa450edef68
* Added detailed instructions for running the individual examples. ↵Jonathan Robie2010-01-201-1/+272
| | | | | | Instructions are taken from the MRG Messaging Tutorial. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901241 13f79535-47bb-0310-9956-ffa450edef68
* QPID-664: added support for testing transactions to qpid-send and qpid-recv, ↵Gordon Sim2010-01-203-27/+62
| | | | | | fixed bug in rollback. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901153 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-2343Rajith Muditha Attapattu2010-01-192-2/+154
| | | | | | | | | I have added the basis for using a single config source for resolving property names. We could now add a set of new properties that follows the naming convention agreed on the list while providing support for old property names. Next step is to dig the code for all the properties and populate the correct tables in ClientProperties.java git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901002 13f79535-47bb-0310-9956-ffa450edef68
* Changed the setIdleTimeout method to take an int instead of a long.Rajith Muditha Attapattu2010-01-1912-25/+23
| | | | | | | | The socket interface takes the so_timeout as an int and also the AMQP heartbeat interval is taken as an int. This change will help simplify the code that handles heartbeats. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901000 13f79535-47bb-0310-9956-ffa450edef68
* fixed bug in destination/receiver correlationRafael H. Schloming2010-01-193-20/+51
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900967 13f79535-47bb-0310-9956-ffa450edef68
* added connection and session address to log statementsRafael H. Schloming2010-01-192-7/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900961 13f79535-47bb-0310-9956-ffa450edef68
* Added support for extended properties in the broker test frameworkKim van der Riet2010-01-191-10/+23
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900956 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2262 : Removed SALCT from from exclude list and added required null check.Martin Ritchie2010-01-192-13/+35
| | | | | | | Updated references to QPID-1204 to QPID-2345 which talks more to the issue of setting exception cause when the connection is closed by the broker. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900943 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1825 : Updated test to only start the 'clock' for timeout when the ↵Martin Ritchie2010-01-191-3/+14
| | | | | | message count on the queue hasn't changed after a 100ms sleep. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900919 13f79535-47bb-0310-9956-ffa450edef68
* Apply QPID_CLIENT_EXTERN where needed; should have been in with r900592. ↵Stephen D. Huston2010-01-191-8/+9
| | | | | | Fixes QPID-2344. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900880 13f79535-47bb-0310-9956-ffa450edef68
* Removed dead code - cluster::Connection::left()Alan Conway2010-01-192-9/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900860 13f79535-47bb-0310-9956-ffa450edef68
* Fix intermittent test error: cluster_test.cpp(1108): error in "testRelease": ↵Alan Conway2010-01-191-0/+1
| | | | | | | | | | | | | | | | check browse(c3, "q", 5) == expected failed [ != m_1 m_2 m_3 m_4 m_5 ] This was a test issue, not a broker issue. What seems to have been happening: - start broker b0 & send messages. - fork broker b1 - line 1103 (lqSub.release(...)); executes against b0 _before_ b1 connects for update lqSub.release(lqSub.getUnaccepted()); - line 1108 browse() executes during the update. - update takes > 0.5 secs for some reason, browse times out. The fix is a synchronous flush in browse() which will wait for the broker to be responsive before trying to get the messages. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900829 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2335: Set the timeout used when waiting for a message to be 1 second ↵Gordon Sim2010-01-191-1/+1
| | | | | | which I assume was the original intention. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900697 13f79535-47bb-0310-9956-ffa450edef68
* This is a first step towards QPID-2343Rajith Muditha Attapattu2010-01-187-7/+7
| | | | | | | | The common module also contains code for the client, and therefore contains configuration required for the client to be accessible from within the common module. Therefore the ClientProperties.java is best be placed inside the common module. The goal is to have a place holder for all configuration properties. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900595 13f79535-47bb-0310-9956-ffa450edef68
* Correct new uuid methods for Windows, add QPID_CLIENT_EXTERN where needed.Stephen D. Huston2010-01-182-2/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900592 13f79535-47bb-0310-9956-ffa450edef68
* Deleting vestigial header file.Jonathan Robie2010-01-181-37/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900506 13f79535-47bb-0310-9956-ffa450edef68
* Commiting John Dunning's revisions to the XML client session test.Jonathan Robie2010-01-181-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900488 13f79535-47bb-0310-9956-ffa450edef68
* Applied John Dunning's patch from ↵Jonathan Robie2010-01-182-4/+8
| | | | | | | | | | https://issues.apache.org/jira/browse/QPID-2335. Allows management tools to report the query for a binding. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900475 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2295: Clustered + persistent broker crashes with inconsistency error.Alan Conway2010-01-184-30/+1
| | | | | | | | | | Code running in the store's timer thread was causing inconsistent changes in message allocation. This code is out-of-date, we no longer need to notify the Queue when persistent storage completes as the message is already available on the queue. Removed the out-dated code. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900448 13f79535-47bb-0310-9956-ffa450edef68
* Alter type of array index variableGordon Sim2010-01-181-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900332 13f79535-47bb-0310-9956-ffa450edef68
* Rebalancing document structure. AMQP compatibility and SASL interoperability ↵Jonathan Robie2010-01-157-21/+428
| | | | | | added. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@899843 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2137 : Update QpidTestCase to set QPID_WORK on the external broker ↵Martin Ritchie2010-01-153-5/+8
| | | | | | based on the port of the running broker. This allows multiple brokers to be started by QTC with a given QPID_WORK value. Removed manual changing of QPID_WORK in FailoverBaseCase as there was no way to know what that value was later. All calls to startBroker in QTC will correctly append the port to the given QPID_WORK value. AcknowledgeOnMessageTest was updated to provide some extra debugging to help aid later investigation of why messages are not recieved after failover. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@899797 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1662 : Added logged to TimeToLiveTest. This showed that the second ↵Martin Ritchie2010-01-151-2/+8
| | | | | | | | | | message was not recieved and so the third was non-null and caused the test failure. Adjusting the timeout for msgs 1 and 2 to 5s helped ensure that they were correctly received. I've left the logging in so that we can see what the results of the three receives were even if it fails on one of the asserts. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@899782 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2323: add a Uuid type and allow it as the value of a Variant.Gordon Sim2010-01-1516-19/+363
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@899657 13f79535-47bb-0310-9956-ffa450edef68
* Removed dead code: OutputTask::hasOutput and Queue::checkForMessages.Alan Conway2010-01-1411-56/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@899356 13f79535-47bb-0310-9956-ffa450edef68
* Added images to JMX Console User's Guide.Jonathan Robie2010-01-1429-22/+22
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@899335 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2340 : Fix ProducerFlowControlTest to call a synchronous operation ↵Robert Godfrey2010-01-141-0/+4
| | | | | | between sends (merged from 0.5-dev) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@899301 13f79535-47bb-0310-9956-ffa450edef68
* The next batch of converted documentation ...Jonathan Robie2010-01-1426-130/+5198
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@899299 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2340 : Fix ProducerFlowControlTest to call a synchronous operation ↵Robert Godfrey2010-01-144-5/+19
| | | | | | between sends (merged from 0.5-dev) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@899296 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2137 : Add a test that creates log messages simultaneously in multiple ↵Martin Ritchie2010-01-131-3/+101
| | | | | | threads to validate the previous change. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@898953 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2137 : Update ot LogMessages velocity macro to create a new ↵Martin Ritchie2010-01-131-21/+16
| | | | | | MessageFormat for each log message as re-using a static formatter is not thread safe. The gap between applyPattern() and format() gives another thread the chance to change the pattern. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@898821 13f79535-47bb-0310-9956-ffa450edef68
* Added raise_event support to the Ruby and Python wrapped agent APIs.Ted Ross2010-01-1316-21/+509
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@898727 13f79535-47bb-0310-9956-ffa450edef68
* Added a null check for SASL client in the connectionOpenOk methodRajith Muditha Attapattu2010-01-131-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@898634 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status