summaryrefslogtreecommitdiff
path: root/java/broker
Commit message (Collapse)AuthorAgeFilesLines
* adding synapse exchangeRajith Muditha Attapattu2007-07-2413-18/+605
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/client_restructure@558903 13f79535-47bb-0310-9956-ffa450edef68
* Recorded rollback of revisions 492756 via svnmerge from Alan Conway2007-03-141-3/+3
| | | | | | | https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@518198 13f79535-47bb-0310-9956-ffa450edef68
* Merged revisions 492756 via svnmerge from Alan Conway2007-03-091-8/+8
| | | | | | | | | | | | | https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid ........ r492756 | kpvdr | 2007-01-04 16:30:39 -0500 (Thu, 04 Jan 2007) | 1 line Fixed C++ client sending protocol version 0-0 over the wire. Minor fixes and tidy-up in related code. ........ git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@516485 13f79535-47bb-0310-9956-ffa450edef68
* Implementation of queue.unbind & message.getGordon Sim2007-02-239-22/+130
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510912 13f79535-47bb-0310-9956-ffa450edef68
* Fixed the various Ref modes so that the new MessageRefTest passes all tests.Kim van der Riet2007-02-201-12/+27
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@509738 13f79535-47bb-0310-9956-ffa450edef68
* Some fixes to get more python tests passing.Gordon Sim2007-02-209-138/+119
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@509616 13f79535-47bb-0310-9956-ffa450edef68
* Additions to allow refs to be sent from broker to client. Also some tidy-up.Kim van der Riet2007-02-165-112/+52
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508460 13f79535-47bb-0310-9956-ffa450edef68
* A few hacks and fixes to get the python tests running again.Gordon Sim2007-02-166-4/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508391 13f79535-47bb-0310-9956-ffa450edef68
* added support for reference caseRajith Muditha Attapattu2007-02-151-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508233 13f79535-47bb-0310-9956-ffa450edef68
* Fix for messages that stick around in unsubscribed queues after rollbackKim van der Riet2007-02-151-0/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508150 13f79535-47bb-0310-9956-ffa450edef68
* Adjusted mechanism for sending refs. (still in progress)Kim van der Riet2007-02-151-27/+33
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508098 13f79535-47bb-0310-9956-ffa450edef68
* Fix for RecoverTest which was failing because the redelivered flag was ↵Kim van der Riet2007-02-151-0/+2
| | | | | | disconnected git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507993 13f79535-47bb-0310-9956-ffa450edef68
* Fixes to get TransactedTest back, there are still unresolved issues with ↵Kim van der Riet2007-02-151-44/+41
| | | | | | rollback(), however. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507960 13f79535-47bb-0310-9956-ffa450edef68
* First backmerge from trunk to 0-9 branch for Java. Not all java tests ↵Kim van der Riet2007-02-14147-3324/+5488
| | | | | | passing yet git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507672 13f79535-47bb-0310-9956-ffa450edef68
* uncommented mandatory routing checkRafael H. Schloming2007-01-311-3/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@501850 13f79535-47bb-0310-9956-ffa450edef68
* reenabled mandatory testsRafael H. Schloming2007-01-301-3/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@501559 13f79535-47bb-0310-9956-ffa450edef68
* Moved across fixes from trunk for handling exclusive consumers and no_local ↵Gordon Sim2007-01-295-18/+59
| | | | | | | | | | | consumption. Fixed close process in AMQChannel (remove channel from map only after consumer cancellations have been processed). git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@501144 13f79535-47bb-0310-9956-ffa450edef68
* filled in a bunch of stubs in AMQMessage and made AMQMessage.getContents() ↵Rafael H. Schloming2007-01-293-11/+39
| | | | | | return duplicate ByteBuffers git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@501099 13f79535-47bb-0310-9956-ffa450edef68
* Moved across auto deletion functionailty for exclusive, non-durable queues ↵Gordon Sim2007-01-294-6/+92
| | | | | | (aka private queues). git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@501081 13f79535-47bb-0310-9956-ffa450edef68
* Fixes to get the python queue tests to work.Gordon Sim2007-01-2913-40/+244
| | | | | | | | (NB: currently, auto-delete is not in so tests that re-use the same exclusive queue conflict with each other) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@501021 13f79535-47bb-0310-9956-ffa450edef68
* Updated broker for issues highlighted by python tests. (e.g. fanout ↵Gordon Sim2007-01-2611-10/+285
| | | | | | exchange, default exchange rules etc) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@500303 13f79535-47bb-0310-9956-ffa450edef68
* Modified the protocol session to create channel zero by default. Updated the ↵Rafael H. Schloming2007-01-261-1/+2
| | | | | | AMQProtocolSessionMBeanTest accordingly git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@500282 13f79535-47bb-0310-9956-ffa450edef68
* Added mechanism to track connection ids for logging and debugging purposes. ↵Kim van der Riet2007-01-253-2/+15
| | | | | | Changed format of log/debug messages for RequestManager and ResponseManager. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499968 13f79535-47bb-0310-9956-ffa450edef68
* updated to use session's new close methodRafael H. Schloming2007-01-251-19/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499929 13f79535-47bb-0310-9956-ffa450edef68
* removed XXX exceptionRafael H. Schloming2007-01-251-1/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499928 13f79535-47bb-0310-9956-ffa450edef68
* Improved channel/connection exception handling.Gordon Sim2007-01-251-8/+37
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499880 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
* 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 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
* removed XXX from resend, centralized message deliver, cleaned up exception ↵Rafael H. Schloming2007-01-236-164/+194
| | | | | | 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-232-5/+5
| | | | | | 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
* Added session close convinience methods to broker ProtocolSession, modified ↵Kim van der Riet2007-01-228-172/+125
| | | | | | 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
* Improvements to debugging messages from Request/ResponseManager. Added timed ↵Kim van der Riet2007-01-223-8/+42
| | | | | | 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
* Introduced channel close methods into AMQMinaProtocolSession.java; ↵Kim van der Riet2007-01-1938-257/+251
| | | | | | 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
* Solved multithreading issue in RequestManager where responses would arrive ↵Kim van der Riet2007-01-192-5/+5
| | | | | | 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
* Changed Content to use ByteBuffer, added Message.Transfer and Message.Cancel ↵Kim van der Riet2007-01-184-5/+16
| | | | | | 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
* Cleared all the cluster compile errors. This now opens the way to testing...Kim van der Riet2007-01-181-0/+5
| | | | 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-187-78/+285
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497278 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
* fixed broker compile errorsRafael H. Schloming2007-01-1633-388/+387
| | | | 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-152-18/+8
| | | | | | 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-152-17/+30
| | | | | | 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-152-90/+42
| | | | | | 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-151-20/+0
| | | | 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-153-69/+26
| | | | | | 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-1241-200/+241
| | | | | | 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
View Lorry Controller Status