summaryrefslogtreecommitdiff
path: root/java
Commit message (Collapse)AuthorAgeFilesLines
* 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
* Changed static method AMQMethodBody.createAMQFrame() to createMessageBody() ↵Kim van der Riet2007-01-155-101/+53
| | | | | | for all generated classes so that it can be used with the new Request and Response handlers. (Don't forget to update the gentools dir.) Created new methods AMQMinaProtocolSession.writeRequest() and writeResponse() as new entry points for Request and Response framing. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496439 13f79535-47bb-0310-9956-ffa450edef68
* Request and Respone managers now use the new common AMQMethodListener classKim van der Riet2007-01-154-86/+44
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496389 13f79535-47bb-0310-9956-ffa450edef68
* Merged the refactor to a common AMQMethodListener class on trunk, plus the ↵Kim van der Riet2007-01-1515-103/+124
| | | | | | race condition fix of Robert Godfrey. This opens the way for Request and Response managers to use a common event dispatch for both client and server. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496326 13f79535-47bb-0310-9956-ffa450edef68
* Refactored to create a common AMQMethodEvent class; Added clinet Method* ↵Kim van der Riet2007-01-1291-432/+888
| | | | | | handlers, removed old Basic* handlers. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@495581 13f79535-47bb-0310-9956-ffa450edef68
* new class to hold message headersRajith Muditha Attapattu2007-01-121-0/+633
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@495451 13f79535-47bb-0310-9956-ffa450edef68
* Split the RequestResponseManager into RequestManager and ResponseManager ↵Kim van der Riet2007-01-113-48/+230
| | | | | | since these two functions are independent of each other. Also added a new exception. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@495251 13f79535-47bb-0310-9956-ffa450edef68
* Compilation fixes. The idea is to substitute the Basic methods with the new ↵Rajith Muditha Attapattu2007-01-1013-217/+266
| | | | | | Message class git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@495043 13f79535-47bb-0310-9956-ffa450edef68
* Created new common interfaces to support the RequestResponseManager on both ↵Kim van der Riet2007-01-105-31/+94
| | | | | | client and server git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@495000 13f79535-47bb-0310-9956-ffa450edef68
* First version of RequestResponseHandler for an idea of how the ↵Kim van der Riet2007-01-104-64/+303
| | | | | | RequestResponse frames will be managed... Not quite complete, still need to find a means of writing the frames that is common to both client and server. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@494962 13f79535-47bb-0310-9956-ffa450edef68
* Oops - fixed a rather glaring compile error that I should not have missed :-(Kim van der Riet2007-01-092-6/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@494554 13f79535-47bb-0310-9956-ffa450edef68
* Corrected errors in AMQResponseBodyKim van der Riet2007-01-092-6/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@494549 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status