| Commit message (Collapse) | Author | Age | Files | Lines |
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232959 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Old clients can omit certain map values. Previously this caused an error,
now a void value is treated as an empty map.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232958 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232481 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232480 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232178 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232172 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232171 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
This is not an error, its normal for ReplicatingSubscriptions to be still
running when a queue is deleted.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232170 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232142 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
If a backup crashes or shuts down any messages that have
been delayed completion for that backup must be marked
complete to avoid the primary hanging.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232075 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
Simplyfig the code, there is no need for these to be separate functions.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1231288 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1231287 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
This ensures that recreation of a bridge does not result in two active subscriptions (evench can cause confusion for replicators, even if they are both active only for a very short period).
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1230488 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1230147 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1230146 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
uninitialised session
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1230143 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
consumer also exists (note that replicating browser sees acquired messages)
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1229681 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1229376 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Don't reply to a "detached" in case of error. Doing so can create an
infinite game of "detached tennis" between federated brokers.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1229375 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1228425 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
function pair.
Done for the new HA work, but this is better practice in any case.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1228424 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
Clarified deliver() and dequeued() logic and locking.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1227885 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Was core dumping occasionally due to QueueReplicator being deleted before
it was initialized.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1227882 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
| |
Separate bridge de-activation from destruction in QueueReplicator:
Only deactivate if destroyed by the WiringReplicator because of a
queue delete. If destroyed for any other reason (e.g. broker
destruction) don't de-activate the bridge as required resources may
not exist.
Added missing locks in QueueReplicator functions.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1222432 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Creating the prefix dynamically caused sporadic core dumps with trace
logging on. It is also inefficient.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1222431 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
ReplicatingSubscription::DelegatingConsumer
The event messages sent to this consumer do not have delayed completion.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1221922 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1221921 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
- Reduce verbosity, drop unknown event messages.
- Lots of clarifications
- Fix minor test bug in ha_tests.py.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1221920 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
These tests are known to be broken by the new HA work.
We will need to fix them and re-enable at some point.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1214971 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1214970 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
ReplicatingSubscription.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1214969 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
| |
primary and backup
Previous code used dequeues to synchronize queue, but dequeue events
are generated in a different thread to message delivery which led to
race conditions. Position events are generated in-line with message
delivery.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1214493 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Acquire was returning incorrect results if the acquired position was
before the first availble index.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1214492 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1214491 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
| |
There was an optimization to re-use messages already on the backup
after fail-over. This optimization was removed to simplify the logic
while we basic replication working. It can be re-introduced
later. Last revision with the optimization was:
r1213258 | QPID-3603: Fix QueueReplicator subscription parameters.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1214490 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
- Queue::destroyed cleans up observers.
- Clean up log messages, comments, some variable names.
- Improvements to brokertest.py
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1213258 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
replicate=all
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1211902 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1210983 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1210616 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1209691 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
- Set acquire=false when creating a ReplicatingSubscription.
- Cleaned up string literals & other cosmetic improvemets.
- Consistent find/get for broker::QueueRegistry and ExchangeRegistry.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1209690 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1208617 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1208461 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
HaBroker registers the ConsumerFactory, QueueReplicator sets
appropriate arguments in consume command.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1207544 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1207447 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
The code to use ReplicatingSubscription is there but it is disabled by
commenting out getConsumerFactories().add in Backup.cpp because it
hangs the test.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1206353 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1206352 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1206351 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1206350 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1206349 13f79535-47bb-0310-9956-ffa450edef68
|