| Commit message (Collapse) | Author | Age | Files | Lines |
| ... | |
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1646257 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1646256 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
should override default.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1646255 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
closing session
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1646118 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
consumer close
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1646009 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
queue is deleted
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1645880 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1645667 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
messages sent back over the wire
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1645645 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
queue precisely when the queue entry changes state
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1644906 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
folder qbtc-ouput to qbtc-test-config
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1644611 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
Log4j, simplify QBTC
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1644492 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
starter class
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1644491 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
SystemConfig
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1643719 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
SystemConfig and simply use attributes instead
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1643660 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1643619 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
broker (better fix)
This is a simpler and better fix based on the discussion at:
http://qpid.2158936.n2.nabble.com/Re-svn-commit-r1642720-in-qpid-trunk-qpid-cpp-src-qpid-messaging-amqp-AddressHelper-h-ConnectionConth-td7617083.html
The changes are all client-side:
- A browsing address is unreliable by default. An explicit reliability setting is respected.
- The client session does not record pre-settled deliveries in it's unacked list.
So by default:
- Browsing links are unreliable. Broker sends pre-settled, messages are not recorded in unacked list.
- The user is not required to acknowledge browsed messages for proper clean-up.
- Calling acknowledge() for a browsed message is a no-op, not an error.
If the user explicitly requests a reliable browsing link, then we behave exactly as before.
I can't see any value in doing this with qpidd but maybe with some other broker there might be
a use for being able to control the accept of browsed messages.
This does affect non-browsing, unreliable links but it is an improvement.
Settling a pre-settled messages is a no-op, so there is no point in recording
pre-settled messages in the unacked list since we do nothing when they are
acknoweldged.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1643276 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
on broker."
This reverts commit 78d7f0727227f13da826180b2fe98f799160a93a.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1643275 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
long ago.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1643264 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@825292 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@824198 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@816614 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@816613 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@816612 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@816261 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
ReadWriteThreadModel. Move the couple of necessary methods to Job.
Fix imports.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@816232 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
service in the same class as it's acquired
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@815729 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@815708 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
there's still stuff to process. Let the cleanup thread do that so that publishes
which are denied don't result in instant connection death.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@815705 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
Allow an existing SocketConnector to be passed into a MINANetworkDriver, for
use with the ExistingSocket bit of TransportConnection.
Move the ExistingSocket stuff to one place, use MINANetworkDriver in
TransportConnection and make AMQProtocolHandler implement ProtocolEngine. Remove MINA specific gubbins from AMQProtocolHandler and AMQProtocolSession.
Move fireAsynchEvent to Job
Add getLocalAddress to AMQProtocolEngine
Move TestNetworkDriver to common
Use correct class for logger in AMQProtocolEngine
Check the exception is thrown properly in SimpleACLTest, make it a little less
prone to obscure race conditions.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@815704 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@812936 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@811326 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@810953 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
AMQMinaProtocolSession. Remove various now-unused classes and update references. Add tests for AMQDecoder. Net -1500 lines, +25% performance on transient messaging. Nice.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@810110 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
that it only returns when all data has been written.
Add getLocalAddress.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@805809 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
NetworkDriver implementation that uses MINA.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@805477 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644950 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644928 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644870 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644704 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
(those running both PLAIN/TLS have to wait for the sniff)
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644644 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
peer closes the connection. Remove some more dead code.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644625 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644586 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
sniffing). Reenable all TLS tests
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644485 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644437 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644374 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
further ByteBuffers being queued to be sent once the transport is closed too
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644128 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644094 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
IO threads it was spawning were being left behind
running on after the tests completed.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644073 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | | |
it is full
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644014 13f79535-47bb-0310-9956-ffa450edef68
|
| | | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
Heartbeating working.
AMQ 1.0 not tested.
System tests failing at about ~PriorityQueueTest with seeming resource leak.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1643866 13f79535-47bb-0310-9956-ffa450edef68
|