| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711915 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711913 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
* 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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711890 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
- 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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711855 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711848 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
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
|
| |
|
|
|
|
| |
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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711820 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711818 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
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
|
| |
|
|
|
|
| |
previous commit.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711708 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711702 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711658 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711631 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Cleaned up the code a bit.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711628 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711624 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711609 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
resolves QPID-1435
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711603 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
| |
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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711540 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
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
|
| |
|
|
|
|
|
|
|
| |
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
|
| |
|
|
|
|
| |
for bank values
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711384 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711379 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711377 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711367 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711328 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@711283 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
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
|
| |
|
|
|
|
|
|
|
|
| |
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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@710216 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@710188 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
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
|
| |
|
|
|
|
| |
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
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* 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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@710075 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709544 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709474 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
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
|
| |
|
|
|
|
| |
the same session.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709429 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709374 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709371 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
| |
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
|
| |
|
|
|
|
| |
exceptions
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709337 13f79535-47bb-0310-9956-ffa450edef68
|