summaryrefslogtreecommitdiff
path: root/java/common/src
Commit message (Collapse)AuthorAgeFilesLines
* QPID-1398: use bnd tool to produce osgi bundles with 'ant bundle'Aidan Skinner2008-10-241-0/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707654 13f79535-47bb-0310-9956-ffa450edef68
* This is for QPID-1296Rajith Muditha Attapattu2008-10-234-14/+27
| | | | | | | | | | | | | added a boolean to the connect method to indicate whether an SSL connection should be created. currently there seems to be two issues. 1. The shutdownInput method used in IoReceiver is not supported by the SSLSocket implementation. 2. I haven't able to get client side authentication working. For item 1 we may need to use nio classes to get around the issue. For item 2 I am yet to figure out the correct config options to get client side auth working. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707453 13f79535-47bb-0310-9956-ffa450edef68
* Candidate fix for QPID-1389. Make sure we don't send commands unless the ↵Rafael H. Schloming2008-10-234-6/+33
| | | | | | session is fully opened. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707388 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1339: support for low level session resumeRafael H. Schloming2008-10-2310-140/+362
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707241 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1352: ignore duplicate detached controlsRafael H. Schloming2008-10-141-2/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@704537 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1339:Rafael H. Schloming2008-10-1316-385/+304
| | | | | | | | | | | | | | | | | | | - Removed the Channel class in order to simplify the state management surrounding Sessions and Connections. - Consolidated the ChannelDelegate into the ConnectionDelegate. - Modified MethodDelegate to invoke a generic handle method as the default action for each dispatched method. - Modified the code generator to produce a separate ConnectionInvoker and SessionInvoker. - Modified the invoker template to use package level visibility for all controls rather than public visibility. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@704147 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1344: modified Connection to preserve the originating stack traces when ↵Rafael H. Schloming2008-10-106-30/+49
| | | | | | throwing exceptions git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@703559 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1344 QPID-1339 : Fixed the two issues preventing protocol negotiationMartin Ritchie2008-10-102-2/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@703369 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1339: refactor of low level client API to permit connections to exist ↵Rafael H. Schloming2008-10-0925-354/+826
| | | | | | in a disconnected state as well as to provide a central point from which to track session state git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@703208 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1268 : Improved cleanup and fixed bug in FileUtils.readFileAsString() ↵Martin Ritchie2008-10-082-53/+107
| | | | | | where it did not close the file.. hence the failures on windows machines in FileUtilsTest git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@702804 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1268 : Added additional deleteDirectory method that behaves like rmdir, ↵Martin Ritchie2008-10-032-32/+457
| | | | | | modified delete to behave like rm. Added further tests for copy and delete. Encorporated review feedback from ASkinner. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@701329 13f79535-47bb-0310-9956-ffa450edef68
* qpid-1284: Qman on behalf AndreaArnaud Simon2008-09-292-0/+195
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@700077 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1266 : Provided test for new stop() method. Updated RefCountExService ↵Martin Ritchie2008-09-031-0/+9
| | | | | | to allow retrieval of the referenceCount. Updated AMQQueue to only perform stop() actions once, such as releasing the RefCountExService. Updated instances where new virtualhosts were not added to the VHostRegistry. See supplemental JIRA for removing the need for this. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@691661 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1268 : Added test for new methodsMartin Ritchie2008-09-021-0/+133
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@691279 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1268 : Added single delete and recursive delete method to common FileUtils.Martin Ritchie2008-09-021-0/+31
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@691264 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1263: fixed codegen to not ignore passed in boolean valuesRafael H. Schloming2008-08-291-0/+44
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@690339 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1258 add ASL to java files that were missing itAidan Skinner2008-08-2220-1/+421
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@688094 13f79535-47bb-0310-9956-ffa450edef68
* qpid-1251: changed close method for closing the underlying socket on windows ↵Arnaud Simon2008-08-201-1/+8
| | | | | | only. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@687310 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1244: fix for NPE on broker initiated connection close, also preserve ↵Rafael H. Schloming2008-08-147-1/+129
| | | | | | the connection close text for better error reporting git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@686068 13f79535-47bb-0310-9956-ffa450edef68
* removed dead code from message Echo utility, and added a message Sink utilityRafael H. Schloming2008-08-132-3/+137
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@685506 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1218: cleaned up the interface to IoTransport a bit; added IoAcceptor; ↵Rafael H. Schloming2008-08-0910-103/+254
| | | | | | fixed Session tracking of sync point; default JAVA inside qpid-run git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@684182 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1213: simplified unprocessed message and moved version specific code ↵Rafael H. Schloming2008-08-086-19/+37
| | | | | | into the _0_8 and _0_10 variants git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@684036 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1218 Optionally use IoTransport, it's hot, but doesn't pass all the ↵Aidan Skinner2008-08-085-9/+155
| | | | | | tests yet. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@684016 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1222: round up the buffer size to the nearest power of twoRafael H. Schloming2008-08-061-2/+17
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@683437 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1221: added customizable UUID generation and switched the default ↵Rafael H. Schloming2008-08-064-0/+193
| | | | | | strategy to use nameUUIDFromBytes rather than randomUUID git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@683337 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1219: cleanup of prior commit (r682887)Rafael H. Schloming2008-08-052-182/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@682915 13f79535-47bb-0310-9956-ffa450edef68
* Profiling driven changes:Rafael H. Schloming2008-08-0522-672/+373
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - made AMQShortString cache the toString() value - added static initializer to IoTransport to disable use of pooled byte buffers - modified IoSender to permit buffering - removed OutputHandler and eliminated intermediate Frame generation between Disassembler and Sender<ByteBuffer> (IoSender) - made Disassembler take advantage of IoSender's buffering - removed Header and Data as distinct protocol events, added Header and Body members to MessageTransfer - modified Assembler and Disassembler to decode/encode Header and Data directly to/from MessageTransfer - modified Disassembler to only write data if encoding of headers is successful - added Strings.toUTF8(String) -> byte[] to do proper UTF-8 encoding that is also fast for 7-bit ascii - modified JMSTextMessage to use the Strings.toUTF8 - modified QpidBench to only generate 7-bit ascii when using TextMessage git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@682887 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1207: fixed io transport close to ensure threads shutdown properlyRafael H. Schloming2008-07-313-23/+57
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@681474 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1072: renamed org.apache.qpidity -> org.apache.qpidRafael H. Schloming2008-07-2979-277/+224
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@680803 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1201: fixed some brainos in IoSenderRafael H. Schloming2008-07-291-3/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@680673 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1201: fixed up version of aidan's patch, there are still failures when ↵Rafael H. Schloming2008-07-295-75/+39
| | | | | | running against an external java broker, however we seem to get past basic connection negotiation now git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@680602 13f79535-47bb-0310-9956-ffa450edef68
* Updated the io transport to use a separate write thread with a circular ↵Rafael H. Schloming2008-07-227-388/+520
| | | | | | buffer that does opportunistic write batching. Fixed error handling and shutdown for the io transport. Switched default from mina to the io transport for the 0-10 client. Modified InputHandler to accumulate bytes in the outer loop and simplified the state machine accordingly. These changes should address QPID-1188, prevent the Java client from running out of memory when writing messages faster than the network and/or broker can keep up, and in general improve performance. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@678848 13f79535-47bb-0310-9956-ffa450edef68
* Moved the Reflection Wrapping code used by the system tests to the system ↵Martin Ritchie2008-07-172-272/+0
| | | | | | test. If they are left in common then we must include the common directory when using the systest-testing frameworks no matter the version of Qpid being tested. Whilst this is probably not a problem as long as the classpath is carefully set up it does introduce another potential uncertainty to any test failure. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@677629 13f79535-47bb-0310-9956-ffa450edef68
* Update to the logging to ensure QpidTestCase is always logged and ↵Martin Ritchie2008-07-161-0/+3
| | | | | | standardized the protocol output format between 0-8/0-9 and 0-10 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@677319 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1177 : Added Protocol Level Debug logging. Uses a final static so ↵Martin Ritchie2008-07-151-0/+2
| | | | | | should JIT out if disabled. To enable set -Damqj.protocol.logging.level=info git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@676982 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1102.Rajith Muditha Attapattu2008-07-152-28/+27
| | | | | | | I have fixed the error handling and revised the while loop in IoSender based on the comments received during the code review git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@676938 13f79535-47bb-0310-9956-ffa450edef68
* Removed the non ASCII characters that are causing the build to minorly complain.Martin Ritchie2008-07-151-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@676886 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1062: moved channel id into the ProtocolEvent interface and removed ↵Rafael H. Schloming2008-07-1014-116/+119
| | | | | | ConnectionEvent, this removes the overhead of creating ConnectionEvents git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@675397 13f79535-47bb-0310-9956-ffa450edef68
* Primarily profiling driven changes:Rafael H. Schloming2008-07-0925-607/+677
| | | | | | | | | | | | | | | | | | | | | | | - added batched writes of commands/controls issued on a session - copy fragmented frames and segments rather than trying to decode them piecemeal, removed FragmentDecoder - added caching for str8 encode/decode - compute sizes as we encode by going back and filling in the amount of bytes written rather than computing it up front - added SYNC option to commands - renamed NO_OPTION argument to NONE - added a timeout to Client.java - removed use of UUID.fromString in BasicMessageProducer_0_10.java git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@675165 13f79535-47bb-0310-9956-ffa450edef68
* QPID-962 Exception handling was... unpleasing... Fix up of patch from rhsAidan Skinner2008-07-031-0/+18
| | | | | | | | | | | | | | | | AMQConnection.java: Refactor listener and stack exceptions in a list. Add get lastException, which can now be any Exception. Don't set connected, let the delegate decide. AMQConnectionDelegate_8_0.java, AMQConnectionDelete_0_10.java: set _connected to true if we suceed AMQProtocolHandler.java: attainState can now throw any sort of Exception AMQStateManager.java: attainState can now throw any Exception ConnectionTest.java: check that exception cause is not null AMQConnectionFailureException.java: Add ability to store a Collection of Exceptions in case there are multiple possible causes of the failure. Which there shouldn't be, but it can happen. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@673688 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1144 : Reference count drops to zero too early for immediate messages ↵Robert Godfrey2008-06-201-1/+1
| | | | | | in a txn git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@669841 13f79535-47bb-0310-9956-ffa450edef68
* QPID-950 : Broker refactoring, copied / merged from branchRobert Godfrey2008-06-1910-99/+705
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@669431 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-1140 and QPId-1141.Rajith Muditha Attapattu2008-06-162-31/+10
| | | | | | | | | I also removed commented code as well as code that wasn't used. Cleaned up unused imports as well. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@668333 13f79535-47bb-0310-9956-ffa450edef68
* QPID-901: add tests for RangeSet; fixed a bug found by the new testsRafael H. Schloming2008-06-164-21/+265
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@668309 13f79535-47bb-0310-9956-ffa450edef68
* QPID-901: set the frame track correctlyRafael H. Schloming2008-06-161-6/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@668308 13f79535-47bb-0310-9956-ffa450edef68
* QPID-901: request known-completed every 64K incoming commands, fixed ↵Rafael H. Schloming2008-06-132-5/+52
| | | | | | handling of incoming known-completed to clear out processed set git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@667615 13f79535-47bb-0310-9956-ffa450edef68
* QPID-901: don't send known-completed for ranges we ignoreRafael H. Schloming2008-06-132-5/+18
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@667540 13f79535-47bb-0310-9956-ffa450edef68
* QPID-901: flush after every 64K commands issuedRafael H. Schloming2008-06-131-0/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@667501 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1129: unless otherwise specified, limit the receive buffer size to 64KRafael H. Schloming2008-06-101-1/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@666259 13f79535-47bb-0310-9956-ffa450edef68
* QPID-901: made logging of ids less expensive, also limit how much data we ↵Rafael H. Schloming2008-06-093-4/+16
| | | | | | dump into the log git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@665798 13f79535-47bb-0310-9956-ffa450edef68