summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* QPID-52: use of tr1 and unordered_map break build or RHEL4.Alan Conway2006-10-2420-66/+36
| | | | | | | | | Replaced unordered_map with std::map. Use boost::shared_ptr instead of std::tr1::shared_ptr. Since we're using boost for other things now anyway it's simpler & more portable. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@467329 13f79535-47bb-0310-9956-ffa450edef68
* QPID-44Martin Ritchie2006-10-241-1/+1
| | | | | | | Fixed test for high and low water marks. Had AMQChannel.UnacknowledgedMessage rather than simply UnacknowledgedMessage. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@467315 13f79535-47bb-0310-9956-ffa450edef68
* Code style fixes, white space removal.Martin Ritchie2006-10-241-61/+71
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@467314 13f79535-47bb-0310-9956-ffa450edef68
* QPID-48Martin Ritchie2006-10-244-42/+160
| | | | | | | | | | Enabled buffer compression on delivery queue as a configuration option from the xml.(advanced.compressBufferOnQueue) Changed DeliveryManager.java to use ConcurrentLinkedQueueNoSize.java this is the standard ConcurrentLinkedQueue but where the size() method returns 0(empty) or 1(has content) as it is an expensive operation. Previously there was a race condition with the use of the _queueing boolean. Under load the consumer would sometimes stop getting messages. This was due to the messages being enqueued without starting the Worker thread. There is still an issue (QPID-54) on high receiving load messages rate received by a client drops. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@467313 13f79535-47bb-0310-9956-ffa450edef68
* QPID-44Martin Ritchie2006-10-242-38/+151
| | | | | | | | | Added High and Low water marking to AMQChannel.java. Currently the low water mark defaults to half the High value. Test for high and low water marks. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@467310 13f79535-47bb-0310-9956-ffa450edef68
* Tidy-up of generated codeKim van der Riet2006-10-231-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@466979 13f79535-47bb-0310-9956-ffa450edef68
* Some code tidy-upKim van der Riet2006-10-235-11/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@466972 13f79535-47bb-0310-9956-ffa450edef68
* corrected URLCarl C. Trieloff2006-10-201-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@466241 13f79535-47bb-0310-9956-ffa450edef68
* Moved cygwin test to top, causing problems on Unix.Alan Conway2006-10-201-5/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@466127 13f79535-47bb-0310-9956-ffa450edef68
* Fixed deps to ensure unit tests are built.Gordon Sim2006-10-201-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@466113 13f79535-47bb-0310-9956-ffa450edef68
* Updated stylesheet for generator such that a const reference is used where a ↵Gordon Sim2006-10-201-1/+1
| | | | | | | | | | FieldTable is passed as an argument to a method body. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@466100 13f79535-47bb-0310-9956-ffa450edef68
* QPID-48Martin Ritchie2006-10-201-3/+22
| | | | | | Addition to be used from DeliveryManager.java to reduce the size of the ByteBuffer when queuing messages to reduce overall memory footprint. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@466082 13f79535-47bb-0310-9956-ffa450edef68
* Modified to maintain a reference to the lastWriteFuture. This is then used ↵Martin Ritchie2006-10-201-1/+16
| | | | | | when closing the ProtocolSession to join on so that we can be sure all data has been written to the broker. A time out of 2 minutes ensures that the client doesn't hang for ever if the broker fails. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@466078 13f79535-47bb-0310-9956-ffa450edef68
* Resolution to QPID-23Martin Ritchie2006-10-206-0/+960
| | | | | | | | | | | Added Simple JNDI SPI Class that uses a PropertiesFile to create a ContextFactory for use with in JNDI. Added a unit test to test using properties file to get correct objects from JNDI lookup. Modifed AMQHeadersExchange.java to allow creation from a BindingURL. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@466076 13f79535-47bb-0310-9956-ffa450edef68
* Introduced log prefix and suffix as per QPID-13Marnie McCormack2006-10-201-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@466046 13f79535-47bb-0310-9956-ffa450edef68
* Added log prefix/suffix handling as per QPID-13Marnie McCormack2006-10-201-3/+37
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@466045 13f79535-47bb-0310-9956-ffa450edef68
* Further fixes and some extra tests for transactions.Gordon Sim2006-10-1915-338/+668
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@465549 13f79535-47bb-0310-9956-ffa450edef68
* Fixed various minor TODO issues.Alan Conway2006-10-1913-73/+33
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@465432 13f79535-47bb-0310-9956-ffa450edef68
* Remove bad assertAlan Conway2006-10-181-3/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@465428 13f79535-47bb-0310-9956-ffa450edef68
* Fix build problems in makefile & client tests.Alan Conway2006-10-184-29/+27
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@465407 13f79535-47bb-0310-9956-ffa450edef68
* Initial checkin of code generator (Java only at this stage) which allows for ↵Kim van der Riet2006-10-1832-0/+16565
| | | | | | the simultaneous support of multiple AMQP versions. This is a temporary location, for comment and evaluation purposes only. This generator is NOT integrated with the rest of the QPID project; it is intended for stand-alone use only for now. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@465322 13f79535-47bb-0310-9956-ffa450edef68
* QPID-36 Added high/low water mark to DUPS_OK_ACKNOWLEDGE.Martin Ritchie2006-10-184-25/+95
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@465166 13f79535-47bb-0310-9956-ffa450edef68
* Fix core dump if address in use.Alan Conway2006-10-174-7/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@465054 13f79535-47bb-0310-9956-ffa450edef68
* Fix #include dependencies.Alan Conway2006-10-171-0/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@465017 13f79535-47bb-0310-9956-ffa450edef68
* Removed dependencies on linked libraries to avoid needless relinking.Alan Conway2006-10-172-7/+7
| | | | | | | Header dependencies will cause libraries to relink when necessary. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@465005 13f79535-47bb-0310-9956-ffa450edef68
* Implemented Client side high/low water mark prefetching for NO_ACK.Martin Ritchie2006-10-176-108/+198
| | | | | | Use of single prefetch should be unaffected. Setting the high and low to be the same. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@464950 13f79535-47bb-0310-9956-ffa450edef68
* Added test for simple commit and rollback.Gordon Sim2006-10-174-0/+163
| | | | | | | | | Updated 'failing' lists Fix for amqp methods with no arguments git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@464943 13f79535-47bb-0310-9956-ffa450edef68
* AMQQueueMBean - management notifications will be sent to the listening ↵Bhupendra Bhusman Bhardwaj2006-10-172-22/+85
| | | | | | clients if the queue size increases the threshold value or a message with size higher than threshold value is received. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@464900 13f79535-47bb-0310-9956-ffa450edef68
* Fixes to transaction handling.Gordon Sim2006-10-1720-104/+1075
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | - This line, and those below, will be ignored-- M java/broker/test/src/org/apache/qpid/server/UnitTests.java M java/broker/test/src/org/apache/qpid/server/queue/DeliveryManagerTest.java A java/broker/test/src/org/apache/qpid/server/txn AM java/broker/test/src/org/apache/qpid/server/txn/UnitTests.java AM java/broker/test/src/org/apache/qpid/server/txn/TxnBufferTest.java M java/broker/test/src/org/apache/qpid/server/util/UnitTests.java AM java/broker/test/src/org/apache/qpid/server/util/OrderedMapHelperTest.java M java/broker/src/org/apache/qpid/server/queue/SubscriptionImpl.java M java/broker/src/org/apache/qpid/server/queue/DeliveryManager.java AM java/broker/src/org/apache/qpid/server/queue/FailedDequeueException.java M java/broker/src/org/apache/qpid/server/queue/AMQMessage.java M java/broker/src/org/apache/qpid/server/queue/AMQQueue.java M java/broker/src/org/apache/qpid/server/queue/Subscription.java M java/broker/src/org/apache/qpid/server/queue/NoConsumersException.java M java/broker/src/org/apache/qpid/server/AMQChannel.java M java/broker/src/org/apache/qpid/server/txn/TxnBuffer.java M java/broker/src/org/apache/qpid/server/txn/TxnOp.java AM java/broker/src/org/apache/qpid/server/util/OrderedMapHelper.java M java/broker/src/org/apache/qpid/server/handler/TxCommitHandler.java AM java/client/test/src/org/apache/qpid/transacted/UnitTests.java M java/client/test/src/org/apache/qpid/client/AllClientUnitTests.java git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@464867 13f79535-47bb-0310-9956-ffa450edef68
* Re enable python tests accidentally commented out in previous checkin.Alan Conway2006-10-161-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@464631 13f79535-47bb-0310-9956-ffa450edef68
* Fix problem with generated code re-starting makefile.Alan Conway2006-10-161-14/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@464629 13f79535-47bb-0310-9956-ffa450edef68
* Link with absolute paths to qpid libs so exes work anywhere.Alan Conway2006-10-161-4/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@464614 13f79535-47bb-0310-9956-ffa450edef68
* Add apr-1/ prefix to APR #includes to pick up from standard location.Alan Conway2006-10-1616-31/+31
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@464577 13f79535-47bb-0310-9956-ffa450edef68
* Renamed unit tests to follow naming conventions, fixed some #include ↵Alan Conway2006-10-1653-165/+161
| | | | | | inconsistencies. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@464503 13f79535-47bb-0310-9956-ffa450edef68
* Build system reorg, see README and Makefile comments for details.Alan Conway2006-10-16192-935/+602
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@464494 13f79535-47bb-0310-9956-ffa450edef68
* Added new method from Mina 1.0Martin Ritchie2006-10-131-0/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@463674 13f79535-47bb-0310-9956-ffa450edef68
* Added Sun FSContext to client-test libMartin Ritchie2006-10-138-32/+100
| | | | | | Updated referenceabletest files to use the temporary directory reported by the System.properties. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@463671 13f79535-47bb-0310-9956-ffa450edef68
* Now defaults to use our own thread pool which offers much better throughput ↵Robert Greig2006-10-131-1/+1
| | | | | | than the MINA one. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@463662 13f79535-47bb-0310-9956-ffa450edef68
* Moved AMQVMBrokerCreationException into correct package.Robert Greig2006-10-124-6/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@463410 13f79535-47bb-0310-9956-ffa450edef68
* QPID-18. Removed unused experimental code that had direct dependencies on ↵Robert Greig2006-10-1225-3423/+15
| | | | | | MINA-0.9.5 and upgraded to MINA-1.1.0 snapshot. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@463403 13f79535-47bb-0310-9956-ffa450edef68
* Fixed incorrect package on AMQVMBrokerCreationException (did not match ↵Robert Greig2006-10-1210-52/+27
| | | | | | physical location). git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@463397 13f79535-47bb-0310-9956-ffa450edef68
* Converted broker to a class for use in tests, plugins etc.Alan Conway2006-10-1223-138/+465
| | | | | | | | qpid::Exception base class for all exceptions, inherits std::exception. Require boost on all platforms: http://www.boost.org, 'yum boost' on fedora. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@463376 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2. JMSBytesMessage.readXXX methods now test the appropriate number of ↵Robert Greig2006-10-122-4/+254
| | | | | | bytes are available in the message and throw the appropriate exception if not. Unit test updated to check behaviour of readXXX methods. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@463363 13f79535-47bb-0310-9956-ffa450edef68
* Fixed ack.RecoverTest and ack.DisconnectAndRedeliverTest. These were failing ↵Gordon Sim2006-10-123-7/+21
| | | | | | | | | | | | | | | due to a race condition where the consumers queue was not bound by the time the publisher sent messages. This is a result of the use of nowait=true for the declare/bind/consume cycle for a BasicMessageConsumer. To work around this in tests like these that have two connections, one consuming & one publishing, I added a declareExchangeSynch() method to AMQSession which allows a thread to block until the session it invokes that method on has processed all the commands up to that point. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@463309 13f79535-47bb-0310-9956-ffa450edef68
* Fixed bug causing ChannelTest.testDeliveryNoAck to fail intermittently.Gordon Sim2006-10-122-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@463179 13f79535-47bb-0310-9956-ffa450edef68
* Renamed to follow naming conventions.Alan Conway2006-10-112-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@463072 13f79535-47bb-0310-9956-ffa450edef68
* Added a little extra debug to the toString()Martin Ritchie2006-10-111-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@462840 13f79535-47bb-0310-9956-ffa450edef68
* Turned up gcc warnings, fixed warnings in code, enabled -Werror.Alan Conway2006-10-1186-787/+540
| | | | | | | | Note: #include "qpid_test_plugin.h" instead of <cppunit/TestPlugin.h> Works around warning from a cppunit macro. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@462834 13f79535-47bb-0310-9956-ffa450edef68
* Added extra debug output when failover fails.Martin Ritchie2006-10-111-4/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@462820 13f79535-47bb-0310-9956-ffa450edef68
* Implementation of basic_get.Gordon Sim2006-10-119-28/+215
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@462729 13f79535-47bb-0310-9956-ffa450edef68