summaryrefslogtreecommitdiff
path: root/qpid/java/broker-plugins/amqp-0-8-protocol
Commit message (Collapse)AuthorAgeFilesLines
* QPID-6481: Move java source tree to top levelAlex Rudyy2015-04-1541-11468/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1673693 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6485: [Java Broker] Remove superfluous find/get methods from the Broker ↵Keith Wall2015-04-101-2/+3
| | | | | | configured object git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1672602 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6476 : [Java Broker] Refactor MessageStore to allow more efficient ↵Robert Godfrey2015-04-038-37/+40
| | | | | | implementations git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1671184 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6469: Remove not used method sendResponseAndCloseSender from ↵orudyy2015-04-021-29/+0
| | | | | | | | AMQProtocolEngine. Remove exception handling code from ProtocolEngine_1_0_0_SASL as it is not used by new i/o layer git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1670933 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6469: Remove content of AMQProtocolEngine#exception as it is not used ↵Alex Rudyy2015-03-312-143/+1
| | | | | | in new i/o layer git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1670271 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6469: Improve AMQProtocolEngine#exception to guard against an exception ↵Alex Rudyy2015-03-272-19/+153
| | | | | | whilst trying to send response to client from the method and re-throw unexpected exception git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1669612 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6429 : [Java Broker] Make maxidle/last read/write times volatile to ↵Keith Wall2015-03-181-5/+5
| | | | | | avoid the risk of spurious disconnection owing to unsafe publication between threads git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667475 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6429 : ensure the consumer target queues are emptied before we perform ↵Robert Godfrey2015-03-161-5/+4
| | | | | | async actions like close git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667152 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6429 : ensure that when message suspension is set, all targets have ↵Robert Godfrey2015-03-161-4/+12
| | | | | | finished any in flight deliveries git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667142 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6429, QPID-6262: [Java Broker] Improve error handling in new NIO code; ↵Keith Wall2015-03-166-93/+51
| | | | | | | | Remove MINA terminlogy (session etc) in 0-8 stack * Also added uncaught exception handler in test framework (QBTC) to guard log the case where a thread exits abnormally. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667068 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6452 : Defer creating filters in default filter map until a consumer is ↵Robert Godfrey2015-03-151-1/+7
| | | | | | added. Optimize filters which start at the tail of the queue. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1666810 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2836 : [Java Broker] Use slf4j facade for logging in the Java BrokerRobert Godfrey2015-03-127-20/+15
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1666234 13f79535-47bb-0310-9956-ffa450edef68
* Merge from trunkKeith Wall2015-03-121-3/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1666200 13f79535-47bb-0310-9956-ffa450edef68
* Bug fix: Prevent NPE possibility if closing an object takes too long.Keith Wall2015-03-031-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1663731 13f79535-47bb-0310-9956-ffa450edef68
* merge from trunkKeith Wall2015-03-032-24/+83
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1663717 13f79535-47bb-0310-9956-ffa450edef68
* channel block/unblock now async, remove unnecessary selector bumpsKeith Wall2015-03-033-60/+24
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1663708 13f79535-47bb-0310-9956-ffa450edef68
* Make management close session asyncRobert Godfrey2015-03-023-56/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1663314 13f79535-47bb-0310-9956-ffa450edef68
* Make close return a future, wait on Future in broker shutdownRobert Godfrey2015-02-191-4/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1660949 13f79535-47bb-0310-9956-ffa450edef68
* Connection close is now performed by i/o threadKeith Wall2015-02-192-12/+43
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1660909 13f79535-47bb-0310-9956-ffa450edef68
* 0-10 queue browser fix.Keith Wall2015-02-121-3/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1659288 13f79535-47bb-0310-9956-ffa450edef68
* broswer consumer close is now pulled by IO rather than pushed by queue, ↵Keith Wall2015-02-122-1/+11
| | | | | | fixing browser tests git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1659232 13f79535-47bb-0310-9956-ffa450edef68
* more refactoringRobert Godfrey2015-02-111-3/+17
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1659004 13f79535-47bb-0310-9956-ffa450edef68
* More refactoringRobert Godfrey2015-02-112-7/+24
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1658990 13f79535-47bb-0310-9956-ffa450edef68
* refactoringRobert Godfrey2015-02-116-6/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1658981 13f79535-47bb-0310-9956-ffa450edef68
* some more fixesRobert Godfrey2015-02-111-0/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1658974 13f79535-47bb-0310-9956-ffa450edef68
* Force the queue runner to notice that the consumer is not now suspendedRobert Godfrey2015-02-101-0/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1658842 13f79535-47bb-0310-9956-ffa450edef68
* Refactoring: make the queue no longer be responsible for pushing messages ↵Keith Wall2015-02-103-12/+53
| | | | | | onto the wire git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1658773 13f79535-47bb-0310-9956-ffa450edef68
* merge from trunkKeith Wall2015-02-103-27/+48
|\ | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1658748 13f79535-47bb-0310-9956-ffa450edef68
| * QPID-6361: [Java Broker] Change 0-8..0-91 queue declare to no longer ↵Keith Wall2015-02-041-11/+0
| | | | | | | | | | | | consider the durability when validating an existing queue. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1657270 13f79535-47bb-0310-9956-ffa450edef68
| * QPID-6342 : Fail fast when commands sent in wrong orderRobert Godfrey2015-01-272-4/+47
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1655186 13f79535-47bb-0310-9956-ffa450edef68
* | Reduce copying in 0-9 pathRobert Godfrey2015-02-012-7/+65
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1656312 13f79535-47bb-0310-9956-ffa450edef68
* | Separate Byte and ProtocolEvent sender/receivers, add server specific 0-10 ↵Robert Godfrey2015-01-312-7/+8
| | | | | | | | | | | | encoder git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1656248 13f79535-47bb-0310-9956-ffa450edef68
* | Merge from trunkKeith Wall2015-01-271-62/+81
|\ \ | |/ | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1655057 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-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] 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
* | Remove dead setIdleTimeout methodKeith Wall2014-12-121-4/+0
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644950 13f79535-47bb-0310-9956-ffa450edef68
* | Extend credit managers to be aware of transport backpressueKeith Wall2014-12-118-25/+399
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644704 13f79535-47bb-0310-9956-ffa450edef68
* | Allow the transport to inform the model that encryption is being usedRobert Godfrey2014-12-111-0/+5
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644586 13f79535-47bb-0310-9956-ffa450edef68
* | NonBlockingSenderReceiver for the Java Broker for AMQP-0-10 and 0-9. ↵Keith Wall2014-12-081-1/+1
| | | | | | | | | | | | | | | | | | | | 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
* | Bug fix: Stop 0-8 protocol layer wrapping the same byte arrayKeith Wall2014-12-051-14/+4
|/ | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1643363 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6257: Introduce operational log for connection being dropped by the ↵Alex Rudyy2014-12-053-34/+55
| | | | | | clients or due to network issue and change the log level for SenderExceptions into INFO/DEBUG git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1643208 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6245 : [Java Broker] release reference to IncomingMessage once ↵Robert Godfrey2014-11-241-37/+36
| | | | | | AMQMessage has been created git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1641389 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6125: [Java Broker] Partial revert so that closeConnection will once ↵Keith Wall2014-11-061-31/+44
| | | | | | again await for an already closing connection to become closed git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1637118 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6207 : [Java Broker] Flow uncommitted messages to disk if combined size ↵Robert Godfrey2014-11-041-0/+49
| | | | | | greater than threshold git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1636617 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6202: [Java Broker] Ensure AMQProtocolEngine#closeSession() completes ↵Keith Wall2014-10-301-17/+46
| | | | | | closure even if AMQChannel fails to close cleanly git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1635548 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6125 : temporary hack to deal with issue causing tests to fail when ↵Robert Godfrey2014-10-231-6/+19
| | | | | | broker close occurs before message.release() git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1633756 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6125 : only send close frame if not already closingRobert Godfrey2014-10-221-8/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1633706 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6125 : make _virtualHost volatileRobert Godfrey2014-10-221-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1633604 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6125 : only log store exceptions that occur against a vhost which is no ↵Robert Godfrey2014-10-221-0/+12
| | | | | | longer AVAILABLE git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1633579 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status