summaryrefslogtreecommitdiff
path: root/java/common/src
Commit message (Collapse)AuthorAgeFilesLines
...
* Appologies for the sudden checkin without notice, close to the release cycle.Rajith Muditha Attapattu2008-11-216-135/+16
| | | | | | | Reverting the changes back. Will attach a patch and commit after the release. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@719657 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1479.Rajith Muditha Attapattu2008-11-216-16/+135
| | | | | | | | | | | | | | | For starters I have changed the IoSender.java IoReceiver.java and AMQSession.java#Dispatcher to use the Thread factory to create the threads they require. The ThreadFactory has two implimentations, the default being the java.lang.Threads. The other is the RealtimeThreadFactory which uses reflection to create threads with a specific priority. -Dqpid.thread_factory=<thread_factory_class> will decide which thread factory should be loaded. -Dqpid.rt_thread_priority=<int> specifies the gloabl real time thread priority and defaults to 20. You could also set individual thread priorities by adding the nessacery config+code changes. I have also changed the Testkit and QpidBench to use the Thread factory so you could use them for testing/benchmarking work on RT JVMs. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@719628 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1463: Andrea's patchesArnaud Simon2008-11-197-224/+606
| | | | | | | | | | | | | - Added read / write methods on org.apache.qpid.transport.codec.Encoder / org.apache.qpid.transport.codec.Decoder; - Added the corresponding implementation on org.apache.qpid.transport.codec.BBEncoder / org.apache.qpid.transport.codec.BBDecoder - Added comments on org.apache.qpid.transport.codec.Encoder / org.apache.qpid.transport.codec.Decoder; - Removed org.apache.qpid.transport.codec.ManagementEncoder / org.apache.qpid.transport.codec.ManagementDecoder. - Added 6 data types (Int8, Int16, Int32, Int64, Double and Float); - Added type mappings with the data types above according to management specifications; - Removed all references to ManagementEncoder / Decoder classes; Now Qman is using (whenever is possible) Decoder / Encoder and when some specific method is needed then the BBDecoder / BBEncoder is used. - Some test case adjustment; git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@718949 13f79535-47bb-0310-9956-ffa450edef68
* updated version numbers and release notes for M4Rafael H. Schloming2008-11-151-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@714267 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1434 : Changed rethrow() name based on feedback from RobMartin Ritchie2008-11-062-45/+22
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@711848 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1434 : Add ability to rethrow AMQExceptionsMartin Ritchie2008-11-061-0/+128
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@711820 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1434 : Add ability to rethrow AMQExceptionsMartin Ritchie2008-11-061-0/+30
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@711818 13f79535-47bb-0310-9956-ffa450edef68
* This check in is related to QPID-1296Rajith Muditha Attapattu2008-11-045-52/+469
| | | | | | | | | Since SSLSocket didn't support shutdownInput method, I added an SSL layer on top of the TCP transport. The SSL layer uses the SSLEngine class introduced in java 1.5. This Layer can be used with minimum code changes to the the nio transport as well. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@711455 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1339:Rafael H. Schloming2008-10-275-55/+215
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - Modified QpidTestCase to start/stop multiple brokers for failover testing. - Modified QpidTestCase to substitute port variables into broker start/stop commands. - Modified test profiles to use the new port variables. - Modified QpidTestCase to permit multiple exclude files. - Modified test profiles to make use of a common exclude list: ExcludeList - Added ConnectionTest.testResumeEmptyReplayBuffer. - Made default exception handling for Connection and Session log the exception. - Added SenderExcetion to specifically signal problems with transmitting connection data. - Modified Session to catch and deal with connection send failures for sessions with positive expiry. - Modified FailoverBaseCase to work for non VM brokers. - Made FailoverTest fail if failover times out. - Modified JMS implementation to make use of the recently added low level session resume. - Unexcluded failover tests from 0-10 test profiles. - Excluded MultipleJCAProviderRegistrationTest due to its testing strategy resulting in spurious failure when running as part of the larger test suite. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@708093 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1394 : Added test to validate that Provider is registered after ↵Martin Ritchie2008-10-241-2/+8
| | | | | | connection is created and logging to highlight if we are unable to register our client connections. We do not need to unregister our clients as the same providers are used for all new connections. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707691 13f79535-47bb-0310-9956-ffa450edef68
* 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
View Lorry Controller Status