summaryrefslogtreecommitdiff
path: root/qpid/java/broker-plugins/amqp-1-0-protocol
Commit message (Collapse)AuthorAgeFilesLines
* QPID-6481: Move java source tree to top levelAlex Rudyy2015-04-1527-6457/+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-1/+1
| | | | | | 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-035-54/+31
| | | | | | 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-37/+1
| | | | | | | | 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-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 : 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-4/+12
| | | | | | 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-161-6/+0
| | | | | | | | 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-2836 : [Java Broker] Use slf4j facade for logging in the Java BrokerRobert Godfrey2015-03-127-26/+42
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1666234 13f79535-47bb-0310-9956-ffa450edef68
* Merge from trunkKeith Wall2015-03-121-0/+6
| | | | 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-031-11/+11
| | | | 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-032-2/+2
| | | | 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-021-5/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1663314 13f79535-47bb-0310-9956-ffa450edef68
* Connection close is now performed by i/o threadKeith Wall2015-02-192-7/+46
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1660909 13f79535-47bb-0310-9956-ffa450edef68
* merged from trunk r1659391Robert Godfrey2015-02-123-15/+23
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1659392 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/+6
| | | | | | 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/+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-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-114-4/+4
| | | | 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/+13
| | | | 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-25/+72
| | | | | | 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-14/+38
|\ | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1658748 13f79535-47bb-0310-9956-ffa450edef68
| * QPID-6353 : [Java Broker] [AMQP 1.0] consumer attempting to drain an empty ↵Robert Godfrey2015-02-032-0/+6
| | | | | | | | | | | | queue does not send back flow indicating drain is complete git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1656664 13f79535-47bb-0310-9956-ffa450edef68
| * QPID-6331 : Allow AMQP 1.0 message content to be evicted to diskRobert Godfrey2015-01-271-14/+32
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1655154 13f79535-47bb-0310-9956-ffa450edef68
* | Separate Byte and ProtocolEvent sender/receivers, add server specific 0-10 ↵Robert Godfrey2015-01-311-3/+3
| | | | | | | | | | | | 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-0/+5
|\ \ | |/ | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1655057 13f79535-47bb-0310-9956-ffa450edef68
| * QPID-6281 : [Java Broker] Config model shadow objects for sessions are not ↵Robert Godfrey2015-01-131-0/+5
| | | | | | | | | | | | being properly closed in AMQP 1.0 plugin git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1651315 13f79535-47bb-0310-9956-ffa450edef68
* | Extend credit managers to be aware of transport backpressueKeith Wall2014-12-115-7/+68
| | | | | | | | 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
* QPID-6190 : [Java Broker] [AMQP 1.0] Fix transactional sending to ↵Robert Godfrey2014-10-271-5/+12
| | | | | | QueueDestination git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1634645 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6175 : [Java Broker] allow maximum message size to be restrictedRobert Godfrey2014-10-213-14/+14
| | | | 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-171-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1632618 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6161 : [Java Broker] add virtual host aliasesRobert Godfrey2014-10-171-10/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1632553 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6061 : [Java Broker] Use subject as the proxy for routing key for 1.0 ↵Robert Godfrey2014-08-302-4/+64
| | | | | | messages sent directly to an exchange of type direct or topic git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1621443 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6054 : [Java Broker] Broker does not honour request for receiver settle ↵Robert Godfrey2014-08-291-0/+2
| | | | | | first incoming link git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1621281 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6040 : [Java Broker] [Java Client] add the ability to create a single ↵Robert Godfrey2014-08-261-4/+4
| | | | | | 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-6046 : [Java Broker] [AMQP 1.0] when creating an outgoing link from the ↵Robert Godfrey2014-08-261-2/+2
| | | | | | address amq.fanout (or any fanout exchange) bind the temporary queue to the exchange witht the queue name git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1620657 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6046 : [Java Broker] [AMQP 1.0] when creating an outgoing link from the ↵Robert Godfrey2014-08-261-0/+13
| | | | | | address amq.fanout (or any fanout exchange) bind the temporary queue to the exchange witht the queue name git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1620629 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6044 : [Java Broker] [AMQP 1.0] cache the valid host names for the ↵Robert Godfrey2014-08-261-57/+1
| | | | | | local machine git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1620593 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6044 : [Java Broker] [AMQP 1.0] When the hostname in the open frame ↵Robert Godfrey2014-08-261-28/+94
| | | | | | does not resolve directly to a vhost, but does resolve via DNS to the local machine, map the connection to the default vhost git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1620570 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6022 : [Java] Fix issues highlighted by code scanning toolsRobert Godfrey2014-08-191-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1618964 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6014 : [Java] declare variables as ConcurrentMap not ConcurrentHashMap ↵Robert Godfrey2014-08-181-1/+2
| | | | | | to avoid linking issues after compiling under Java 8 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1618690 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6000 : [Java Broker] [Java Client] add the ability to configure ↵Robert Godfrey2014-08-163-10/+29
| | | | | | automatic message compression git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1618375 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6003 : [Java Broker] improve conversion of non-standard AMQP 1.0 types ↵Robert Godfrey2014-08-151-33/+98
| | | | | | in message headers git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1618176 13f79535-47bb-0310-9956-ffa450edef68
* QPID-5745 : [Java Broker] enforce disconnect of AMQP 0-x connections when ↵Robert Godfrey2014-08-081-2/+2
| | | | | | 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
* QPID-3978 : [Java Broker] Allow for acquired messages to be removed from a ↵Robert Godfrey2014-08-082-17/+26
| | | | | | queue due to TTL or management actions git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1616742 13f79535-47bb-0310-9956-ffa450edef68
* QPID-5813: Advance version numbers on trunk to 0.29 or 0.32-SNAPSHOT as ↵Justin Ross2014-08-071-1/+1
| | | | | | appropriate git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1616586 13f79535-47bb-0310-9956-ffa450edef68
* QPID-5965 : [Java Broker] flow transient messages to disk in low memory ↵Robert Godfrey2014-08-061-2/+13
| | | | | | situations git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1616155 13f79535-47bb-0310-9956-ffa450edef68
* QPID-5958: [Java Broker] Wire up the Connection#remoteProcessPid attribute ↵Keith Wall2014-08-031-0/+6
| | | | | | | | | | to the client's process identifier made available as connection properties during connection negotiation. * Make information available via the Connection tab during the Web Management UI. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1615425 13f79535-47bb-0310-9956-ffa450edef68