| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707924 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707918 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
of acquire/accept.
client/AckPolicy: removed, functionality moved to Subscription and SubscriptionSettings
client/SubscriptionSettings: struct aggregates flow control & accept-acquire parameters for subscribe.
client/Subscription: represents active subscription. Query settings, unacked messages, manual accept/acquire
client/SubscriptionManager: use AcceptMode, AcquireMode enums rather than confusing bools.
Issues addressed by the change:
- old use of bool for acceptMode was inverted wrt AMQP enum values, bools are confusing.
- old AckPolicy was broken - not possible to access the instance associated with an active subscription
- old AckPolicy did not provide a way to do manual acquire, only accept.
- setting values on SubscriptionManager to apply to subsequent subscriptions is awkward & error-prone, now can use SubscriptionSettings to control on each subscribe individually.
- a subscription is a central concept in AMQP, it deserves to be a class. Subscription and SubscriptionSettings provides a single point for future expansion of interactions with a a Subscription.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707808 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707806 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707799 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707793 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707766 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707760 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707756 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707754 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707753 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Change Connection class, statistics federationLink and authIdentity to property
in the management-schema.xml file
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707730 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
- Fixed typo in getTimestamp()
- Updated lock usage to use the try: acquire() finally: release() pattern
- Removed unused match method from URL
- Fixed a bug where 'packages' was accessed without lock protection
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707724 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707720 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707704 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707699 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707697 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
picked up by the test phase.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707695 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707694 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
connection is created and logging to highlight if we are unable to register our client connections. We do not need to unregister our clients as the same providers are used for all new connections.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707692 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
connection is created and logging to highlight if we are unable to register our client connections. We do not need to unregister our clients as the same providers are used for all new connections.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707691 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
by the broker on ApplicationRegistry shutdown
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707678 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
from rgodfrey.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707672 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
SASL configurations
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707658 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707657 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707654 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707653 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
too large to encode are supplied
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707652 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707651 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
compound message handling improvements.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707640 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707616 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
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@707615 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
Added test to verify double/float headers set by c++ are correctly read by python
[TODO: add wider range of header types, add bidirectional tests, add tests against other languages]
[Also fixed one or two SSL related files missing from distribution list]
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707604 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
for CPP examples
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707515 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707514 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707468 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
I missed these two files in the previous commit.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707458 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
| |
added a boolean to the connect method to indicate whether an SSL connection should be created.
currently there seems to be two issues.
1. The shutdownInput method used in IoReceiver is not supported by the SSLSocket implementation.
2. I haven't able to get client side authentication working.
For item 1 we may need to use nio classes to get around the issue.
For item 2 I am yet to figure out the correct config options to get client side auth working.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707453 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Now the code is changed back to what it was before the changes described in QPId-1319 was applied.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707452 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
qmfconsole API
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707449 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707446 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Agree with Aidan that SSL should only be a broker level option.
I have removed the code that copied the top level ssl value to the broker options. I will also correct the examples on the qpid wiki page
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707443 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
ends with it
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707427 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
- 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@707406 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
session is fully opened.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707388 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707381 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Added new Mock Objects to the broke to allow direct testing of the new class.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707344 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
more frequent than once per second.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707311 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
second.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707308 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707241 13f79535-47bb-0310-9956-ffa450edef68
|