summaryrefslogtreecommitdiff
path: root/qpid/java/broker-plugins/amqp-0-10-protocol
Commit message (Collapse)AuthorAgeFilesLines
* QPID-6481: Move java source tree to top levelAlex Rudyy2015-04-1526-8046/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1673693 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6495: [Java Broker] Ensure the closing a 0-10 connection releases ↵Keith Wall2015-04-141-1/+12
| | | | | | protocol layer session resources before the Connection model close future returns for the caller git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1673570 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6485: [Java Broker] Remove superfluous find/get methods from the Broker ↵Keith Wall2015-04-101-4/+4
| | | | | | configured object git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1672602 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6477: [Java Broker] Make 0-10 implementation ignore all received frames ↵Keith Wall2015-04-051-8/+17
| | | | | | except ConnectionCloseOk once ConnectionClose is sent git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1671415 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6476 : [Java Broker] Refactor MessageStore to allow more efficient ↵Robert Godfrey2015-04-035-17/+7
| | | | | | implementations git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1671184 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6429 : [Java Broker] Make maxidle/last read/write times volatile to ↵Keith Wall2015-03-181-2/+2
| | | | | | 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 : Fix issue when async close is called twice on a session, tidy up ↵Robert Godfrey2015-03-171-25/+31
| | | | | | debug and logging git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667346 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6429 : ensure the consumer target queues are emptied before we perform ↵Robert Godfrey2015-03-161-5/+5
| | | | | | 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-8/+16
| | | | | | finished any in flight deliveries git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667144 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6429, QPID-6262: [Java Broker] Improve error handling in new NIO code; ↵Keith Wall2015-03-162-10/+10
| | | | | | | | 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/+1
| | | | | | 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-125-10/+16
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1666234 13f79535-47bb-0310-9956-ffa450edef68
* Merge from trunkKeith Wall2015-03-124-4/+74
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1666200 13f79535-47bb-0310-9956-ffa450edef68
* merge from trunkKeith Wall2015-03-032-4/+61
| | | | 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-34/+40
| | | | 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-022-15/+24
| | | | 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-192-7/+7
| | | | 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-193-22/+57
| | | | 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/+6
| | | | 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/+7
| | | | | | 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-112-3/+16
| | | | 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-1/+24
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1658990 13f79535-47bb-0310-9956-ffa450edef68
* refactoringRobert Godfrey2015-02-117-7/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1658981 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-104-3/+50
| | | | | | onto the wire git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1658773 13f79535-47bb-0310-9956-ffa450edef68
* Change server encoder default capacity/thresholdRobert Godfrey2015-01-311-2/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1656249 13f79535-47bb-0310-9956-ffa450edef68
* Separate Byte and ProtocolEvent sender/receivers, add server specific 0-10 ↵Robert Godfrey2015-01-313-11/+623
| | | | | | encoder git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1656248 13f79535-47bb-0310-9956-ffa450edef68
* Remove dead setIdleTimeout methodKeith Wall2014-12-121-7/+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-119-58/+96
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644704 13f79535-47bb-0310-9956-ffa450edef68
* Ensure that the NonBlockingSenderReceiver closes (and thread stops) if the ↵Keith Wall2014-12-111-5/+0
| | | | | | 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-111-0/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644586 13f79535-47bb-0310-9956-ffa450edef68
* Force close connection on 0-10 when message sent to closing virtual hostRobert Godfrey2014-12-101-37/+49
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644374 13f79535-47bb-0310-9956-ffa450edef68
* NonBlockingSenderReceiver for the Java Broker for AMQP-0-10 and 0-9. ↵Keith Wall2014-12-081-2/+2
| | | | | | | | | | 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
* QPID-6262: Rob's prototype NIO workKeith Wall2014-12-051-1/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1643302 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6257: Introduce operational log for connection being dropped by the ↵Alex Rudyy2014-12-051-1/+1
| | | | | | 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-6258: [Java Broker] Remove SubFlushRunner leaving QueueRunner solely ↵Keith Wall2014-12-051-1/+1
| | | | | | responsible for asynchronous message delivery git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1643197 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6163 : [Java Broker] Remove stderr debug logging left by this commitKeith Wall2014-12-011-4/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1642719 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6226: [Java Broker] Change queue.declare so that on the passive path, ↵Keith Wall2014-11-181-33/+17
| | | | | | | | exclusivity is verified if command has set the exclusive flag. Also strengthen the python tests. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1640390 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6207 : [Java Broker] Flow uncommitted messages to disk if combined size ↵Robert Godfrey2014-11-041-2/+55
| | | | | | greater than threshold git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1636617 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6198 : [Java Broker] do not retain unnecesary references to transfers ↵Robert Godfrey2014-10-301-0/+4
| | | | | | which have been sent git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1635345 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6175 : [Java Broker] allow maximum message size to be restrictedRobert Godfrey2014-10-216-45/+98
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1633466 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6163 : [Java Broker] Disconnect clients which do not obey flow controlRobert Godfrey2014-10-174-65/+113
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1632618 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6055 : [Java Broker] Ensure max frame size is always less than ↵Robert Godfrey2014-08-301-1/+1
| | | | | | Integer.MAX_VALUE git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1621498 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6040 : [Java Broker] [Java Client] add the ability to create a single ↵Robert Godfrey2014-08-265-58/+133
| | | | | | consumer that is consuming across a collection of queues git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1620659 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6027 : Give Json extracts a stable ordering, and add option to REST ↵Robert Godfrey2014-08-201-1/+3
| | | | | | servlet to extract data for an initial configuration (e.g. for a vhost) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1619259 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6000 : [Java] Address review comments from AlexRobert Godfrey2014-08-191-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1618871 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3978 : [Java Broker] Download severity of log message 'MessageRelease ↵Keith Wall2014-08-181-3/+3
| | | | | | | | received for message which has not been acquired' to debug This message is now normal and will happen as a result of ttl or management action. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1618660 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6000 : [Java Broker] [Java Client] add the ability to configure ↵Robert Godfrey2014-08-163-8/+75
| | | | | | automatic message compression git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1618375 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4429 : [Java] Implement max frame size negotiation checks in 0-x protocolsRobert Godfrey2014-08-092-20/+45
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1616977 13f79535-47bb-0310-9956-ffa450edef68
* QPID-5745 : [Java Broker] enforce disconnect of AMQP 0-x connections when ↵Robert Godfrey2014-08-082-10/+34
| | | | | | authentication is not performed in a timely manner git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1616899 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status