summaryrefslogtreecommitdiff
path: root/java
Commit message (Collapse)AuthorAgeFilesLines
...
* This contain fixes for compilation errors in the systests packageRajith Muditha Attapattu2007-01-248-103/+273
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499612 13f79535-47bb-0310-9956-ffa450edef68
* Fix for TextMessageTest failureKim van der Riet2007-01-241-7/+61
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499571 13f79535-47bb-0310-9956-ffa450edef68
* Filled in MessageRecoverHandler.Rafael H. Schloming2007-01-241-3/+18
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499551 13f79535-47bb-0310-9956-ffa450edef68
* Content.writePayload now handles a null byte bufferRafael H. Schloming2007-01-241-2/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499550 13f79535-47bb-0310-9956-ffa450edef68
* fixed NPE in AMQMessage, _taken was not being initialized from some ↵Rafael H. Schloming2007-01-241-2/+1
| | | | | | constructors, now it is initialized on declaration git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499549 13f79535-47bb-0310-9956-ffa450edef68
* Fixed problem with missing type field in Message.transport. Used JMSHeaders ↵Kim van der Riet2007-01-245-61/+82
| | | | | | instead. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499525 13f79535-47bb-0310-9956-ffa450edef68
* fixed headers exchange, filled in more stubsRafael H. Schloming2007-01-233-10/+32
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499163 13f79535-47bb-0310-9956-ffa450edef68
* added missing ByteBuffer.duplicate()Rafael H. Schloming2007-01-231-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499134 13f79535-47bb-0310-9956-ffa450edef68
* fixed compile errorRafael H. Schloming2007-01-231-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499133 13f79535-47bb-0310-9956-ffa450edef68
* removed leftover printlnsRafael H. Schloming2007-01-231-2/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499123 13f79535-47bb-0310-9956-ffa450edef68
* removed XXX from resend, centralized message deliver, cleaned up exception ↵Rafael H. Schloming2007-01-2310-186/+215
| | | | | | handling, added per channel max frame size git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499121 13f79535-47bb-0310-9956-ffa450edef68
* Modified Content to make get methods to be non-consuming through use of ↵Kim van der Riet2007-01-237-34/+46
| | | | | | light-weight copys. Shortened name of Content type enum. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499030 13f79535-47bb-0310-9956-ffa450edef68
* Synchronized the toString method in the Content classRajith Muditha Attapattu2007-01-223-3/+30
| | | | | | | | Removed commented code from the BasicMessageProducer git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@498804 13f79535-47bb-0310-9956-ffa450edef68
* Added session close convinience methods to broker ProtocolSession, modified ↵Kim van der Riet2007-01-2210-177/+153
| | | | | | handlers that need to close a session to use new methods. Added logger to RequestManager and ResponseManager. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@498797 13f79535-47bb-0310-9956-ffa450edef68
* Addded toString() to Content to aid in debuggingKim van der Riet2007-01-221-0/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@498664 13f79535-47bb-0310-9956-ffa450edef68
* Improvements to debugging messages from Request/ResponseManager. Added timed ↵Kim van der Riet2007-01-226-25/+73
| | | | | | wait for Channel.CloseOk massage in broker's closeChannelRequest method. Added checks for illegal frames that would open a closed channel git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@498631 13f79535-47bb-0310-9956-ffa450edef68
* replaced Hashtable with ConcurrentHashMap to solve intermittant ↵Rafael H. Schloming2007-01-192-7/+7
| | | | | | ConcurrentModificationException git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497992 13f79535-47bb-0310-9956-ffa450edef68
* Put the exchange name into destinationRafael H. Schloming2007-01-191-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497991 13f79535-47bb-0310-9956-ffa450edef68
* Introduced channel close methods into AMQMinaProtocolSession.java; ↵Kim van der Riet2007-01-1952-330/+311
| | | | | | Refactored StateAwareMethodListener.java to simplify call and remove redundant parameters, reworked all affected handlers. Connected the AMQP version information to the protocol session in all broker handlers. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497974 13f79535-47bb-0310-9956-ffa450edef68
* route on destination rather than exchangeRafael H. Schloming2007-01-192-4/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497949 13f79535-47bb-0310-9956-ffa450edef68
* added logic to handle the Reference case when transfering large messagesRajith Muditha Attapattu2007-01-191-64/+102
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497906 13f79535-47bb-0310-9956-ffa450edef68
* Solved multithreading issue in RequestManager where responses would arrive ↵Kim van der Riet2007-01-195-9/+15
| | | | | | before the request made it into the requestMap. Fixed server's ChannelCloseHandler and ConnectionCloseMethodHandler to work with new write methods. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497820 13f79535-47bb-0310-9956-ffa450edef68
* fixed 2 compilation errosRajith Muditha Attapattu2007-01-182-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497633 13f79535-47bb-0310-9956-ffa450edef68
* implemented the logic for MessageTransfer and MessageAppendRajith Muditha Attapattu2007-01-189-90/+105
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497616 13f79535-47bb-0310-9956-ffa450edef68
* Changed Content to use ByteBuffer, added Message.Transfer and Message.Cancel ↵Kim van der Riet2007-01-187-28/+42
| | | | | | handlers git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497585 13f79535-47bb-0310-9956-ffa450edef68
* made message-transfer return a result, switched over message delivery to use ↵Rafael H. Schloming2007-01-182-29/+29
| | | | | | message-transfer, added a generated .copy() to method bodies, and made hello-world acknowledge the message it sends to itself git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497515 13f79535-47bb-0310-9956-ffa450edef68
* Completed broker MessageQosHandlerKim van der Riet2007-01-181-1/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497489 13f79535-47bb-0310-9956-ffa450edef68
* Fixed minor bug in AMQResponseBody.toString()Kim van der Riet2007-01-181-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497483 13f79535-47bb-0310-9956-ffa450edef68
* Client: added request and response managers for channel 0Kim van der Riet2007-01-181-0/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497450 13f79535-47bb-0310-9956-ffa450edef68
* Cleared all the cluster compile errors. This now opens the way to testing...Kim van der Riet2007-01-1817-88/+107
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497445 13f79535-47bb-0310-9956-ffa450edef68
* filled out consume and transfer handlersRafael H. Schloming2007-01-188-79/+286
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497278 13f79535-47bb-0310-9956-ffa450edef68
* Last of client compile errors and exceptionsKim van der Riet2007-01-173-14/+25
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497195 13f79535-47bb-0310-9956-ffa450edef68
* Solved remaining compile problems in client except for missing line in ↵Kim van der Riet2007-01-174-43/+74
| | | | | | UnprocessedMessage.java file. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497179 13f79535-47bb-0310-9956-ffa450edef68
* fixed the compilation errors in the message classes and changed to use ↵Rajith Muditha Attapattu2007-01-1717-84/+87
| | | | | | MessageHeaders instead of the old ContentHeaders class git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497169 13f79535-47bb-0310-9956-ffa450edef68
* The method signatures are changed to use the new MessageHeaders and Content ↵Rajith Muditha Attapattu2007-01-171-4/+3
| | | | | | classes git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497162 13f79535-47bb-0310-9956-ffa450edef68
* This contains modifications to create messages using the new MessageHeaders ↵Rajith Muditha Attapattu2007-01-171-12/+10
| | | | | | and Content classes git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497161 13f79535-47bb-0310-9956-ffa450edef68
* Conversion of client/BasicMessageProducer to new Message classKim van der Riet2007-01-172-54/+62
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497138 13f79535-47bb-0310-9956-ffa450edef68
* Fixed typo in client/AMQSession.java from last checkinKim van der Riet2007-01-171-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497093 13f79535-47bb-0310-9956-ffa450edef68
* added error handling and resolved compilation errorsRajith Muditha Attapattu2007-01-171-20/+45
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497078 13f79535-47bb-0310-9956-ffa450edef68
* added error handling and resolved compilation errorsRajith Muditha Attapattu2007-01-172-3/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497063 13f79535-47bb-0310-9956-ffa450edef68
* Filled in the MessageTransferMethodHandler and added a few fields to the ↵Rajith Muditha Attapattu2007-01-177-53/+87
| | | | | | | | | | MessageHeaders class. Minor modifications to AMQProtocolSession to directly fire the unprocessed message to AMQSession instead of strong in a map. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497062 13f79535-47bb-0310-9956-ffa450edef68
* Corrected typoKim van der Riet2007-01-161-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496874 13f79535-47bb-0310-9956-ffa450edef68
* Created wiring to client RequestManagers and ResponseManagers, refactored ↵Kim van der Riet2007-01-1613-154/+244
| | | | | | all frame write code to use new write mechanisms. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496873 13f79535-47bb-0310-9956-ffa450edef68
* fixed several encoding/decoding bugsRafael H. Schloming2007-01-165-11/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496812 13f79535-47bb-0310-9956-ffa450edef68
* fixed a braino in ConnectionStartOkRafael H. Schloming2007-01-161-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496810 13f79535-47bb-0310-9956-ffa450edef68
* added request/response factories to AMQDataBlockDecoderRafael H. Schloming2007-01-164-2/+15
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496768 13f79535-47bb-0310-9956-ffa450edef68
* Removed the generics from the client handlersRajith Muditha Attapattu2007-01-1610-21/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496732 13f79535-47bb-0310-9956-ffa450edef68
* fixed broker compile errorsRafael H. Schloming2007-01-1636-397/+407
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496586 13f79535-47bb-0310-9956-ffa450edef68
* Changed the RequestManager to use AMQMethodListener instead of the old ↵Kim van der Riet2007-01-156-64/+35
| | | | | | AMQResponseCallback. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496499 13f79535-47bb-0310-9956-ffa450edef68
* Added a request/response id to the MethodEvent class that is used to ↵Kim van der Riet2007-01-154-23/+43
| | | | | | dispatch incoming messages to the handlers. Corrected some compile errors. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496456 13f79535-47bb-0310-9956-ffa450edef68