summaryrefslogtreecommitdiff
path: root/java/client
Commit message (Collapse)AuthorAgeFilesLines
* 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-1513-15/+258
| | | | | | | | | 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 filter into commonArnaud Simon2007-08-061-20/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@563135 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
* renamed to qpidity Arnaud Simon2007-08-0664-12047/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@563131 13f79535-47bb-0310-9956-ffa450edef68
* QPID-543 : Add ability to register cusom exchange typesRobert Godfrey2007-08-061-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@563125 13f79535-47bb-0310-9956-ffa450edef68
* git-svn-id: ↵Arnaud Simon2007-08-0612-162/+600
| | | | https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@563097 13f79535-47bb-0310-9956-ffa450edef68
* JMS message selector grammar Arnaud Simon2007-08-061-0/+592
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@563043 13f79535-47bb-0310-9956-ffa450edef68
* Added message selectorArnaud Simon2007-08-0513-89/+2129
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@562885 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status