summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client
Commit message (Collapse)AuthorAgeFilesLines
* Add in management statistics for client flow control.Andrew Stitcher2009-02-032-11/+6
| | | | | | | Really fixed Client library to count credit the same way the broker does. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@740433 13f79535-47bb-0310-9956-ffa450edef68
* Send client property indicating that client supportsAndrew Stitcher2009-02-021-0/+4
| | | | | | | | | producer throttling in the Connection.OpenOK message. Broker only tries to apply flow control to client if it has received the property in the Connection.OpenOK message. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@740135 13f79535-47bb-0310-9956-ffa450edef68
* Correction for: start a broker in cluster, send messages that are flow to ↵Carl C. Trieloff2009-01-304-1/+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
* Producer side rate throttling:Andrew Stitcher2009-01-272-14/+107
| | | | | | | | | 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
* Some minor updates to logging levels to avoid undue alarm.Gordon Sim2009-01-261-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@737679 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1613: Ensure that the rule registered with the demuxer for LocalQueue ↵Gordon Sim2009-01-234-4/+35
| | | | | | subscriptions is removed when they are cancelled. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@737028 13f79535-47bb-0310-9956-ffa450edef68
* Removed BodyHolder: minor performance improvement, opens the way for more ↵Alan Conway2009-01-222-3/+3
| | | | | | efficient memory management. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736783 13f79535-47bb-0310-9956-ffa450edef68
* Minor typo fixesTed Ross2009-01-151-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734685 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1567: Initial support for asynchronous queue state replicationGordon Sim2009-01-152-1/+16
| | | | | | | | | | | | | | | * 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-151-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734668 13f79535-47bb-0310-9956-ffa450edef68
* Implement heartbeat timeout on client:Andrew Stitcher2009-01-139-20/+83
| | | | | | | | - The client shuts down a connection if it receives no traffic on it in 2 timeout periods git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734221 13f79535-47bb-0310-9956-ffa450edef68
* Send heartbeat from broker to clientAndrew Stitcher2009-01-132-2/+16
| | | | | | | | - 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
* QPID-976: Prompt for password if it is required and not specified through ↵Gordon Sim2009-01-081-7/+21
| | | | | | settings. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@732702 13f79535-47bb-0310-9956-ffa450edef68
* QPID-976: Patch from Ted Ross (tross@redhat.com). Remove the handling of ↵Gordon Sim2009-01-081-28/+1
| | | | | | empty usernames and leaves that up to the SASL library. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@732691 13f79535-47bb-0310-9956-ffa450edef68
* Tidied up a number of TODO itemsAndrew Stitcher2009-01-082-4/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@732620 13f79535-47bb-0310-9956-ffa450edef68
* Adapt to recent changes/additionsStephen D. Huston2009-01-071-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@732551 13f79535-47bb-0310-9956-ffa450edef68
* * Cyrus SASL intgeration for c++ clientGordon Sim2009-01-0611-220/+709
| | | | | | | | * 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
* options name re-name to be more explicit & better testCarl C. Trieloff2008-12-172-5/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@727517 13f79535-47bb-0310-9956-ffa450edef68
* LVQ queue option for no acquireCarl C. Trieloff2008-12-162-2/+6
| | | | 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-102-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@725488 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1527: Added exclusive option to SubscriptionSettings and accompanying test.Gordon Sim2008-12-102-2/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@725484 13f79535-47bb-0310-9956-ffa450edef68
* OutputControl and subclasses: added giveReadCredit() for IO level flow control.Alan Conway2008-12-081-2/+3
| | | | | | | 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
* Corrected doxygen comment.Alan Conway2008-12-031-3/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@722923 13f79535-47bb-0310-9956-ffa450edef68
* Avoid potential deadlock between IO thread in Connector::handleClosed() and ↵Gordon Sim2008-12-021-1/+4
| | | | | | application thread in ConnectionImpl::closed() git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@722554 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1478: Same fix is required in SslConnector unfortunately.Gordon Sim2008-11-241-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@720271 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1478: ensure concurrent publishers work correctly (as well as reported ↵Gordon Sim2008-11-243-4/+5
| | | | | | assertion, the test uncovered a potential deadlock due to bounds being expanded before frames were added to queue). git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@720251 13f79535-47bb-0310-9956-ffa450edef68
* Avoid spurious error message for TransportFailureGordon Sim2008-11-241-0/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@720178 13f79535-47bb-0310-9956-ffa450edef68
* Removed overblown Doxygen comments.Jonathan Robie2008-11-191-25/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@718937 13f79535-47bb-0310-9956-ffa450edef68
* Added doxygen documentation for Connection::open(ConnectionSettings)Jonathan Robie2008-11-181-2/+27
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@718718 13f79535-47bb-0310-9956-ffa450edef68
* Remove optimistic consume options. Better default message for SSL errors.Alan Conway2008-11-172-23/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@718277 13f79535-47bb-0310-9956-ffa450edef68
* Added some failover capable testsGordon Sim2008-11-145-12/+18
| | | | | | | | Added grantCredit() method to subscription to allow simpler control of message delivery git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@714065 13f79535-47bb-0310-9956-ffa450edef68
* Don't stop connector until close has been sent and close-ok received in ↵Gordon Sim2008-11-131-2/+5
| | | | | | response. (If necessary delay error notification until then). git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@713739 13f79535-47bb-0310-9956-ffa450edef68
* Fixed a file-descriptor leak in the c++ client API. If the socket connectionTed Ross2008-11-112-2/+14
| | | | | | | fails, the socket is never closed. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@713154 13f79535-47bb-0310-9956-ffa450edef68
* Remove wrappers for 'transparent' failover; this will be better handled ↵Gordon Sim2008-11-106-2445/+0
| | | | | | through implementation of session resume within SessionImpl. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@712653 13f79535-47bb-0310-9956-ffa450edef68
* Added a bit more detail to comments.Gordon Sim2008-11-071-0/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@712173 13f79535-47bb-0310-9956-ffa450edef68
* * Added some doxygen comments for FailoverManagerGordon Sim2008-11-072-5/+64
| | | | | | | | * Added means for application to alter the order in which urls are tried (or indeed the list of urls to try) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@712127 13f79535-47bb-0310-9956-ffa450edef68
* Restrict connection close codes to the set defined in the specGordon Sim2008-11-063-5/+22
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@711989 13f79535-47bb-0310-9956-ffa450edef68
* * fix bug causing last message to occasionally be lost on replayGordon Sim2008-11-062-3/+9
| | | | | | | | | * 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/qpid@711903 13f79535-47bb-0310-9956-ffa450edef68
* SubscriptionManager and Dispatcher were missing wait() methods meaning that ↵Gordon Sim2008-11-064-0/+16
| | | | | | 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/qpid@711838 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1294 (Johnathan Robie) Improved doxygen generation.Alan Conway2008-11-054-0/+206
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@711702 13f79535-47bb-0310-9956-ffa450edef68
* Added ability to release messages through the Subscription class (+test)Gordon Sim2008-11-0510-15/+88
| | | | | | | | | | 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
* Adding a couple of utilities (don't alter any existing functionality) that ↵Gordon Sim2008-11-044-0/+332
| | | | | | | | | | 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/qpid@711256 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/qpid@710124 13f79535-47bb-0310-9956-ffa450edef68
* Various fixes arising from testing client failover:Gordon Sim2008-11-038-19/+41
| | | | | | | | | | | | | | | | | | | | * 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/qpid@710106 13f79535-47bb-0310-9956-ffa450edef68
* Added return Message overload of SubscriptionManager get().Alan Conway2008-10-313-3/+18
| | | | | | | 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
* 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/qpid@709429 13f79535-47bb-0310-9956-ffa450edef68
* Resolve Time diffs for Windows; add Windows version of asynch I/O layer. ↵Stephen D. Huston2008-10-301-2/+3
| | | | | | Resolves QPID-1209 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@709285 13f79535-47bb-0310-9956-ffa450edef68
* Replicate session state for un-acknowledged messages to new cluster members.Alan Conway2008-10-302-9/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@709242 13f79535-47bb-0310-9956-ffa450edef68
* * added flag to SubscriptionSettings to control automatic completion of messageGordon Sim2008-10-293-22/+38
| | | | | | | | | | * removed automatic acquiring under autoAck mode * added test for results from acquire requests * added short txtest to the set of system tests run under make check git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@708919 13f79535-47bb-0310-9956-ffa450edef68
* Fix minor compile warnings noticed on WindowsStephen D. Huston2008-10-275-7/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@708387 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status