summaryrefslogtreecommitdiff
path: root/qpid/java/client/src
Commit message (Collapse)AuthorAgeFilesLines
* added 0_10 replyTo supportArnaud Simon2007-09-186-14/+46
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@576853 13f79535-47bb-0310-9956-ffa450edef68
* added support querying an exchange and implemented dtx Session Arnaud Simon2007-09-183-12/+24
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@576799 13f79535-47bb-0310-9956-ffa450edef68
* fixed several bugs after running samples against 0_10 Arnaud Simon2007-09-177-21/+50
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@576491 13f79535-47bb-0310-9956-ffa450edef68
* changed qpid session propagationArnaud Simon2007-09-172-11/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@576396 13f79535-47bb-0310-9956-ffa450edef68
* 0_10 implementationArnaud Simon2007-09-171-8/+70
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@576388 13f79535-47bb-0310-9956-ffa450edef68
* Updated ConnectionURLArnaud Simon2007-09-175-5/+47
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@576378 13f79535-47bb-0310-9956-ffa450edef68
* Took out the URL parsing logic from the AMQConnectionURL and moved in two ↵Rajith Muditha Attapattu2007-09-1411-250/+804
| | | | | | | | | | | | | | | | | | Parser classes. The Connection Type (0-8 or 0-10) is decided based on the URL scheme if AMQConnection is created by passing a URL. In other cases it will be based on a jvm switch. Other constructors in AMQConnection internally constructs an 0-8 URL and call the constrcutor with a URL. In that case it is difficult to figure out the type of connection with out additional information. The additional information commes in the form of the following jvm arguments SwitchCon - enables this switch 0-10 - creates an 0-10 connection and the absence of it creates an 0-8 connection This was done to minimize any impact on the test code. currently only one code path can be tested at a given time. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@575789 13f79535-47bb-0310-9956-ffa450edef68
* * moved most of the classes in the org.apache.qpidity package toRafael H. Schloming2007-09-1326-125/+125
| | | | | | | | | | | | | | | | | | | | org.apache.qpidity.transport * factored out the network specific pieces into org.apache.qpidity.transport * moved the mina specific code to org.apache.qpidity.transport.network.mina * replaced the handler chain with Sender/Receiver chains that can deal with close request/closed notifications * moved from an anonymous struct[] to a real Header class * removed an excess copy from message data transmit git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@575474 13f79535-47bb-0310-9956-ffa450edef68
* updated message hierarchy for using 0_10 messagesArnaud Simon2007-09-1320-197/+317
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@575289 13f79535-47bb-0310-9956-ffa450edef68
* QPID-572 Applied test patch supplied by Aidan Skinner along with change to ↵Martin Ritchie2007-09-121-0/+152
| | | | | | ConcurrentSelectorDeliveryManager that resolves the ordering problem. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574982 13f79535-47bb-0310-9956-ffa450edef68
* This is the first pass at refactoring the Connection stuff.Rajith Muditha Attapattu2007-09-114-231/+426
| | | | | | | | | | | | | | The AMQConnection was not made abstract to preserve the widely usd AMQConsutructor in test cases. Instead 0-8,0-10 specific functionality was delegated to a version specific delegate. The version is selected via a JVM argument (and based on the URL format) Currently this mean that we can test only a single code path (o-8 or 0-10) at a time. Next Step is to refactor the URL stuff. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574582 13f79535-47bb-0310-9956-ffa450edef68
* added message flow mode window Arnaud Simon2007-09-101-2/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574255 13f79535-47bb-0310-9956-ffa450edef68
* added 0_10 factoryArnaud Simon2007-09-101-1/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574227 13f79535-47bb-0310-9956-ffa450edef68
* updated recoverArnaud Simon2007-09-101-8/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574226 13f79535-47bb-0310-9956-ffa450edef68
* git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574225 ↵Arnaud Simon2007-09-102-17/+2
| | | | 13f79535-47bb-0310-9956-ffa450edef68
* added AbstractJMSMessage createJMSMessageFromUnprocessedMessageArnaud Simon2007-09-101-3/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574223 13f79535-47bb-0310-9956-ffa450edef68
* removed AbstractJMSMessage createJMSMessageFromUnprocessedMessageArnaud Simon2007-09-101-9/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574222 13f79535-47bb-0310-9956-ffa450edef68
* git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574221 ↵Arnaud Simon2007-09-103-0/+707
| | | | 13f79535-47bb-0310-9956-ffa450edef68
* Unprocessed message was made abstract and a 0-8 and 0-10 implementation is ↵Rajith Muditha Attapattu2007-09-0610-173/+336
| | | | | | | | | | provided. The return message extends unprocessed_msg_0_8 as return message is only a 0-8 feature. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@573282 13f79535-47bb-0310-9956-ffa450edef68
* Separated 0-8 functionality from the AMQSession,/BasicMessageProducer and ↵Rajith Muditha Attapattu2007-09-057-433/+765
| | | | | | BasicMessageConsumer and made them abstract git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@573039 13f79535-47bb-0310-9956-ffa450edef68
* fixed a race condition in rollback() that leads to intermittant failures of ↵Rafael H. Schloming2007-09-042-28/+37
| | | | | | TransactedTest, also modified TransactedTest to be slightly more robust git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@572751 13f79535-47bb-0310-9956-ffa450edef68
* added byteBuffer to Stream converter Arnaud Simon2007-09-046-99/+386
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@572656 13f79535-47bb-0310-9956-ffa450edef68
* fixed a race condition in ConnectionStartTestRafael H. Schloming2007-08-311-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@571367 13f79535-47bb-0310-9956-ffa450edef68
* Remerge of M2. All tests pass locallyMartin Ritchie2007-08-3013-186/+270
| | | | | | | | | | | | | | | | Testing done in Intelij and mvn command line via windows/cygwin. Python tests removed from auto build pending Jython-siztion. Tested running broker in intelij and python run-tests from cygwin. All tests pass. (CombinedTest still exhibts a race condition. but that has always been so.) Additional Race condition identified (around MsgReject/AutoDeleteQueues) during testing patch to follow. systests are inconsistent Some use TestableMemoryMessageStore some use MemoryMessgaeStore. Lets not roll back this change if issues are discovered. Lets work together to go forward and address any issues. I have spent a lot of time ensuring the tests work for me so I hope that they work for you. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@571129 13f79535-47bb-0310-9956-ffa450edef68
* Added a temp fix to overcome the ByteBuffer.array() problemRajith Muditha Attapattu2007-08-251-0/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@569695 13f79535-47bb-0310-9956-ffa450edef68
* Corrected logic to check message listenerRajith Muditha Attapattu2007-08-251-40/+41
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@569691 13f79535-47bb-0310-9956-ffa450edef68
* I provided a fixed to the deadlock issue in MessageConsumerImpl.Rajith Muditha Attapattu2007-08-254-356/+205
| | | | | | | | | | | | | | | | | | Here is the deadlock issue --------------------------- The internal receive thread acquires the _incomingMessageLock and blocks on sync() The MINA thread gets on to onMessage() and blocks while trying to acquire the incomingMessageLock Since the MINA thread doesn't return it can't process the execution.complete() sent by the broker. Since the execution.complete doesn't get processed, the sync() doesn't return. Hence the deadlock. Solution ---------- I rewrote the receive logic using a LinkedBlockingQueue and leveraging the application thread that calls receive methods git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@569688 13f79535-47bb-0310-9956-ffa450edef68
* Added basic test case to test JMSRajith Muditha Attapattu2007-08-243-22/+79
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@569547 13f79535-47bb-0310-9956-ffa450edef68
* updated afterReceiveArnaud Simon2007-08-245-22/+32
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@569431 13f79535-47bb-0310-9956-ffa450edef68
* updated consumer threadArnaud Simon2007-08-248-114/+118
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@569414 13f79535-47bb-0310-9956-ffa450edef68
* git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@569298 ↵Arnaud Simon2007-08-245-45/+41
| | | | 13f79535-47bb-0310-9956-ffa450edef68
* Fixed the following issuesRajith Muditha Attapattu2007-08-2418-55/+144
| | | | | | | | | | | | | | | | | | | | | | | | | | | 1) TopicImpl doesn't populate the routing key properly. The Destination Impl needs to have a routing key field (I added the field). For Topic The queue name is generated. For Queue the routingkey is same as queue name. 2) QpidMessage - Calling flip on messageData resets the limit to zero in beforeMessageDispatch(). I commented out the flip() 3) QpidMessage - setMessageData Instead of _messageData = messageBody, I modified it to do _messageData = messageBody.duplicate(); 4) MessageActorId is not set properly - so I modified the code to set this. This id is used for the destination 5) When creating BytesMessageImpl, in the constructor, it doesn't read from the underlying message impl. There for the _readIn is null and results in MessageNotReadableException. I added a temp solution to read and populate _readIn. However need to revisit it later git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@569238 13f79535-47bb-0310-9956-ffa450edef68
* Updated XIDArnaud Simon2007-08-221-29/+131
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@568535 13f79535-47bb-0310-9956-ffa450edef68
* I added support in the JMS layer to figure out if it received any messages ↵Rajith Muditha Attapattu2007-08-215-46/+33
| | | | | | after calling flush git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@568321 13f79535-47bb-0310-9956-ffa450edef68
* changed to use futuresArnaud Simon2007-08-211-31/+166
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@568054 13f79535-47bb-0310-9956-ffa450edef68
* changed DtxSession to return Futures, moved MessageListener to util and ↵Rajith Muditha Attapattu2007-08-2110-40/+51
| | | | | | added URL support to the client git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@567946 13f79535-47bb-0310-9956-ffa450edef68
* updated syncArnaud Simon2007-08-202-15/+44
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@567678 13f79535-47bb-0310-9956-ffa450edef68
* added syncArnaud Simon2007-08-205-29/+113
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@567674 13f79535-47bb-0310-9956-ffa450edef68
* Updated QpidURL scheme Arnaud Simon2007-08-203-5/+19
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@567629 13f79535-47bb-0310-9956-ffa450edef68
* wrote a parser for the new URL formatRajith Muditha Attapattu2007-08-171-0/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@567174 13f79535-47bb-0310-9956-ffa450edef68
* added jndi Arnaud Simon2007-08-1712-121/+1126
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@567048 13f79535-47bb-0310-9956-ffa450edef68
* Added connection factory supportArnaud Simon2007-08-1620-131/+978
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@566698 13f79535-47bb-0310-9956-ffa450edef68
* updated javadocArnaud Simon2007-08-161-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@566548 13f79535-47bb-0310-9956-ffa450edef68
* updated javadocArnaud Simon2007-08-161-131/+218
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@566538 13f79535-47bb-0310-9956-ffa450edef68
* Added initial ConnectionFactory support to JMSRajith Muditha Attapattu2007-08-1512-15/+241
| | | | | | | | | Rearranged package structure for qpid client Addded javadoc support for qpid client git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@566403 13f79535-47bb-0310-9956-ffa450edef68
* Added foreign message support Arnaud Simon2007-08-1511-43/+349
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@566187 13f79535-47bb-0310-9956-ffa450edef68
* Added clearData() and getTransferId() to the Message interfaceRajith Muditha Attapattu2007-08-157-9/+66
| | | | | | | | Added Java doc git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@566155 13f79535-47bb-0310-9956-ffa450edef68
* Updated message creation methods. Arnaud Simon2007-08-141-18/+69
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@565727 13f79535-47bb-0310-9956-ffa450edef68
* added error code supportRajith Muditha Attapattu2007-08-135-18/+28
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@565561 13f79535-47bb-0310-9956-ffa450edef68
* Added support for message handling.Rajith Muditha Attapattu2007-08-137-129/+277
| | | | | | | | | | | | | | | | | | Sending Messages ------------------- ByteBufferMessage for small messages - data will be in memory. FileMessage and StreamingMessage for sending large messages. Receiving Messages ------------------- For small messages u can use MessageListener and receive ByteBufferMessage. You need to use the MessageListener with the MessagePartListenerAdapter. For large messages it is recomended to use MessagePartListener. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@565407 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status