summaryrefslogtreecommitdiff
path: root/java/client
Commit message (Collapse)AuthorAgeFilesLines
* Clean up of code that is no longer being used.Rajith Muditha Attapattu2008-10-226-629/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707226 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1384: updated AMQDestination + added test for 0.10 code pathArnaud Simon2008-10-221-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@706894 13f79535-47bb-0310-9956-ffa450edef68
* qpid-1374: Added handling of null message propertiesArnaud Simon2008-10-202-4/+18
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@706166 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1373: Remove message for unack'd map when acking individual messages. ↵Aidan Skinner2008-10-171-0/+1
| | | | | | Add test. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@705658 13f79535-47bb-0310-9956-ffa450edef68
* s/setPrefecthLimits/setPrefetchLimitsAidan Skinner2008-10-171-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@705654 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1352: log the original exception so we don't lose the stack traceRafael H. Schloming2008-10-131-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@704187 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1289: Make 0-8/0-9 client honour the max_preftech system property.Aidan Skinner2008-10-104-16/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@703383 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1339: refactor of low level client API to permit connections to exist ↵Rafael H. Schloming2008-10-0928-1845/+304
| | | | | | 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-1335: moved Qman into java/management/clientArnaud Simon2008-10-0986-9653/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@703177 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1327 - Added severity field to events, cleaned up routing key usageTed Ross2008-10-081-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@702977 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1327 - Event support for ManagementTed Ross2008-10-073-6/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@702651 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-1319.Rajith Muditha Attapattu2008-10-073-8/+54
| | | | | | | | | | If SSL is specified as an option in the ConnectionURL then it will be copied to the broker level options. If SSL is also specified in the broker URL then it will override the value given at the top level. I also added a simple test case for this use case. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@702488 13f79535-47bb-0310-9956-ffa450edef68
* Add commons-pool to dependencysAidan Skinner2008-10-071-0/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@702474 13f79535-47bb-0310-9956-ffa450edef68
* This is in response to Rafis comments on QPID-943.Rajith Muditha Attapattu2008-10-011-1/+5
| | | | | | | The userid is now converted into bytes using the UTF-8 encoding and the result is cached. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@700886 13f79535-47bb-0310-9956-ffa450edef68
* qpid-1284: Qman unit testsArnaud Simon2008-09-2919-0/+2386
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@700134 13f79535-47bb-0310-9956-ffa450edef68
* qpid-1284: Qman on behalf AndreaArnaud Simon2008-09-2967-0/+7263
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@700077 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for the java client for QPID-943.Rajith Muditha Attapattu2008-09-253-0/+10
| | | | | | | The 0-8 and 0-9 clients adds the user_id of the connection to the message properties before sending the message git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@699045 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1257 : Add new build target 'release-bin' that will generate a broker ↵Martin Ritchie2008-09-051-0/+12
| | | | | | and client package. Documenation will be added to the wiki such that performance tests could also be packaged. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@692461 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1208: fixed ConnectionURLTest to match the new behavior of ↵Rafael H. Schloming2008-08-291-1/+2
| | | | | | AMQConnectionURL.toString() git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@690337 13f79535-47bb-0310-9956-ffa450edef68
* Add ASL to everywhere, to everything.Aidan Skinner2008-08-281-1/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@689937 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1208Rajith Muditha Attapattu2008-08-281-8/+1
| | | | | | | | I removed the code that prints the password when log level == debug. Instead now it will print "xxxx" for password irrespective of the log level. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@689854 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1119 : M2x commit : Addition of a System property to ↵Martin Ritchie2008-08-221-1/+1
| | | | | | | | | | | | | AMQProtocolHandler.java to allow the syncWait default to be changed. To perform this a new SlowMessageStore has been added to the systest package. This allows all MessageStore methods to have a pre and/or post delay applied. This delay can be configured dynamically if you have a handle to the Store or via the XML configuration. The SlowMessageStore can also be used to wrap any existing MessageStore (Testing only carried out with the default MemoryMessageStore) To make testing easier on M2x VMTestCase has been modified to allow the test to simply configure logging levels and systemProperties. These are then reverted after the test has completed. These changes will naturally need more work to before they are merged to trunk which uses totally different methods for ClientProperties and for running tests. systests/pom.xml didn't have amqj.logging.level as a systemProperty hence setting it did nothing for the tests. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@688110 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1258 add ASL to java files that were missing itAidan Skinner2008-08-2224-0/+504
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@688094 13f79535-47bb-0310-9956-ffa450edef68
* Add Simple Request/Response Example from M2.xMartin Ritchie2008-08-212-0/+476
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@687665 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1225 : Temporary commit to allow CI systems to help diagnose cause of ↵Martin Ritchie2008-08-211-0/+2
| | | | | | race condition. My guess is that the session is open but closes right after the isClosed call is done. So the client the goes on and does a waitForFrame that never arrives causing the timeout exceptions. As commented in AMQPH if we add our frame listener such that it will receive any existing and subsequent exceptions, such as connection closing whilst we add them to the framelisteners then I think this will resolve the issue. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@687664 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1217: make temporary queue creation actually create the temporary queue.Aidan Skinner2008-08-203-30/+23
| | | | | | | | | | AMQSession*: consolidate createTemporaryQueue into AMQSession. ConnectionTest: declare custom exchanges before testing them TemporaryQueueTest: add test for QPID-1217 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@687383 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1245: use notifyMessage rather than onMessage in setMessageListener so ↵Rafael H. Schloming2008-08-151-1/+1
| | | | | | that messages from the synchronous queue actually get acked git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@686172 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1244: fix for NPE on broker initiated connection close, also preserve ↵Rafael H. Schloming2008-08-141-0/+1
| | | | | | 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
* QPID-1236: made setObjectProperty validate the passed in valueRafael H. Schloming2008-08-131-0/+22
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@685536 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1235: fixed setXXXProperty to check for empty stringsRafael H. Schloming2008-08-121-0/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@685218 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1233: made getStringProperty(nonexistent) return null instead of NPERafael H. Schloming2008-08-121-8/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@685207 13f79535-47bb-0310-9956-ffa450edef68
* QPID-615: Merge rupertlssmiths 581293Aidan Skinner2008-08-121-0/+125
| | | | | | QPID-615, Added patched version of MINAs VM Pipe cleanup thread. Will replace once bug fix is in newer version of MINA. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@685151 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1092: Merge 662770 to trunk from ritchiem:Aidan Skinner2008-08-121-23/+1
| | | | | | | Changed toString to be String.valueOf(getObject()) Added MessageToStringTest, tests performing toString on Message before calling getObject(). git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@685115 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1218: cleaned up the interface to IoTransport a bit; added IoAcceptor; ↵Rafael H. Schloming2008-08-092-5/+5
| | | | | | 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-0828-842/+546
| | | | | | 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-084-5/+171
| | | | | | tests yet. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@684016 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1213: fixed a performance regressing from converting uuid -> string and ↵Rafael H. Schloming2008-08-081-4/+1
| | | | | | back again git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@683941 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1213: removed empty .java files leftover from applying a patchRafael H. Schloming2008-08-071-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@683744 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1213: Patch from rgodfrey to refactor AbstractJMSMessage and ↵Rafael H. Schloming2008-08-0739-913/+2346
| | | | | | 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-1221: added customizable UUID generation and switched the default ↵Rafael H. Schloming2008-08-061-1/+5
| | | | | | 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-051-15/+2
| | | | 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-0510-302/+95
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - 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-053-36/+13
| | | | | | | | | | | | | | | 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
* 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-1192: Make consumer send Selector as part of binding.Aidan Skinner2008-07-305-16/+38
| | | | | | | | | 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
* QPID-1072: renamed org.apache.qpidity -> org.apache.qpidRafael H. Schloming2008-07-2957-300/+295
| | | | 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-291-3/+12
| | | | | | | | 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 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 up version of aidan's patch, there are still failures when ↵Rafael H. Schloming2008-07-296-72/+67
| | | | | | 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
View Lorry Controller Status