summaryrefslogtreecommitdiff
path: root/qpid/java
Commit message (Collapse)AuthorAgeFilesLines
* QPID-6481: Move java source tree to top levelAlex Rudyy2015-04-153261-542407/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1673693 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6489: Use synchronous publishing in ↵Alex Rudyy2015-04-151-2/+16
| | | | | | FailoverBehaviourTest.testFlowControlFlagResetOnFailover git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1673690 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6494: [Java Broker] Remove redundant listener code from the BrokerAdapterKeith Wall2015-04-141-165/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1673571 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-5818 : [Java Broker] creating children from within the configuration ↵Robert Godfrey2015-04-124-14/+13
| | | | | | thread leads to deadlock as the configuration thread blocks waiting for a task which cannot be executed because it needs the config thread. Instead use asynchronous child creation. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1673017 13f79535-47bb-0310-9956-ffa450edef68
* QPID-5818 : [Java Broker] creating children from within the configuration ↵Robert Godfrey2015-04-1217-254/+286
| | | | | | thread leads to deadlock as the configuration thread blocks waiting for a task which cannot be executed because it needs the config thread. Instead use asynchronous child creation. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1673014 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA : Remove redundant access modifiers in interfacesRobert Godfrey2015-04-123-4/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1672999 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6476 : Expose vhost target size so a store can decide to flow messages ↵Robert Godfrey2015-04-124-0/+18
| | | | | | to disk in recovery if necessary git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1672998 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6476 : Fix InternalMessage implementation so it can be storedRobert Godfrey2015-04-123-1/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1672997 13f79535-47bb-0310-9956-ffa450edef68
* Fix failing FailoverBehaviourTest#testFlowControlFlagResetOnFailoverAlex Rudyy2015-04-101-3/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1672692 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6488 : Set the Port object as an attribute on every HttpRequestRobert Godfrey2015-04-106-35/+39
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1672632 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6487 : Run link detached callback outside of scope of AMQP 1.0 ↵Robert Godfrey2015-04-101-2/+9
| | | | | | connection lock git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1672608 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6485: [Java Broker] Remove superfluous find/get methods from the Broker ↵Keith Wall2015-04-1013-215/+69
| | | | | | configured object git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1672602 13f79535-47bb-0310-9956-ffa450edef68
* QPID-5818: [Java Broker] Ensure that connection/session use a configuration ↵Keith Wall2015-04-072-77/+39
| | | | | | thread to mutate the model on receipt of close from wire git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1671810 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6478: Set state to ACTIVE on creation of file based authentication ↵Alex Rudyy2015-04-062-7/+105
| | | | | | provider when empty or non existing user file is specified git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1671526 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6442: [Java Broker] Compare the Broker#defaultVirtualHost against the ↵Keith Wall2015-04-064-10/+24
| | | | | | virtualhost name, not the virtualhost node name. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1671509 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6477: [Java Broker] Make 0-10 implementation ignore all received frames ↵Keith Wall2015-04-052-18/+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-6429: [Java Broker] Make NetworkConnectionScheduler utilise the ↵Keith Wall2015-04-041-3/+8
| | | | | | | | Broker's uncaught exception handler so that exeptions are logged and can optionally stop the Broker * Also bound the IO pool's upper size git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1671335 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6429: [Java Broker] Prevent NPE on shutdown if an AMQP port failed to ↵Keith Wall2015-04-041-1/+4
| | | | | | bind on startup git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1671267 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6429: [Java Broker] Add more logging to investigate the failure to ↵Keith Wall2015-04-042-1/+16
| | | | | | close ports in general (sporadic test failure) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1671265 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6429: [Java Broker] Add more logging to investigate the failure to ↵Keith Wall2015-04-041-0/+6
| | | | | | close AMQPS Port on CI Instance (sporadic SSLTest failure) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1671262 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6429: [Java Broker] Discard only ByteBuffers that have been sent down ↵Keith Wall2015-04-031-1/+9
| | | | | | | | | | | | the wire. In #dowrite, the algorithm means to poll off only the ByteBuffers that have been completely sent down the wire, however it is missing a break. The effect of this is, if we have back pressure and send has been called with an empty ByteBuffer, it can poll away ByteBuffers from the front of the queue that are have content. The Python EchoTests demonstrate the bug because they a) use messages that are sufficient large to cause the client to exert back pressure and b) there are no messages in the properties so send is called with an empty ByteBuffer. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1671203 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6476 : [Java Broker] Refactor MessageStore to allow more efficient ↵Robert Godfrey2015-04-0399-1218/+2292
| | | | | | 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-022-66/+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-6446: Verify that store path is a writable folder on creation of derby ↵Alex Rudyy2015-04-017-4/+263
| | | | | | virtual host and node git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1670629 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-6466: [Java Client] Avoid possibilty that the dispatcher and IO thread ↵Keith Wall2015-03-262-59/+68
| | | | | | can reject/release the same message during consumer close git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1669472 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6465: Fix ArrayIndexOutOfBoundsException thrown on attempt to hexify ↵Alex Rudyy2015-03-262-2/+52
| | | | | | password in MD5AuthenticationProvider git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1669340 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6438: Delete unreachable code from RestServlet#performCreateOrUpdateAlex Rudyy2015-03-261-11/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1669339 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6464: Set replica consistency policy to 'NoConsistencyPolicy' in order ↵Alex Rudyy2015-03-252-1/+82
| | | | | | to avoid hanging for timeout specified in TimeConsistencyPolicy on creation of JE transaction after transition from Master into Detached state when HA claster has no majority but the remaining Master change configuration tasks attempted to execute git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1669092 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6438: Address review comments from Keith WallAlex Rudyy2015-03-241-138/+143
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1668828 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6460, QPID-6460: [Java Client] Make task pool used for exception ↵Keith Wall2015-03-202-65/+59
| | | | | | | | | | reporting duties exactly one thread to serialise the callbacks Also, * name the task pool thread (for diagnostic purposes) * no longer forcedily shutdown the pool on close as an unexpected InterruptedException may corrupt an application's state git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1668000 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: Add Apache licenses to scripts generating keystores/trustores/CA ↵Alex Rudyy2015-03-202-15/+54
| | | | | | and improve instruction messages issued by scripts git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667982 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: Re-create java broker peer storeAlex Rudyy2015-03-202-0/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667924 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: Re-generate expired ssl certificatesAlex Rudyy2015-03-2020-63/+177
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667918 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6459 : Don't print stack trace when a read from a socket gets an IO errorRobert Godfrey2015-03-181-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667595 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6458: [Java Client] Prevent the client sending channel.flow (or ↵Keith Wall2015-03-181-1/+4
| | | | | | message.stop) after the session has been closed by the client git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667578 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6429 : [Java Broker] Make maxidle/last read/write times volatile to ↵Keith Wall2015-03-184-11/+11
| | | | | | 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-6457 : [Java Broker] Make asynchronous commits occur on executor threadsRobert Godfrey2015-03-173-4/+152
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667409 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6429 : Remove dead code, add name to (idle) pooled IO threadsRobert Godfrey2015-03-172-69/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667404 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6456: [Java Broker] Correct method id used by connectionclose.ok for ↵Keith Wall2015-03-171-1/+1
| | | | | | AMQP 0-8. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667364 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6429 : Fix issue when async close is called twice on a session, tidy up ↵Robert Godfrey2015-03-176-39/+41
| | | | | | debug and logging git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667346 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6429 : add debugRobert Godfrey2015-03-171-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667312 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6429 : remove redundant wakeup/state change caused in sendRobert Godfrey2015-03-171-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667224 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6429 : ensure the consumer target queues are emptied before we perform ↵Robert Godfrey2015-03-163-15/+14
| | | | | | 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-162-12/+28
| | | | | | finished any in flight deliveries git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667144 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-6454 : Add page summarizing all api pathsRobert Godfrey2015-03-167-45/+186
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667137 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA : Fix typo in testRobert Godfrey2015-03-161-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667093 13f79535-47bb-0310-9956-ffa450edef68