summaryrefslogtreecommitdiff
path: root/qpid/java/common/src
Commit message (Collapse)AuthorAgeFilesLines
* 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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@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@665798 13f79535-47bb-0310-9956-ffa450edef68
* QPID-901: added logging of sync bit and command-idRafael H. Schloming2008-06-094-3/+51
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@665733 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1127: disable direct buffers as default.Arnaud Simon2008-06-091-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@664698 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1126: reuse channel numbers for sessions that have closed, and honor ↵Rafael H. Schloming2008-06-075-12/+36
| | | | | | the negotiated channel-max; also removed unnecessary catches that were swallowing stack traces from several tests git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@664339 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1125: log exceptions destined to be swallowed by MINARafael H. Schloming2008-06-061-2/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@664140 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1062: merge writes of separate frames within an assembly, use sync flag ↵Rafael H. Schloming2008-06-062-17/+61
| | | | | | instead of sync command on message transfer git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@663813 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1116: fixed a race condition in connection/session close, session close ↵Rafael H. Schloming2008-06-052-4/+20
| | | | | | now waits for the session to be detached before returning, this guarantees we won't have any active sessions when the connection close is attempted git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@663677 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1062: use BBDecoder for non fragmented segments, modified ↵Rafael H. Schloming2008-06-046-22/+85
| | | | | | BBDecoder/Encoder to use byte buffer primitives, made various classes final (including generated classes) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@663325 13f79535-47bb-0310-9956-ffa450edef68
* QPID-901: honor the timely-reply flag and handle known-completedRafael H. Schloming2008-06-032-9/+38
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@662859 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1062: modified generated code to keep packing flags in wire form and ↵Rafael H. Schloming2008-06-038-102/+71
| | | | | | override commonly used size methods for improved performance git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@662849 13f79535-47bb-0310-9956-ffa450edef68
* This check in is for QPID-1102.Rajith Muditha Attapattu2008-05-302-0/+313
| | | | | | | | | IoHandler and IoSender uses the java.io classes for IO operations and have shown very good improvement in latency and memory usage over MINA. For certain tests with pub/sub it gives a 2X improvement in throughput. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@661561 13f79535-47bb-0310-9956-ffa450edef68
* QPID-901: Track and report session exceptions, modified generator validate ↵Rafael H. Schloming2008-05-236-3/+255
| | | | | | values before trying to encode them. Also, moved createDurableSubscriber from AMQSession_0_10 -> AMQSession. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@659631 13f79535-47bb-0310-9956-ffa450edef68
* Made Range, RangeSet, and Session all use proper RFC1982 comparisons per ↵Rafael H. Schloming2008-05-2214-240/+167
| | | | | | QPID-861. Also switched command ids from long -> int, and added a mutex to channel to prevent multi-frame commands from interleaving when invoked from separate threads. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@659271 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status