summaryrefslogtreecommitdiff
path: root/java/client/src
Commit message (Collapse)AuthorAgeFilesLines
* 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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@569414 13f79535-47bb-0310-9956-ffa450edef68
* git-svn-id: ↵Arnaud Simon2007-08-245-45/+41
| | | | https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@569298 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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@565407 13f79535-47bb-0310-9956-ffa450edef68
* git-svn-id: ↵Arnaud Simon2007-08-133-12/+7
| | | | https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@565401 13f79535-47bb-0310-9956-ffa450edef68
* added constructorsArnaud Simon2007-08-1310-16/+226
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@565354 13f79535-47bb-0310-9956-ffa450edef68
* updated JMS messagesArnaud Simon2007-08-131-0/+26
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@565337 13f79535-47bb-0310-9956-ffa450edef68
* updated JMS messagesArnaud Simon2007-08-1328-4564/+3510
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@565336 13f79535-47bb-0310-9956-ffa450edef68
* Added a Toy Exchange that does same basic routing for direct and topic.Rajith Muditha Attapattu2007-08-1011-82/+247
| | | | | | | | | | Should be good enough for Arnaud to test atleast the basic JMS functionality. Added a FileMessage to demo Martins requirment. Haven't tested yet. The Toy Broker can now accept subscriptions and transfer messages to clients git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@564451 13f79535-47bb-0310-9956-ffa450edef68
* implemented the Connection and Session APIRajith Muditha Attapattu2007-08-0912-251/+434
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@564124 13f79535-47bb-0310-9956-ffa450edef68
* updated the amqp.0-10-preview.xml to reflect the latest votes, and added ↵Rafael H. Schloming2007-08-091-7/+0
| | | | | | support for execution results git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@564077 13f79535-47bb-0310-9956-ffa450edef68
* changed the API based on the discussions with rafi and arnaud. also fixed ↵Rajith Muditha Attapattu2007-08-0810-366/+221
| | | | | | the compilation errors git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@563959 13f79535-47bb-0310-9956-ffa450edef68
* implemented Message Arnaud Simon2007-08-086-103/+515
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@563917 13f79535-47bb-0310-9956-ffa450edef68
* implemented Session.sync()Rafael H. Schloming2007-08-084-24/+31
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@563738 13f79535-47bb-0310-9956-ffa450edef68
* changed messageFlush to return an intArnaud Simon2007-08-071-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@563420 13f79535-47bb-0310-9956-ffa450edef68
* changed messageFlush to return an intArnaud Simon2007-08-071-3/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@563417 13f79535-47bb-0310-9956-ffa450edef68
* changed messageFlush to return an intArnaud Simon2007-08-071-489/+483
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@563416 13f79535-47bb-0310-9956-ffa450edef68
* fixed compilation errorsRajith Muditha Attapattu2007-08-0619-69/+70
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@563312 13f79535-47bb-0310-9956-ffa450edef68
* Implemented queue browsing Arnaud Simon2007-08-064-13/+267
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@563226 13f79535-47bb-0310-9956-ffa450edef68
* Added dtx classesArnaud Simon2007-08-068-44/+657
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@563197 13f79535-47bb-0310-9956-ffa450edef68
* moved from nclientArnaud Simon2007-08-0654-0/+10413
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@563134 13f79535-47bb-0310-9956-ffa450edef68
* moved in common Arnaud Simon2007-08-061-592/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@563132 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status