| Commit message (Collapse) | Author | Age | Files | Lines |
|
|
|
|
|
| |
to their own git repositories
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1751566 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
(review comment from @kwall)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1743615 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
queue is empty
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1743491 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
| |
hostname verification of tls connections
* hostname verification is performed by default.
* introduce connection_option "ssl_skip_hostname_check" to disable this feature
* hostname verification will throw an ImportError on Python <2.6
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1743379 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
on AMQP 0-8 and 0-9
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1743168 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1740373 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
qpid_tests.broker_0_10.message.MessageTests.test_release_order to fetch explicitly required number of messages before sending accept/release in order to make sure that released messages are not resend back by the broker
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1740341 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
remove an obsolete file
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1740297 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
tools and extras
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1740289 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
C++ client if swigged client is in-use
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1737539 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
detected by the background thread.
QPID-7064: Improve documentation of the asynchronous error callbacks.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1730741 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
released soon, rest needs a tidy up).
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1723357 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1713943 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1700852 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1687474 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1685116 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1684716 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
flow_control_wait_condition lock used on the 08..091 path
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1684350 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
after/before sending flow-ok on suspending/resuming respectively. work by Lorenz Quack <quack.lorenz@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1683751 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
work by Lorenz Quack <quack.lorenz@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1683708 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
| |
the Python client
* Like the Qpid Java Client, this implementation does not send channel.flow-ok.
Work by Lorenz Quack <quack.lorenz@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1683432 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
for a READY entry in Java Broker log file
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1674911 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
if start has not been called
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1671499 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1671100 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
08..09 code path
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1671094 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
paths through 08..0-9 code
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1671072 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
causing the recursion problem
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1666447 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
compatibility with Python 2.4
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1663039 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1661647 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
pkg_resources and report to the peer at connection time using version/qpid.client_version connection property
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1661459 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1658984 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
allow customization of autoDel and excl flags
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1656278 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1651102 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1629178 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
no credentials are provided
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1628687 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
used in other modules in this package)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1628423 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1627808 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
and add pure python implementations for SCRAM/CRAM/PLAIN mechanisms
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1627554 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
to shutdown a socket to prevent spurious exception when socket closed by peer
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1627553 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1626249 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1626184 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
the receipt of large messages occupying more than one frame (08-091)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1624545 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
authentication
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1622953 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
property types
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1622952 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
connection properties
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1622951 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
location on older python versions
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1622950 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
method interleaving
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1622949 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
received correctly
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1622948 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1622559 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
with failover.
This is partly not-a-bug, there is a client error handling issue that has been
corrected.
qpid-txtest2 initializes a queue with messages at the start and drains the
queues at the end. These operations are *not transactional*. Therefore
duplicates are expected if there is a failover during initialization or
draining. When duplicates were observed, there was indeed a failover at one of
these times.
Making these operations transactional is not enough to pass, now we see the test
fail with "no messages to fetch". This is explained as follows:
If there is a failover during a transaction, TransactionAborted is raised. The
client assumes the transaction was rolled back and re-plays it. However, if the
failover occurs at a critical point *after* the client has sent commit
but *before* it has received a response, then the the client *does not know*
whether the transaction was committed or rolled-back on the new primary.
Re-playing in this case can duplicate the transaction. Each transaction moves
messages from one queue to another so as long as transactions are atomic the
total number of messages will not change. However, if transactions are
duplicated, a transactional session may try to move more messages than exist on
the queue, hence "no messages to fetch". For example if thread 1 moves N
messages from q1 to q2, and thread 2 tries to move N+M messages back, then
thread 2 will fail.
This problem has been corrected as follows: C++ and python clients now raise the
following exceptions:
- TransactionAborted: The transaction has definitely been rolled back due to a
connection failure before commit or a broker error (e.g. a store error) during commit.
It can safely be replayed.
- TransactionUnknown: The transaction outcome is unknown because the connection
failed at the critical time. There's no simple automatic way to know what
happened without examining the state of the broker queues.
Unfortunately With this fix qpid-txtest2 is no longer useful test for TX
failover because it regularly raises TransactionUnknown and there's not much we
can do with that.
A better test of TX atomicity with failover is to run a pair of
qpid-send/qpid-receive with fail-over and verify that the number of
enqueues/dequeues and message depth are a multiple of the transaction size. See
the JIRA for such a test. (Note these test also sometimes raise
TransactionUnknown but it doesn't matter since all we are checking is that
messages go on and off the queues in multiple of the TX size.) )
Note: the original bug also reported seeing missing messages from
qpid-txtest2. I don't have a good explanation for that but since the
qpid-send/receive test shows that transactions are atomic I am going to let that
go for now.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1621211 13f79535-47bb-0310-9956-ffa450edef68
|