summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker
Commit message (Collapse)AuthorAgeFilesLines
* Correction for: start a broker in cluster, send messages that are flow to ↵Carl C. Trieloff2009-01-302-18/+28
| | | | | | disk, then join a broker to the cluster. Then consume from the new node. Cotent released messages where loosing content. This patch corrects that. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@739378 13f79535-47bb-0310-9956-ffa450edef68
* Better error messages for not-attached exceptions.Alan Conway2009-01-291-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@739031 13f79535-47bb-0310-9956-ffa450edef68
* Producer side rate throttling:Andrew Stitcher2009-01-275-20/+201
| | | | | | | | | This uses the Message.Flow command to send credit from broker to client to ensure that the client doesn't exceed a rate configured on the broker per session. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@738247 13f79535-47bb-0310-9956-ffa450edef68
* Cluster rename: dump -> update, newbie -> joinerAlan Conway2009-01-271-4/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@737971 13f79535-47bb-0310-9956-ffa450edef68
* Some minor updates to logging levels to avoid undue alarm.Gordon Sim2009-01-262-1/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@737679 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1611 patch from mickCarl C. Trieloff2009-01-253-6/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@737460 13f79535-47bb-0310-9956-ffa450edef68
* Use special management ids for objects used in state transfer to new ↵Gordon Sim2009-01-236-26/+41
| | | | | | | | | members. This prevents the ids getting out of sync across the cluster and allows management methods to be used reliably. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@737203 13f79535-47bb-0310-9956-ffa450edef68
* Catch up on recent file additions/removals; fix compile errors on WindowsStephen D. Huston2009-01-232-4/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@737201 13f79535-47bb-0310-9956-ffa450edef68
* Reverted checkin r.736814 as it breaks the store recover.Kim van der Riet2009-01-231-7/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@737091 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1567: More changes to make clustering and federation work togetherGordon Sim2009-01-226-3/+58
| | | | | | | | | | | * replicate outgoing link traffic to all nodes * coordinate amongst nodes so that only one node actually maintains active links with the others able to take over if that node fails git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736841 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1611: Patch from Mick Goulish to ensure queues are created in store in ↵Gordon Sim2009-01-221-0/+7
| | | | | | cluster configuration git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736814 13f79535-47bb-0310-9956-ffa450edef68
* Removed BodyHolder: minor performance improvement, opens the way for more ↵Alan Conway2009-01-224-8/+5
| | | | | | efficient memory management. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736783 13f79535-47bb-0310-9956-ffa450edef68
* Re-issue 736381 with a literal.Ted Ross2009-01-211-4/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736394 13f79535-47bb-0310-9956-ffa450edef68
* Moved minimum frameMax constant into publicTed Ross2009-01-211-3/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736381 13f79535-47bb-0310-9956-ffa450edef68
* Enforce a minimum frame-max to avoid really bad things that can happenTed Ross2009-01-211-3/+4
| | | | | | | if frame-max is set to zero. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736370 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1567: Added ability for federation links to failover to other specified ↵Gordon Sim2009-01-2110-9/+227
| | | | | | known-hosts git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736354 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1567: added 'exactly-once' guarantee to asynchronous replication of ↵Gordon Sim2009-01-2011-38/+73
| | | | | | | | | | | | queue state * altered replication protocol to detect and eliminate duplicates * added support for acknowledged transfer over inter-broker bridges * added option to qpid-route to control this git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736018 13f79535-47bb-0310-9956-ffa450edef68
* Fix tests broken by r735776: check payload pointer before use. Gordon Sim2009-01-201-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@735988 13f79535-47bb-0310-9956-ffa450edef68
* Put messages into LVQ FIFO if no key is specified.Carl C. Trieloff2009-01-191-7/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@735776 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1567: clean shutdown of event queueGordon Sim2009-01-161-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@735054 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1567: Initial support for asynchronous queue state replicationGordon Sim2009-01-157-4/+221
| | | | | | | | | | | | | | | * Added QueueEvents class with per broker instance * Modified qpid::broker::Queue to notify QueueEvents of enqueues and dequeues (based on configuration) * Added replication subdir containing two plugins: - an event listener that registers with QueueEvents and creates messages representing received events on a replication queue - a custom exchange type for processing messages of the format created by the listener plugin * Added new option for controlling event generation to qpid::client::QueueOptions * Added new queue option to qpid-config script for the same git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734674 13f79535-47bb-0310-9956-ffa450edef68
* Minor formatting fixes and typo correction.Gordon Sim2009-01-152-6/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734668 13f79535-47bb-0310-9956-ffa450edef68
* Send heartbeat from broker to clientAndrew Stitcher2009-01-136-7/+69
| | | | | | | | - Server sends possible heartbeat range and client replies with desired heartbeat as part of the tune-tuneOk exchange git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734220 13f79535-47bb-0310-9956-ffa450edef68
* Start to fix Timer to improve encapsulation and then fixAndrew Stitcher2009-01-134-3/+12
| | | | | | | | its inbuilt race conditions (mostly due to the awkward interface of Timer and TimerTask) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734213 13f79535-47bb-0310-9956-ffa450edef68
* Tidied up a number of TODO itemsAndrew Stitcher2009-01-081-2/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@732620 13f79535-47bb-0310-9956-ffa450edef68
* Ensure that if no store is loaded we don't flow to disk, but revert to ↵Gordon Sim2009-01-073-4/+21
| | | | | | rejecting messages. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@732482 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1560: add support for a qpid.exclusive-binding option on direct ↵Gordon Sim2009-01-071-3/+14
| | | | | | exchange that causes the binding specified to be the only one for the given key. I.e. if there is already a binding at this exchange with this key it will be atomically updated to bind the new queue. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@732297 13f79535-47bb-0310-9956-ffa450edef68
* Fix for windows build: add implementations of the getSecurityLayer()Gordon Sim2009-01-071-0/+15
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@732292 13f79535-47bb-0310-9956-ffa450edef68
* * Cyrus SASL intgeration for c++ clientGordon Sim2009-01-0611-9/+347
| | | | | | | | * SASL security layer support for c++ client and broker git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@732082 13f79535-47bb-0310-9956-ffa450edef68
* Minor logging fixes.Alan Conway2009-01-051-45/+55
| | | | | | | | cpp/src/tests/BrokerFixture.h: make tests quiet, log with error+ qpid/broker/Daemon.cpp: print to stderr in parent process if child fails. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@731739 13f79535-47bb-0310-9956-ffa450edef68
* Sorry! Carelessly committed more than I wanted to. Reverting part of my ↵Gordon Sim2009-01-051-14/+3
| | | | | | previous commit. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@731717 13f79535-47bb-0310-9956-ffa450edef68
* Reduce log level from warning to info as (a) its not necessarily a bad thing ↵Gordon Sim2009-01-051-4/+16
| | | | | | at all and (b) the default logging level is now at notice+ git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@731710 13f79535-47bb-0310-9956-ffa450edef68
* Log changes: logging default now notice+, "listening on" messages are at ↵Alan Conway2009-01-051-1/+1
| | | | | | notice level. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@731649 13f79535-47bb-0310-9956-ffa450edef68
* stats correction pointed out by gordonCarl C. Trieloff2009-01-031-4/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@730890 13f79535-47bb-0310-9956-ffa450edef68
* - browse correction, to update replacement message on browseCarl C. Trieloff2008-12-301-0/+8
| | | | | | | | - correct stats for lvq messages git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@730031 13f79535-47bb-0310-9956-ffa450edef68
* options name re-name to be more explicit & better testCarl C. Trieloff2008-12-172-9/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@727517 13f79535-47bb-0310-9956-ffa450edef68
* LVQ browse policy updateCarl C. Trieloff2008-12-161-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@727184 13f79535-47bb-0310-9956-ffa450edef68
* LVQ queue option for no acquireCarl C. Trieloff2008-12-162-1/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@727166 13f79535-47bb-0310-9956-ffa450edef68
* Fix unused arg warnings from MSVCStephen D. Huston2008-12-101-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@725488 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1526: add checks for exclusive ownership plus tests to verify they are ↵Gordon Sim2008-12-102-4/+10
| | | | | | executed git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@725483 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1449 - Added federation tag that was missing when management was disabledTed Ross2008-12-101-0/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@725456 13f79535-47bb-0310-9956-ffa450edef68
* OutputControl and subclasses: added giveReadCredit() for IO level flow control.Alan Conway2008-12-082-0/+6
| | | | | | | Cluster: Set read credit limit for cluster connections. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@724233 13f79535-47bb-0310-9956-ffa450edef68
* Cluster: handle CPG flow-control conditions.Alan Conway2008-12-021-0/+2
| | | | | | | PollableQueue: allow dispatch functions to refuse dispatch. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@722614 13f79535-47bb-0310-9956-ffa450edef68
* Added management accounting for transaction dequeues.Ted Ross2008-12-021-0/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@722446 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1497: Ensure policy count and size reflect transactionality of dequeuesGordon Sim2008-12-018-10/+26
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@722200 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1495: Patch from Danushka Menikkumbura to fix compilation problem.Gordon Sim2008-12-011-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@722037 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1280: fixed performance regression for multiple subscribers on shared queueGordon Sim2008-11-294-27/+167
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@721685 13f79535-47bb-0310-9956-ffa450edef68
* Backed out last change; not sure it actually makes sense.Gordon Sim2008-11-272-12/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@721258 13f79535-47bb-0310-9956-ffa450edef68
* Ensure broker doesn't hang waiting for async enqueue to complete on shutdown.Gordon Sim2008-11-272-2/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@721256 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1264: fix for topic exchange (patch from astitcher@redhat.com)Gordon Sim2008-11-271-4/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@721243 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status