summaryrefslogtreecommitdiff
path: root/qpid
Commit message (Collapse)AuthorAgeFilesLines
...
| | * QPID-6269: trigger autodelete timer on queue recoveryGordon Sim2014-12-171-0/+4
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1646257 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-6267: honour policy timeout even if it is 0Gordon Sim2014-12-171-1/+1
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1646256 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-5003: Use correct property for delayed auto-delete. Explicit 0 timeout ↵Gordon Sim2014-12-171-3/+4
| | | | | | | | | | | | | | | | | | should override default. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1646255 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-6272 : [Java Broker] clear queue delete task on default queue before ↵Robert Godfrey2014-12-171-5/+5
| | | | | | | | | | | | | | | | | | closing session git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1646118 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-5099 : [Java Client] release pre-acquired messages after explicit ↵Robert Godfrey2014-12-161-0/+6
| | | | | | | | | | | | | | | | | | consumer close git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1646009 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-6272: [Java Broker] Null reference to AMQChannel#defaultQueue once the ↵Keith Wall2014-12-161-14/+36
| | | | | | | | | | | | | | | | | | queue is deleted git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1645880 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-6125: [Java Broker] Fix test broken by my previous commitKeith Wall2014-12-151-2/+2
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1645667 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-6125: [Java Broker] Consistently quote queue/exchange names in error ↵Keith Wall2014-12-151-46/+43
| | | | | | | | | | | | | | | | | | messages sent back over the wire git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1645645 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-6268 : [Java Broker] increment/decrement the unacknowledge count on the ↵Robert Godfrey2014-12-123-2/+6
| | | | | | | | | | | | | | | | | | 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
| | * QPID-6265: Unify log4j layout for system tests and spawn broker, rename test ↵Alex Rudyy2014-12-113-3/+3
| | | | | | | | | | | | | | | | | | folder qbtc-ouput to qbtc-test-config git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1644611 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-6265: Change system tests to have one log per file configured using ↵Alex Rudyy2014-12-1026-471/+530
| | | | | | | | | | | | | | | | | | Log4j, simplify QBTC git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1644492 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-6265: Allow suppression of system out operational logging in broker ↵Alex Rudyy2014-12-102-5/+34
| | | | | | | | | | | | | | | | | | starter class git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1644491 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-6263 : [Java Broker] Move startup/recovery logic from server.Broker to ↵Robert Godfrey2014-12-079-117/+152
| | | | | | | | | | | | | | | | | | SystemConfig git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1643719 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-6263 : [Java Broker] Remove knowledge of BrokerOptions from ↵Robert Godfrey2014-12-0717-83/+197
| | | | | | | | | | | | | | | | | | SystemConfig and simply use attributes instead git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1643660 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-6263 : [Java Broker] remove ApplicationRegistryRobert Godfrey2014-12-063-193/+81
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1643619 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-6252: AMQP 1.0 browsing client generates large number of errors on ↵Alan Conway2014-12-052-2/+4
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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
| | * Revert "QPID-6252: AMQP 1.0 browsing client generates large number of errors ↵Alan Conway2014-12-056-10/+5
| | | | | | | | | | | | | | | | | | | | | | | | on broker." This reverts commit 78d7f0727227f13da826180b2fe98f799160a93a. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1643275 13f79535-47bb-0310-9956-ffa450edef68
| | * NO-JIRA: Remove exclusion related to QPID-3605. Looks like this was fixed ↵Keith Wall2014-12-051-3/+0
| | | | | | | | | | | | | | | | | | long ago. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1643264 13f79535-47bb-0310-9956-ffa450edef68
| * | Merge from trunkAidan Skinner2009-10-1427-112/+568
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@825292 13f79535-47bb-0310-9956-ffa450edef68
| * | Merge from trunkAidan Skinner2009-10-11327-5807/+13050
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@824198 13f79535-47bb-0310-9956-ffa450edef68
| * | Fix bind error messageAidan Skinner2009-09-181-2/+2
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@816614 13f79535-47bb-0310-9956-ffa450edef68
| * | MINANetworkDriverTest: Make sure we sleep for at least the alloted time.Aidan Skinner2009-09-181-16/+20
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@816613 13f79535-47bb-0310-9956-ffa450edef68
| * | QPID-2104 AMQProtocolHandler: hand the actual write off to a seperate threadAidan Skinner2009-09-181-2/+9
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@816612 13f79535-47bb-0310-9956-ffa450edef68
| * | Merge from trunkAidan Skinner2009-09-17198-2945/+4998
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@816261 13f79535-47bb-0310-9956-ffa450edef68
| * | QPID-2024 QPID-2105: Remove now unnecessary classes like Event, PoolingFilter, Aidan Skinner2009-09-1711-1003/+113
| | | | | | | | | | | | | | | | | | | | | | | | | | | 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
| * | QPID-2015: Remove AMQIoTransportProtocolSession. Release the executor ↵Aidan Skinner2009-09-164-150/+2
| | | | | | | | | | | | | | | | | | 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
| * | QPID-2105: Merging the patch didn't uncomment this test, stoopid git. Aidan Skinner2009-09-161-3/+3
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@815708 13f79535-47bb-0310-9956-ffa450edef68
| * | QPID-2106: Don't close connections if the broker has asked it to close andAidan Skinner2009-09-164-12/+40
| | | | | | | | | | | | | | | | | | | | | | | | | | | 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
| * | QPID-2105: Make NetworkDriver.open use a SSLContextFactory, not an SSLEngine.Aidan Skinner2009-09-1624-487/+479
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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
| * | Merge from trunk Aidan Skinner2009-09-09304-2023/+25726
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@812936 13f79535-47bb-0310-9956-ffa450edef68
| * | QPID-2025: Log errors instead of printStackTracing()Aidan Skinner2009-09-042-3/+9
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@811326 13f79535-47bb-0310-9956-ffa450edef68
| * | QPID-2025: remove dead classesAidan Skinner2009-09-032-342/+0
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@810953 13f79535-47bb-0310-9956-ffa450edef68
| * | QPID-2025: Add a AMQProtocolEngine from the de-MINAfied ↵Aidan Skinner2009-09-0136-822/+1069
| | | | | | | | | | | | | | | | | | 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
| * | QPID-2024: Change send to stash the future and have flush join on that so ↵Aidan Skinner2009-08-192-4/+16
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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
| * | QPID-2024: Add ProtocolEngine and NetworkDriver interfaces and a ↵Aidan Skinner2009-08-1810-22/+1124
| | | | | | | | | | | | | | | | | | 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
* | | Remove dead setIdleTimeout methodKeith Wall2014-12-1216-86/+1
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644950 13f79535-47bb-0310-9956-ffa450edef68
* | | Reduce logging, use bytebuffers on the read path in a more optimal fashsion.Keith Wall2014-12-123-50/+46
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644928 13f79535-47bb-0310-9956-ffa450edef68
* | | Notify engine when transport is blockedRobert Godfrey2014-12-123-11/+11
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644870 13f79535-47bb-0310-9956-ffa450edef68
* | | Extend credit managers to be aware of transport backpressueKeith Wall2014-12-1129-319/+328
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644704 13f79535-47bb-0310-9956-ffa450edef68
* | | Only when a port is running TLS only can it be identified early as encrypted ↵Keith Wall2014-12-111-1/+4
| | | | | | | | | | | | | | | | | | (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
* | | Ensure that the NonBlockingSenderReceiver closes (and thread stops) if the ↵Keith Wall2014-12-118-852/+26
| | | | | | | | | | | | | | | | | | 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
* | | Allow the transport to inform the model that encryption is being usedRobert Godfrey2014-12-1113-367/+80
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644586 13f79535-47bb-0310-9956-ffa450edef68
* | | Reenable support for SSL and Plain on the same port (i.e. the transport ↵Keith Wall2014-12-105-22/+86
| | | | | | | | | | | | | | | | | | 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
* | | Iniital SSL workRobert Godfrey2014-12-109-52/+274
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644437 13f79535-47bb-0310-9956-ffa450edef68
* | | Force close connection on 0-10 when message sent to closing virtual hostRobert Godfrey2014-12-104-40/+87
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644374 13f79535-47bb-0310-9956-ffa450edef68
* | | Stop reading bytes from the wire once the transport is closed. Also prevent ↵Keith Wall2014-12-091-4/+7
| | | | | | | | | | | | | | | | | | 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
* | | Exclude ExternalAuthenticationTest too (requires SSL)Keith Wall2014-12-091-0/+1
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644094 13f79535-47bb-0310-9956-ffa450edef68
* | | Omit the BrokerLoggingTest that tests SSL. As SSL is currently disabled the ↵Keith Wall2014-12-092-0/+9
| | | | | | | | | | | | | | | | | | | | | | | | 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
* | | Ensure selector is closed, continue to use same backing buffer on read until ↵Robert Godfrey2014-12-091-18/+14
| | | | | | | | | | | | | | | | | | it is full git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644014 13f79535-47bb-0310-9956-ffa450edef68
* | | NonBlockingSenderReceiver for the Java Broker for AMQP-0-10 and 0-9. ↵Keith Wall2014-12-086-21/+259
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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