summaryrefslogtreecommitdiff
path: root/qpid
Commit message (Collapse)AuthorAgeFilesLines
* Correct excessive use of inline functions in PersistableMessage.h.Alan Conway2008-11-062-98/+133
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711915 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1437 - Fixed qmf agent shutdownTed Ross2008-11-062-7/+49
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711913 13f79535-47bb-0310-9956-ffa450edef68
* * fix bug causing last message to occasionally be lost on replayGordon Sim2008-11-064-5/+40
| | | | | | | | | * make presence of gaps an error condition in the resuming_receiver example * add ability to apply functor to replay buffer git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711903 13f79535-47bb-0310-9956-ffa450edef68
* Remove unused class broker::IncomingExecutionContext.Alan Conway2008-11-063-206/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711890 13f79535-47bb-0310-9956-ffa450edef68
* Non fucntional changesCarl C. Trieloff2008-11-064-16/+15
| | | | | | | | | - move sequence count to args, so only store if set - correct const-ness in fieldtable git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711884 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1417: ensure there are no dangling pointers in a connections output tasksGordon Sim2008-11-063-0/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711855 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1434 : Changed rethrow() name based on feedback from RobMartin Ritchie2008-11-063-46/+23
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711848 13f79535-47bb-0310-9956-ffa450edef68
* SubscriptionManager and Dispatcher were missing wait() methods meaning that ↵Gordon Sim2008-11-065-2/+18
| | | | | | if start was called there was no way to join with the dispatch thread and shutdown cleanly. Fixed by adding that method. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711838 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1431 : Prevent listeners being added to _frameListeners when an ↵Martin Ritchie2008-11-064-13/+739
| | | | | | exception state has occured due to connection closure. This adds additional synchronisation to the error handling condition. It also removes the need for a CopyOnWriteArrayList that was perhaps the wrong data structure for this list. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711822 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1434 : Add ability to rethrow AMQExceptionsMartin Ritchie2008-11-061-0/+128
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711820 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1434 : Add ability to rethrow AMQExceptionsMartin Ritchie2008-11-061-0/+30
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711818 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1326Rajith Muditha Attapattu2008-11-051-0/+4
| | | | | | | | If a transport is specified and if "//" is missing from the URL, an error will be thrown. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711740 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1294 (Johnathan Robie) Improved doxygen generation. Files missed in ↵Alan Conway2008-11-057-0/+1298
| | | | | | previous commit. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711708 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1294 (Johnathan Robie) Improved doxygen generation.Alan Conway2008-11-056-2/+210
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711702 13f79535-47bb-0310-9956-ffa450edef68
* Added ability to release messages through the Subscription class (+test)Gordon Sim2008-11-0514-19/+190
| | | | | | | | | | Added another mode for managing completion (+test) Fixed regression where bytes credit was not reallocated in windowing mode after an accept/release Fixed regression where subscribe request is issued before listener is registered with dispatcher git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711698 13f79535-47bb-0310-9956-ffa450edef68
* Fix error in run_test.Alan Conway2008-11-051-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711658 13f79535-47bb-0310-9956-ffa450edef68
* Add new source filesStephen D. Huston2008-11-053-24/+45
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711631 13f79535-47bb-0310-9956-ffa450edef68
* Added support for push-routes and queue-based routes.Ted Ross2008-11-051-112/+182
| | | | | | | Cleaned up the code a bit. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711628 13f79535-47bb-0310-9956-ffa450edef68
* Disable SIGPIPE for client as well as brokerGordon Sim2008-11-051-8/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711624 13f79535-47bb-0310-9956-ffa450edef68
* Cluster: clean up connections when a member leaves the cluster.Alan Conway2008-11-056-4/+28
| | | | | | | Fixed a memory error in cluster_test and some reporting errors in test scripts. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711623 13f79535-47bb-0310-9956-ffa450edef68
* Add missing IntegerTypes.h include; fixes QPID-1436Stephen D. Huston2008-11-051-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711609 13f79535-47bb-0310-9956-ffa450edef68
* No need to decalre TxOpConstVisitor - it's defined in TxOpVisitor.h; ↵Stephen D. Huston2008-11-051-2/+0
| | | | | | resolves QPID-1435 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711603 13f79535-47bb-0310-9956-ffa450edef68
* Cluster: replicate transaction state to newcomers.Alan Conway2008-11-0523-76/+311
| | | | | | | | | | | | | constants.rb: generate type code constants for AMQP types. Useful with Array. framing/Array: - added some std:::vector like functions & typedefs. - use TypeCode enums, human readable ostream << operator. rubygen - fixed error in generation of exceptions for bad codes. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711587 13f79535-47bb-0310-9956-ffa450edef68
* fixed compilation warnings from comparison of signed and unsigned intsGordon Sim2008-11-051-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711540 13f79535-47bb-0310-9956-ffa450edef68
* Added bank numbers to the routing key of a QMF heartbeat message.Ted Ross2008-11-043-8/+25
| | | | | | | | This is used by the console to identify which agent sent the indication. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711458 13f79535-47bb-0310-9956-ffa450edef68
* This check in is related to QPID-1296Rajith Muditha Attapattu2008-11-045-52/+469
| | | | | | | | | Since SSLSocket didn't support shutdownInput method, I added an SSL layer on top of the TCP transport. The SSL layer uses the SSLEngine class introduced in java 1.5. This Layer can be used with minimum code changes to the the nio transport as well. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711455 13f79535-47bb-0310-9956-ffa450edef68
* Clarified broker/agent banks in method names. Added new accessor methods ↵Ted Ross2008-11-041-5/+11
| | | | | | for bank values git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711384 13f79535-47bb-0310-9956-ffa450edef68
* renamed suite to avoid collision for newer versions of boostGordon Sim2008-11-041-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711379 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1430: fixed an NPE on connection closeRafael H. Schloming2008-11-041-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711377 13f79535-47bb-0310-9956-ffa450edef68
* Fixed usage text for qpid-toolTed Ross2008-11-041-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711367 13f79535-47bb-0310-9956-ffa450edef68
* constants.rb: generate type code constants for AMQP types. Useful with Array.Alan Conway2008-11-0414-87/+267
| | | | | | | | | framing/Array: - added some std:::vector like functions & typedefs. - use TypeCode enums, human readable ostream << operator. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711365 13f79535-47bb-0310-9956-ffa450edef68
* Added unit test for replay utility class.Gordon Sim2008-11-042-1/+81
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711328 13f79535-47bb-0310-9956-ffa450edef68
* Allow local broker to be run in any position in a ClusterFixture.Alan Conway2008-11-041-84/+77
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711283 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1429Martin Ritchie2008-11-041-13/+11
| | | | | | | Removed the dependency check and removed full path from commands. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711261 13f79535-47bb-0310-9956-ffa450edef68
* Adding a couple of utilities (don't alter any existing functionality) that ↵Gordon Sim2008-11-048-6/+554
| | | | | | | | | | are useful in applications handling failover. Added example of their use that I've been using in testing. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711256 13f79535-47bb-0310-9956-ffa450edef68
* Correct signature of usleep() methodStephen D. Huston2008-11-031-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@710216 13f79535-47bb-0310-9956-ffa450edef68
* Add missing source filesStephen D. Huston2008-11-031-0/+15
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@710188 13f79535-47bb-0310-9956-ffa450edef68
* correction for Active-Active clustering, allowing late joining nodes in the ↵Carl C. Trieloff2008-11-033-40/+61
| | | | | | cluster to sync counter values for sequenced messages git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@710157 13f79535-47bb-0310-9956-ffa450edef68
* This line seems not to be as redundant as I thought! Its removal seems to ↵Gordon Sim2008-11-031-0/+1
| | | | | | trigger some leaks for some platforms/cases. Adding it back for now. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@710124 13f79535-47bb-0310-9956-ffa450edef68
* Various fixes arising from testing client failover:Gordon Sim2008-11-0310-24/+52
| | | | | | | | | | | | | | | | | | | | * introduced new exception type for signalling connection failure (as distinct from any logical connection errors) * ConnectionImpl::closeInternal(): take copy of session map to prevent concurrent modification (by the same thread) as sessions are deleted and erase themselves. * ConnectionImpl::shutdown: hold lock before calling closeInternal(); mark handler failed before informing sessions of failure * SessionImpl::connectionBroker(): remove code as its rather meaningless * Don't swallow exceptions in Dispatcher * Handle exceptions in FailoverListener * Take weak_ptr to ConnectionImpl on constructor of Connector, then convert to shared_ptr when 'receiver' thread is started. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@710106 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1384: Changed for storing UTF8 Strings in filesArnaud Simon2008-11-033-4/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@710075 13f79535-47bb-0310-9956-ffa450edef68
* Get initial Windows options in; event log doesn't yet workStephen D. Huston2008-10-312-9/+43
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709544 13f79535-47bb-0310-9956-ffa450edef68
* Federation enhancements and bug fixes:Ted Ross2008-10-313-5/+114
| | | | | | | | | | qmfconsole.py - minor fixes, make sure object-dereference only queries one broker Bridge.cpp - Added channel-id to queue name to avoid collisions qpid-route - Added link-map feature for viewing the entire federated topology git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709532 13f79535-47bb-0310-9956-ffa450edef68
* Cluster returns connection exception for un-supported AMQP features.Alan Conway2008-10-313-4/+40
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709474 13f79535-47bb-0310-9956-ffa450edef68
* Added return Message overload of SubscriptionManager get().Alan Conway2008-10-315-10/+24
| | | | | | | Fixed compile error in broker/Vhost.cpp git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709440 13f79535-47bb-0310-9956-ffa450edef68
* Fix intermittent hanging where two threads are waiting for completions on ↵Gordon Sim2008-10-311-1/+1
| | | | | | the same session. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709429 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1411: Applied Andrea's patch; added config file sample Arnaud Simon2008-10-3141-983/+819
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709374 13f79535-47bb-0310-9956-ffa450edef68
* qpid-1422: renamed qmanServlet.war into qman.warArnaud Simon2008-10-311-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709371 13f79535-47bb-0310-9956-ffa450edef68
* Federation bug-fixes:Ted Ross2008-10-314-12/+22
| | | | | | | | | | | | | | 1) Locking was added to protect the exchange's vector of bridges. 2) Bridges are now properly torn down when a link is lost. 3) Auto-tracing was improperly assigning tags to federation queues. Also, the federation queue name now uses the broker-id for the destination broker. This makes it easier to determine which queues go to which brokers. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709342 13f79535-47bb-0310-9956-ffa450edef68
* Fixed a problem with improper shutdown that occasionally caused unhandled ↵Ted Ross2008-10-311-0/+1
| | | | | | exceptions git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709337 13f79535-47bb-0310-9956-ffa450edef68