summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* * moved most of the classes in the org.apache.qpidity package toRafael H. Schloming2007-09-1384-1639/+1511
| | | | | | | | | | | | | | | | | | | | org.apache.qpidity.transport * factored out the network specific pieces into org.apache.qpidity.transport * moved the mina specific code to org.apache.qpidity.transport.network.mina * replaced the handler chain with Sender/Receiver chains that can deal with close request/closed notifications * moved from an anonymous struct[] to a real Header class * removed an excess copy from message data transmit git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@575474 13f79535-47bb-0310-9956-ffa450edef68
* Use frameset begin/end flags for determining frameset boundaries.Gordon Sim2007-09-1328-180/+240
| | | | | | | | Set frameset & segment begin/end flags for content bearing methods (i.e. messages). git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@575377 13f79535-47bb-0310-9956-ffa450edef68
* updated message hierarchy for using 0_10 messagesArnaud Simon2007-09-1320-197/+317
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@575289 13f79535-47bb-0310-9956-ffa450edef68
* QPID-572 Applied test patch supplied by Aidan Skinner along with change to ↵Martin Ritchie2007-09-122-1/+159
| | | | | | ConcurrentSelectorDeliveryManager that resolves the ordering problem. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574982 13f79535-47bb-0310-9956-ffa450edef68
* In ClientChannel: Use subscribe and flush in place of get; use ↵Gordon Sim2007-09-1226-98/+405
| | | | | | | | | | per-subscriber flow control for managing prefetches. In brokers Session: set credit to 0 when subscription is created (modified python tests accordingly) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574979 13f79535-47bb-0310-9956-ffa450edef68
* * Python: reinstated 0-8 framing in parallel with the new 0-10 framingAndrew Stitcher2007-09-121-3/+33
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574936 13f79535-47bb-0310-9956-ffa450edef68
* * python/qpid/codec.pyAndrew Stitcher2007-09-125-25/+80
| | | | | | | | | | | | | | | | | Comment typo * cpp/src/qpid/broker/RecoveryManagerImpl.cpp Cruft removal * python/qpid/codec.py * python/qpid/connection.py * cpp/src/qpid/framing/AMQFrame.h * cpp/src/qpid/framing/AMQFrame.cpp Initial implementation of 0-10 framing - This uses the new 12 byte frame header, but doesn't support splitting segments/framesets over multiple frames yet. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574735 13f79535-47bb-0310-9956-ffa450edef68
* This is the first pass at refactoring the Connection stuff.Rajith Muditha Attapattu2007-09-114-231/+426
| | | | | | | | | | | | | | The AMQConnection was not made abstract to preserve the widely usd AMQConsutructor in test cases. Instead 0-8,0-10 specific functionality was delegated to a version specific delegate. The version is selected via a JVM argument (and based on the URL format) Currently this mean that we can test only a single code path (o-8 or 0-10) at a time. Next Step is to refactor the URL stuff. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574582 13f79535-47bb-0310-9956-ffa450edef68
* Moved old ClientChannel class from using basic to using message for publish ↵Gordon Sim2007-09-117-86/+112
| | | | | | | | | | & consume. (Get and qos still use the basic class's defintions, that will be changed next) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574551 13f79535-47bb-0310-9956-ffa450edef68
* Support for keyword args in session interfaceGordon Sim2007-09-104-36/+101
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574323 13f79535-47bb-0310-9956-ffa450edef68
* memory clean up fixCarl C. Trieloff2007-09-101-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574284 13f79535-47bb-0310-9956-ffa450edef68
* added message flow mode window Arnaud Simon2007-09-101-2/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574255 13f79535-47bb-0310-9956-ffa450edef68
* added 0_10 factoryArnaud Simon2007-09-101-1/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574227 13f79535-47bb-0310-9956-ffa450edef68
* updated recoverArnaud Simon2007-09-101-8/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574226 13f79535-47bb-0310-9956-ffa450edef68
* git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574225 ↵Arnaud Simon2007-09-102-17/+2
| | | | 13f79535-47bb-0310-9956-ffa450edef68
* added AbstractJMSMessage createJMSMessageFromUnprocessedMessageArnaud Simon2007-09-101-3/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574223 13f79535-47bb-0310-9956-ffa450edef68
* removed AbstractJMSMessage createJMSMessageFromUnprocessedMessageArnaud Simon2007-09-101-9/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574222 13f79535-47bb-0310-9956-ffa450edef68
* git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574221 ↵Arnaud Simon2007-09-103-0/+707
| | | | 13f79535-47bb-0310-9956-ffa450edef68
* Client side support for message and delivery properties in header segments.Gordon Sim2007-09-1021-106/+330
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574176 13f79535-47bb-0310-9956-ffa450edef68
* updates to be able to manage lifecycle of async storeCarl C. Trieloff2007-09-086-11/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@573762 13f79535-47bb-0310-9956-ffa450edef68
* interface to hang external journal's per queue onto a PersistableQueueCarl C. Trieloff2007-09-061-1/+26
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@573367 13f79535-47bb-0310-9956-ffa450edef68
* Implementation of execution.result on the client side Gordon Sim2007-09-0641-265/+865
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@573359 13f79535-47bb-0310-9956-ffa450edef68
* 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@573282 13f79535-47bb-0310-9956-ffa450edef68
* * Tidy up framing::Buffer classAndrew Stitcher2007-09-062-47/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@573213 13f79535-47bb-0310-9956-ffa450edef68
* - removed profiler from configureCarl C. Trieloff2007-09-051-3/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@573065 13f79535-47bb-0310-9956-ffa450edef68
* applied Nuno's patchCarl C. Trieloff2007-09-052-1/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@573059 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@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@572751 13f79535-47bb-0310-9956-ffa450edef68
* added debugging utility methodRafael H. Schloming2007-09-041-0/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@572750 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@572656 13f79535-47bb-0310-9956-ffa450edef68
* Initial implementation (plus very simple tests) of message.acquire, ↵Gordon Sim2007-09-0317-68/+356
| | | | | | message.release, message.reject and message.flush. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@572394 13f79535-47bb-0310-9956-ffa450edef68
* Fix for QPID-561Gordon Sim2007-09-033-12/+4
| | | | | | | | Renabled MessageBuilderTest git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@572264 13f79535-47bb-0310-9956-ffa450edef68
* Removed BrokerChannel.cpp, .h: replaced by Session.cpp, .hAlan Conway2007-08-312-705/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@571577 13f79535-47bb-0310-9956-ffa450edef68
* * Summary:Alan Conway2007-08-3126-428/+1117
| | | | | | | | | | | | | | | | | | | | | | | | | | - Moved BrokerChannel functionality into Session. - Moved ChannelHandler methods handling into SessionAdapter. - Updated all handlers to use session. (We're still using AMQP channel methods in SessionAdapter) Roles & responsibilities: Session: - represents an _open_ session, may be active or suspended. - ows all session state including handler chains. - attahced to SessionAdapter when active, not when suspended. SessionAdapter: - reprents the association of a channel with a session. - owned by Connection, kept in the session map. - channel open == SessionAdapter.getSessio() != 0 Anything that depends on attachment to a channel, connection or protocol should be in SessionAdpater. Anything that suvives a session suspend belongs in Session. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@571575 13f79535-47bb-0310-9956-ffa450edef68
* * Changes to make C++ client code use the asynchronous network IOAndrew Stitcher2007-08-3115-193/+309
| | | | | | | | * Fixed up the test for buffer changes * Removed unused buffer operations git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@571529 13f79535-47bb-0310-9956-ffa450edef68
* Pass QueuedMessage to queues consumers. This records the position of that ↵Gordon Sim2007-08-3111-79/+96
| | | | | | message in the queue which is need to handle rlease and acquire. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@571518 13f79535-47bb-0310-9956-ffa450edef68
* QPID-554 Patch submitted by Jia Jia to add viewing of binary content in ↵Martin Ritchie2007-08-318-154/+502
| | | | | | messages. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@571491 13f79535-47bb-0310-9956-ffa450edef68
* Fixed bug where stale iterator is used.Gordon Sim2007-08-311-4/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@571410 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@571367 13f79535-47bb-0310-9956-ffa450edef68
* Fix compile errors in generated code.Alan Conway2007-08-302-4/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@571347 13f79535-47bb-0310-9956-ffa450edef68
* fixed a race condition causing intermittant test failures in ↵Rafael H. Schloming2007-08-301-40/+49
| | | | | | AMQBrokerManagerMBeanTest git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@571277 13f79535-47bb-0310-9956-ffa450edef68
* - Update cluster code to work with new FrameHandlerAlan Conway2007-08-3014-152/+136
| | | | | | | | - Update ClassifierHandler to use Visitor rather than map. - Replace heap allocation in cluster classes with boost::optional. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@571246 13f79535-47bb-0310-9956-ffa450edef68
* * configure.ac: Disabled cluster build temporarily while fixing build problems.Alan Conway2007-08-302-1/+5
| | | | | | | * src/qpid/framing/Handler.h: Add missing default constructor. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@571161 13f79535-47bb-0310-9956-ffa450edef68
* Remerge of M2. All tests pass locallyMartin Ritchie2007-08-30198-6815/+17361
| | | | | | | | | | | | | | | | 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@571129 13f79535-47bb-0310-9956-ffa450edef68
* * src/qpid/broker/Session.h, .cpp: Session holds all state of a session ↵Alan Conway2007-08-2917-199/+294
| | | | | | | | | | | | | | | | | | | | | | | including handlers created for that session. Session is not directly associated with a channel. * src/qpid/broker/SessionAdapter.h, .cpp: SessionAdapter is bound to a channel managed by the Connection. It can be attached to and detatched from a Session. * src/qpid/broker/Connection.cpp, .h: Use SessionAdapter. * src/qpid/framing/Handler.h: Removed use of shared_ptr. Handlers belong either to a Session or a Connection and are destroyed with it. * src/qpid/framing/InputHandler.h, OutputHandler.h: Both now inherit from FrameHandler and can be used as FrameHandlers. Intermediate step to removing them entirely. * src/qpid/broker/ConnectionAdapter.h: * src/qpid/client/ConnectionHandler.h: * src/qpid/framing/ChannelAdapter.cpp, .h: Minor changes required by Handler changes. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@570982 13f79535-47bb-0310-9956-ffa450edef68
* Remove Java from code generation check.Alan Conway2007-08-291-3/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@570855 13f79535-47bb-0310-9956-ffa450edef68
* * rubygen/cppgen.rb: Use class Uuid for AMQP uuids.Alan Conway2007-08-292-5/+2
| | | | | | | * rubygen/templates/structs.rb: Use class Uuid for AMQP uuids. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@570595 13f79535-47bb-0310-9956-ffa450edef68
* Generate constants and reply exceptions from spec constants.Alan Conway2007-08-283-5/+50
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@570540 13f79535-47bb-0310-9956-ffa450edef68
* Updated message.transfer encoding to use header and content segments ↵Gordon Sim2007-08-28117-3746/+2032
| | | | | | | | | | (including new structs). Unified more between the basic and message classes messages. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@570538 13f79535-47bb-0310-9956-ffa450edef68
* Updated ignoresAndrew Stitcher2007-08-280-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@570502 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status