summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker
Commit message (Collapse)AuthorAgeFilesLines
* Clean up logging a bit: only warn once, not for every connectionGordon Sim2008-11-251-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@720538 13f79535-47bb-0310-9956-ffa450edef68
* Reduce logging noise from NullMessageStore: log "persistence disabled" once ↵Alan Conway2008-11-243-39/+14
| | | | | | at start up, not on every action. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@720243 13f79535-47bb-0310-9956-ffa450edef68
* Replace lower_bound with equivalent loop; resolves QPID-1424Stephen D. Huston2008-11-191-3/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@719133 13f79535-47bb-0310-9956-ffa450edef68
* Ensure that callbacks are removed before IncompleteMessageList instance is ↵Gordon Sim2008-11-195-1/+11
| | | | | | | | | | deleted. (also removed commented out line of code from Queue.cpp) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@719012 13f79535-47bb-0310-9956-ffa450edef68
* Remove optimistic consume options. Better default message for SSL errors.Alan Conway2008-11-171-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@718277 13f79535-47bb-0310-9956-ffa450edef68
* Avoid alarming error message when unencrypted tcp is disabled. Test ↵Gordon Sim2008-11-141-5/+4
| | | | | | availability of tcp transport rather than catching exception if its not enabled. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@714099 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1461 - Added qmf event support for connections.Ted Ross2008-11-137-14/+84
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@713838 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1414: fix to prevent concurrent modification of brokers known url listGordon Sim2008-11-131-7/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@713714 13f79535-47bb-0310-9956-ffa450edef68
* Removed optimisticConsume queue option, queues always consume optimistically.Alan Conway2008-11-121-11/+0
| | | | | | | There's no benefit to non-optimistic consume. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@713521 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1457: Removed erroneous signal settingsAndrew Stitcher2008-11-121-3/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@713466 13f79535-47bb-0310-9956-ffa450edef68
* Cluster replicates queues/exchanges with same encode/decode functions as the ↵Alan Conway2008-11-121-3/+8
| | | | | | | | | store. Removed un-necessary heap allocation in QPID_LOG statements. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@713425 13f79535-47bb-0310-9956-ffa450edef68
* Include DeliveryRecord::credit in replication to new members.Alan Conway2008-11-112-3/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@713171 13f79535-47bb-0310-9956-ffa450edef68
* Fix deadlock when Message::flush() re-enters IncompleteMessageList.Alan Conway2008-11-111-2/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@713165 13f79535-47bb-0310-9956-ffa450edef68
* Fixed a violation of the lock hierarchy in LinkRegistry and LinkTed Ross2008-11-111-24/+25
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@713161 13f79535-47bb-0310-9956-ffa450edef68
* broker/Message, IncompleteMessageList: drop waitFor(De|En)Complete, replace ↵Alan Conway2008-11-076-45/+53
| | | | | | with callbacks. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@712258 13f79535-47bb-0310-9956-ffa450edef68
* Add Message callbacks for async completion.Alan Conway2008-11-069-33/+68
| | | | | | | | Add unit test for async completion. Add sync parameter to generated session functions, defaults as before but allows greater control. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@711998 13f79535-47bb-0310-9956-ffa450edef68
* Restrict connection close codes to the set defined in the specGordon Sim2008-11-068-26/+23
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@711989 13f79535-47bb-0310-9956-ffa450edef68
* Removed the --enforce-acl option. Instead if a policy file is specified acl ↵Rajith Muditha Attapattu2008-11-061-12/+2
| | | | | | | | | will be enabled. Also removed Route from the Object list and did a bit of code cleanup. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@711957 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1413: disable output before sending detachGordon Sim2008-11-064-2/+15
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@711931 13f79535-47bb-0310-9956-ffa450edef68
* 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/qpid@711915 13f79535-47bb-0310-9956-ffa450edef68
* Remove unused class broker::IncomingExecutionContext.Alan Conway2008-11-062-204/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@711890 13f79535-47bb-0310-9956-ffa450edef68
* Non fucntional changesCarl C. Trieloff2008-11-062-5/+4
| | | | | | | | | - 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/qpid@711884 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1417: ensure there are no dangling pointers in a connections output tasksGordon Sim2008-11-061-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@711855 13f79535-47bb-0310-9956-ffa450edef68
* Added ability to release messages through the Subscription class (+test)Gordon Sim2008-11-053-4/+18
| | | | | | | | | | 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/qpid@711698 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/qpid@711603 13f79535-47bb-0310-9956-ffa450edef68
* Cluster: replicate transaction state to newcomers.Alan Conway2008-11-0512-10/+145
| | | | | | | | | | | | | 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/qpid@711587 13f79535-47bb-0310-9956-ffa450edef68
* constants.rb: generate type code constants for AMQP types. Useful with Array.Alan Conway2008-11-041-4/+1
| | | | | | | | | 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/qpid@711365 13f79535-47bb-0310-9956-ffa450edef68
* correction for Active-Active clustering, allowing late joining nodes in the ↵Carl C. Trieloff2008-11-032-3/+7
| | | | | | cluster to sync counter values for sequenced messages git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@710157 13f79535-47bb-0310-9956-ffa450edef68
* Federation enhancements and bug fixes:Ted Ross2008-10-311-1/+4
| | | | | | | | | | 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/qpid@709532 13f79535-47bb-0310-9956-ffa450edef68
* Added return Message overload of SubscriptionManager get().Alan Conway2008-10-311-1/+3
| | | | | | | Fixed compile error in broker/Vhost.cpp git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@709440 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/qpid@709342 13f79535-47bb-0310-9956-ffa450edef68
* Fix namespace reference usage to work on WindowsStephen D. Huston2008-10-301-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@709286 13f79535-47bb-0310-9956-ffa450edef68
* Adjust ACL-related enums to avoid Windows macro clashes; fixes QPID-1368Stephen D. Huston2008-10-303-98/+100
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@709283 13f79535-47bb-0310-9956-ffa450edef68
* Resolved unused argument warnings from MSVCStephen D. Huston2008-10-303-33/+33
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@709282 13f79535-47bb-0310-9956-ffa450edef68
* Adjust namespace references to work with MSVCStephen D. Huston2008-10-308-19/+26
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@709281 13f79535-47bb-0310-9956-ffa450edef68
* Consistently refer to struct as struct, not classStephen D. Huston2008-10-301-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@709280 13f79535-47bb-0310-9956-ffa450edef68
* Removed unneeded and nonportable include config.hStephen D. Huston2008-10-301-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@709274 13f79535-47bb-0310-9956-ffa450edef68
* Add Windows pieces for building the broker; resolves QPID-1338Stephen D. Huston2008-10-301-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@709271 13f79535-47bb-0310-9956-ffa450edef68
* Replicate session state for un-acknowledged messages to new cluster members.Alan Conway2008-10-303-18/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@709242 13f79535-47bb-0310-9956-ffa450edef68
* Use new wrapped get() accessor in AddressStephen D. Huston2008-10-241-2/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707766 13f79535-47bb-0310-9956-ffa450edef68
* Added exchange options to qpid-configTed Ross2008-10-241-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707651 13f79535-47bb-0310-9956-ffa450edef68
* Revised transactional options to perftest as they could not be used on older ↵Gordon Sim2008-10-245-40/+107
| | | | | | | | | | boost versions due to ambiguity. Refactored TxAccept to avoid excessive testing and searching for delivery records. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707615 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1348 - Dynamic binding for federation. Parameterized exchange names ↵Ted Ross2008-10-2411-89/+430
| | | | | | for CPP examples git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707515 13f79535-47bb-0310-9956-ffa450edef68
* Some fixes to the LVQ (primarily a patch from cctrieloff@redhat.com)Gordon Sim2008-10-234-27/+79
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707446 13f79535-47bb-0310-9956-ffa450edef68
* don't append realm in null authenticator if the userid as supplied already ↵Gordon Sim2008-10-231-1/+5
| | | | | | ends with it git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707427 13f79535-47bb-0310-9956-ffa450edef68
* Minor changes to provide access for cluster to replicate delivery records.Alan Conway2008-10-236-20/+74
| | | | | | | | | - broker::Queue: find message by position, set position. - broker::SemanticState: make record() public, add eachUnacked(), fix typo "NotifyEnabld" - broker::DeliveryRecord: added more public accessors git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707406 13f79535-47bb-0310-9956-ffa450edef68
* More complete fix to prevention of divide by zero when the sampling rate is ↵Gordon Sim2008-10-231-1/+1
| | | | | | more frequent than once per second. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707311 13f79535-47bb-0310-9956-ffa450edef68
* Fixed to avoid division by zero when sampling more frequently than once per ↵Gordon Sim2008-10-231-1/+4
| | | | | | second. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707308 13f79535-47bb-0310-9956-ffa450edef68
* Refactored DeliveryRecord and delivery path to remove some redundant code.Gordon Sim2008-10-2111-268/+75
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@706811 13f79535-47bb-0310-9956-ffa450edef68
* Qualify userid with realm when authentication is turned offGordon Sim2008-10-211-2/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@706806 13f79535-47bb-0310-9956-ffa450edef68