| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1510596 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1509861 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
- Removed "FIXME" log statements inadvertently left in code.
- Changed some trace statements to debug to faclilitate debugging.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1509428 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
Backups send prepare messages to primary, primary delays completion of prepare
till all are prepared (or there is a failure).
This is NOT the production solution - blocking could cause a deadlock. We need
to introduce asynchronous completion of prepare without blocking. This
interim solution allows testing on other aspects of TX support.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1509424 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
On primary a PrimaryTxObserver observes a transaction's TxBuffer and generates
transaction events on a tx-replication-queue. On the backup a TxReplicator
receives the events and constructs a TxBuffer equivalent to the one in the
primary.
Unfinished:
- Primary does not wait for backups to prepare() before committing.
- All connected backups are assumed to be in the transaction, there are race
conditions around brokers joining/leavinv where this assumption is invalid.
- Need more tests.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1509423 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1509422 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
Added TransactionObserver interface, called at each point in a transaction's
lifecycle. Currently only a single observer can be associated with a
transaction.
Added startTx, startDtx to BrokerObserver so plugins can observe transactions
starting and set a TransactionObserver.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1509421 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
This class really was intended as a observer for broker-level events which
includes configuration but may in future include other non-configuration events
such as transactions.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1509420 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Removed un-necessary RangeOps layers.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1509419 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1509418 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
(missed out from earlier commit)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1508915 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
to the named node if not specified
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1508832 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1508523 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
commit of dequeue
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1508516 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
- Since we removed a whole lot of old API code we can drastically cut
down on the header files that we export.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1507469 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
QPID-4941: Remove qmf1 console examples
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1507467 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
- Remove qmf1 engine code
- Remove qmf1 language bindings
- Remove qmf1 agent code (it depends on engine)
- Fix up cmake to build
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1507464 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1507370 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1507112 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1507085 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1506613 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Compute limit-check result even for first connection.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1505823 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
that are not currently in use
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1504622 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
queue specified only if neither durable nor reliable
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1504621 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
well as earliest compatible version
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1504071 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1504065 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
specified
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1504058 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1504036 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1503653 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1503652 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1502766 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1502714 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1502664 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
use QMFv2 format only
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1502642 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1502193 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1502192 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1502090 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1501768 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
This test is still failing very occasionally (approx 1 in 5000 runs) It is being
disabled to cut down on noise in automated builds untill the problem is fixed.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1501259 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1500613 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
overwriting.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1500085 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
Implemented:
message_id, correlation_id,
jms_type, creation_time, absolute_expiry_time
There are a couple of caveats: The easily available way to get
jms_type doesn't distinguish between an empty string and the
property not being sent at all. So we treat this case as property
not set as that seems like it will get most cases correct (why bother
to send an empty jms_type?). The creation_time property is currently
implemented as the time the message was put on the queue (if enabled
in the broker) as amqp 0_10 has no standard way to indicate the
creation time and we're not currently holding the creation time for amqp 1.0
messages.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1500052 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
Test failing if run as: ha_tests.py -DDURATION=2
AssertionError: Stalled test0 waiting for 248, sent 1228
The problem was a missing call to notify() when a ReplicatingSubscription
skipped a message. That resulted in very long (>1s) delays between skipped
messages which caused the test to time out.
Changes:
- ReplicatingSubscription::deliver call notify() to keep consumer active.
- Re-enable test_failover_send_receive.
- Increase default credit for replicating subscription to match qpid-send.
- Rename ReplicatingSubscription::unacked as unready, clearer meaning.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1499789 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1499788 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1499540 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
with duplicate keys
Patch from Gordon Sim to correct issues in initial fix.
Now successive bind requests are accepted when the key, queue, and exchange
are identical if and only if all of the binding args are also identical.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1498671 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1498630 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1497926 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1497827 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1497749 13f79535-47bb-0310-9956-ffa450edef68
|