| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
|
| |
Added QueueGuard::cancelled, only call cancel once.
Don't enqueue after cancel.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1399814 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
subscriptions (Jason Dillaman)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1399813 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Introduce a separate lock for Queue::UsageBarrier.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1399812 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
messages
* Call AMQSession#sync after the sending of each (non-transactional) message, this is required to avoid spurious
test fails on machines that are CPU starved.
* Renamed test from testPausedOrder to testMessagesSentByTwoThreadsAreDeliveredInOrder to better reflect the
nature of the test.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1399547 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1399445 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1399370 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1399369 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1399311 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1399279 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1398778 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
Dillaman)
Rework ManagementAgent locks, get rid of shared buffers that were points of contention.
Minor log message improvements in ha code.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1398530 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397926 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397735 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Using a private class typedef in a free function.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397723 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Was seeing core dumps with QueueReplicator::queue == 0. Caused by race
conditions when calling QueueReplicator::deactivate. Renamed deactivate to
destroy and call it only when the broker::Queue is destroyed.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397676 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
bindings. Added unit tests for Address Helper and two specific test
cases for verifying link behavior (bindings and customization of
subscription queues).
Review request : https://reviews.apache.org/r/7412/
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397651 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
a different package.
Applied patch from Phil Harvey <phil@philharveyonline.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397542 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
ServiceLoader-based model rather than embedding Felix to use OSGi.
Removed the ability to reload security configuration because this feature is not very useful in
its current form and was making our code hard to refactor.
Modified all tests to use jars rather than classes. This makes them closer to real-world deployments, e.g. the META-INF/services
file is read from within the jar.
Also moved various system tests from their respective modules into "systests". This removes the need for most modules to depend
on systests, thus simplifying our dependency graph.
Applied patch from myself, Keith Wall and Phil Harvey <phil@philharveyonline.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397519 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397507 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397506 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397502 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
This check-in is a test only, the issue was fixed as a side effect
of the fix for QPID-4350.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397295 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397279 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397265 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Previously each library file was requiring 'cqpid'. Moved this into the
lib/qpid_messaging.rb file.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397262 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Updated the examples and libraries to reflect this change.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397261 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397260 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
descriptive text.
Also added description for --link-heartbeat-interval
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397253 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Subscribed auto-delete queues are deleted by the backup.
Timed auto-delete queues are deleted after the timeout.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397243 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Systemd is a replacement for SysVInit scripts for starting up daemons on
Linux systems.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397235 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Applied patch from Ernie Allen
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397218 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1397092 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
/ only create TCP connection when absolutely necessary
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1396700 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
consumers' performance
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1396299 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
primary.
Test test_delete_missing_response was failing with "cluster active, cannot promote".
- Fixed test bug: "fake" primary triggered "cannot promote".
- Backup: always create QueueReplicator if not already existing.
- Terminology change: "initial" queues -> "catch-up" queues.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1396244 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1395627 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1394739 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
| |
A joining broker now attempts to contact all known members of the cluster and
check their status. If any brokers are in a state other than "joining" the
broker will refuse to promote. This will allow rgmanager to continue to try
addresses till it finds a ready brokers.
Note this reqiures ha-brokers-url to be a list of all known brokers, not a
virtual IP. ha-public-url can still be a VIP.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1394706 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Introduce a new document structure
Migrate useful content from old book to the new structure, rationalising the id's
Remove out-of-date content
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1394629 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
behaviour of an SSLSocket) during closure of a connection using SSL
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1394457 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
session error.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1393597 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1393479 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
module specific
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1393415 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
| |
replicate a deleted queue
Fixes queues getting into a partially deleted state: previously when a broker was
promoted, it did not clean up it's QueueReplicators. The QueueReplicators keep a
shared_ptr to the Queue so this kept Queues in memory after they were destroyed. It also
kept them in QMF, since the management object is unregistered in the destructor.
This patch cleans up properly on promotion.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1393201 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
replicate a deleted queue. (Based on patch by Jason Dillama)
This does not directly tackle the origin of the problem but extends Jasons's patch since
it addresses something we had to fix anyway: "leaking" queues and exchanges. It does 2 things.
1. enabled hideDeletedError on all subscription objects used by HA
This suppress the troublesome exception with a harmless no-op
2. Delete queues/exchanges missing from responses (based on Jasons patch)
Fix the "leak" of queues and exchanges possible when an object replicated
to a backup is deleted from the newn primary before the backup connects.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1393089 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
password masking in URL toString().
Makes SSLTest use a ConnectionFactory instead of instantiating AMQConnections directly, exposing this issue.
Replaces horrible use of an AMQConnectionURL objects in MultipleBrokersFailoverTest and FailoverBehaviourTest (which both broke after this fix) with fully string-generated connection strings.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1393034 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1393032 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1392496 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1392489 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1392093 13f79535-47bb-0310-9956-ffa450edef68
|