summaryrefslogtreecommitdiff
path: root/java
Commit message (Collapse)AuthorAgeFilesLines
* QPID-1213: Patch from rgodfrey to refactor AbstractJMSMessage and ↵Rafael H. Schloming2008-08-0753-1116/+2384
| | | | | | descendants to move AMQP version specific code into delegates and remove unnecessary conversion between 0-8 and 0-10 objects git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@683683 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1182 : Some of the NullPointerExceptions from the SimpleACLTest are due ↵Martin Ritchie2008-08-071-7/+14
| | | | | | to the close and the notification overlapping due to the lack of locking. The problem is that the AtomicBoolean _closed is used for control but the AMQSession.checkNotClosed needs to check _closed and then throw any exception in the StateManager. However, in a loop of the SimpleACLTest, I would see _closed == false but then it is set right afterwards but the option to check AMQStateManager and throw the exception is past and the super.Closeable.checkNotClosed is called and throws the JMSException with no linked exception hence the test throws NullPointerException git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@683635 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1195 , QPID-1193 Initial changes to allow bind and queue arguments to ↵Martin Ritchie2008-08-0716-66/+776
| | | | | | be stored and recovered from the MessageStore. Created a test to validate that the stored values can be recovered. DerbyStore hasn't fully been implemented. Surrounding work has been done and tested with BDBMessageStore. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@683632 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1218: fix stupid used-only-by-tests method breakage that I have exposedAidan Skinner2008-08-071-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@683597 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1218: Boost broker performance by lots.Aidan Skinner2008-08-0711-73/+59
| | | | | | | | | | | | | | AMQMessage: Allow references to be incremented in a pile IncomingMessage: Increment message references in one go, flatten delivery loop a little. Make _destinationQueues an ArrayList, massively increasing performance. Iter ate through it with indexing AccessResult: don't use StringBuilder so much Update tests and exchanges to reflect new API usage, almost all of this is just type narrowing except for Topic where there's an extra copy, but it isn't too bad relative to the number of HashSet and HashMap operations that go on inside there. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@683583 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-066-2/+203
| | | | | | 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-053-197/+8
| | | | 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-0537-993/+534
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - 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-1206: Fix failover and failover testsAidan Skinner2008-08-055-52/+39
| | | | | | | | | | | | | | | AMQConnection: remove dead and confusingly misnamed method AMQSession: rename failedOver to failedOverDirty to convey actual usage, only set it if we failed over while dirty. Ewww! BasicMessageConsumer: if we're in client ack mode, mark as dirty when we receive a message PingPongProducer: calculate expected replies properly if we fail after a send or before a commit FailoverTest: test transacted case git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@682672 13f79535-47bb-0310-9956-ffa450edef68
* Add slf4j deps to perftests, we should move all this to antAidan Skinner2008-08-051-0/+25
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@682644 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1215 : Replaced use of FileReader with FileInputStreamMartin Ritchie2008-08-041-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@682309 13f79535-47bb-0310-9956-ffa450edef68
* improved usageRafael H. Schloming2008-08-011-5/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@681674 13f79535-47bb-0310-9956-ffa450edef68
* added benchmark tool for java native + jms APIsRafael H. Schloming2008-08-012-0/+920
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@681666 13f79535-47bb-0310-9956-ffa450edef68
* added tools module to the main buildRafael H. Schloming2008-07-313-2/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@681477 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1210: made qpid-run output level configurableRafael H. Schloming2008-07-312-13/+29
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@681476 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
* This is related to QPID-1208 .Rajith Muditha Attapattu2008-07-311-4/+3
| | | | | | | | I have enabled the code which will print xxxx when the log level != debug. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@681408 13f79535-47bb-0310-9956-ffa450edef68
* qpid-1163: Added test for qpid-1163 (Note: I have checked that this test did ↵Arnaud Simon2008-07-311-7/+73
| | | | | | not pass before r673074) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@681367 13f79535-47bb-0310-9956-ffa450edef68
* qpid-1205: deleted cpp.sync profile, added cpp.noprefetch profileArnaud Simon2008-07-312-2/+58
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@681333 13f79535-47bb-0310-9956-ffa450edef68
* Fix line breakAidan Skinner2008-07-311-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@681320 13f79535-47bb-0310-9956-ffa450edef68
* Turn off TopicSessionTest#testNonMatchingMessagesDoNotFillQueue since c++ ↵Aidan Skinner2008-07-312-2/+3
| | | | | | broker doesn't do server side selectors git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@681318 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1192: Make consumer send Selector as part of binding.Aidan Skinner2008-07-307-19/+89
| | | | | | | | | QPID-1191: Add test to exhibit leak Change DurableSubscriptionTest to validate exception type recieved Make BasicMessageConsumer validate the Selector before attempting creation git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@681117 13f79535-47bb-0310-9956-ffa450edef68
* added defaulting of QPID_HOMERafael H. Schloming2008-07-304-2/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@680987 13f79535-47bb-0310-9956-ffa450edef68
* Update QpidTestCase to add /bin to the path for the external brokerMartin Ritchie2008-07-302-5/+15
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@680942 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1000 : Made both changes as per JIRA notesMartin Ritchie2008-07-301-4/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@680941 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1072: renamed org.apache.qpidity -> org.apache.qpidRafael H. Schloming2008-07-29150-601/+536
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@680803 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1203: Add 08ExcludeList for external Java broker and make the profile ↵Aidan Skinner2008-07-295-7/+42
| | | | | | | | use that. Make AMQConnectionFactory take an optional clientid and use that if specified. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@680752 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1203: use slf4j instead of log4j directlyAidan Skinner2008-07-292-3/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@680751 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1203 Don't treat protocol negotiation failure as failover reducing error.Aidan Skinner2008-07-291-4/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@680750 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-2911-147/+106
| | | | | | 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
* removed defaulted entries from the java testprofileRafael H. Schloming2008-07-291-15/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@680601 13f79535-47bb-0310-9956-ffa450edef68
* Add java test profileAidan Skinner2008-07-281-0/+18
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@680349 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1200: Only set out and err if we're actually redirecting them.Aidan Skinner2008-07-281-2/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@680309 13f79535-47bb-0310-9956-ffa450edef68
* qpid-1157: added jms tck scripts + README file + config file for setting ↵Arnaud Simon2008-07-232-0/+7
| | | | | | email related properties git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@679105 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1187 : The broker did not correctly handle subscriptions that would ↵Martin Ritchie2008-07-231-1/+5
| | | | | | suspend due to exhaustion of bytes credit. The processQueue loop would spin, this fix marks the subscription inactive for that loop in processQueue so it will stop processing that subscription and ultimately the whole processQueue loop if required. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@679059 13f79535-47bb-0310-9956-ffa450edef68
* Updated the io transport to use a separate write thread with a circular ↵Rafael H. Schloming2008-07-229-414/+536
| | | | | | 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
* QPID-1185: replaced occurrances of with , also made default.testprofile ↵Rafael H. Schloming2008-07-206-76/+11
| | | | | | always load so that all other testprofiles only need to override values that are different git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@678260 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1184: redirect stdout and stderr from QpidTestCaseRafael H. Schloming2008-07-192-0/+27
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@678211 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1182 : Added additional logging to identify the exception that caused ↵Martin Ritchie2008-07-175-19/+35
| | | | | | Authentication to fail. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@677633 13f79535-47bb-0310-9956-ffa450edef68
* Moved the Reflection Wrapping code used by the system tests to the system ↵Martin Ritchie2008-07-174-5/+5
| | | | | | 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
* QPID-1177 : Fixed the format of the messages, realised that the ↵Martin Ritchie2008-07-171-6/+2
| | | | | | transport.Connection uses a logging wrapper but in my haste to make the format the same in AMQProtocolHandler hadn't checked the output was as expected. Was missing the String.format. Also there was an extra debug level output of the sent frame. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@677525 13f79535-47bb-0310-9956-ffa450edef68
* QPID-871 : The shutdown change had a spurious getInstance() call which would ↵Martin Ritchie2008-07-161-8/+14
| | | | | | case a new instance of ID 1 to be created if there wasn't one, it would then procede to shutdown that MBeanServer not the MBeanServer attached to the ApplicationRegistry that is being shutdown. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@677327 13f79535-47bb-0310-9956-ffa450edef68
* Update to the logging to ensure QpidTestCase is always logged and ↵Martin Ritchie2008-07-169-4/+49
| | | | | | 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-1181 : Added additional logging to help diagnose a NullPointerExceptionMartin Ritchie2008-07-163-1/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@677263 13f79535-47bb-0310-9956-ffa450edef68
* Renamed shutdownServer to restartBroker as that is what is doesMartin Ritchie2008-07-164-9/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@677262 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1179 : Adjusted the test size from 100 to 10, this should reduce the ↵Martin Ritchie2008-07-161-26/+48
| | | | | | likely hood of a slow machine failing the test. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@677260 13f79535-47bb-0310-9956-ffa450edef68
* Converted client.failover.FailoverTest so it can utilise the standard ↵Martin Ritchie2008-07-163-73/+72
| | | | | | mechanism for failover testing, as the local CruiseControl had testP2PFailoveWithMessagesLeft fail with extra messages being left on broker. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@677259 13f79535-47bb-0310-9956-ffa450edef68
* Added a warning log statement if the TransportConnection autocreates an InVM ↵Martin Ritchie2008-07-161-0/+1
| | | | | | Broker git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@677258 13f79535-47bb-0310-9956-ffa450edef68