summaryrefslogtreecommitdiff
path: root/java
Commit message (Collapse)AuthorAgeFilesLines
* Additions to build system to cause junit to produce a reportMartin Ritchie2006-10-314-1/+24
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@469491 13f79535-47bb-0310-9956-ffa450edef68
* Added stacktrace on failureMartin Ritchie2006-10-311-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@469478 13f79535-47bb-0310-9956-ffa450edef68
* Updated to programmatically set QPID_WORK for logging, to stop failed buildsMartin Ritchie2006-10-312-2/+16
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@469470 13f79535-47bb-0310-9956-ffa450edef68
* Added a sleep to give the VM broker time to create queues.Martin Ritchie2006-10-311-25/+37
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@469463 13f79535-47bb-0310-9956-ffa450edef68
* Committed development version by mistake.Martin Ritchie2006-10-311-11/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@469436 13f79535-47bb-0310-9956-ffa450edef68
* Added additional logging to diagnose issues when unable to create an in VM ↵Martin Ritchie2006-10-311-3/+17
| | | | | | broker git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@469430 13f79535-47bb-0310-9956-ffa450edef68
* QPID-56Martin Ritchie2006-10-312-0/+90
| | | | | | | | | Also resolves a race condition where an messages could be sent out of order. Modification of the Java ConcurrentLinkedQueue to provide a constant time size() method git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@469424 13f79535-47bb-0310-9956-ffa450edef68
* QPID-56Martin Ritchie2006-10-311-28/+18
| | | | | | | Also resolves a race condition where an messages could be sent out of order. This change needs to be benchmarked against original DeliveryManager.java with the race condition fixed. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@469422 13f79535-47bb-0310-9956-ffa450edef68
* Applied patchCarl C. Trieloff2006-10-271-5/+0
| | | | | | | | (JIRA-35) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@468538 13f79535-47bb-0310-9956-ffa450edef68
* Removed duplicate log4j classes. Jboss jar included old ones that are notGordon Sim2006-10-262-0/+0
| | | | | | | | compatible with latest code. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@468070 13f79535-47bb-0310-9956-ffa450edef68
* MBeans updated. Management operation implemented in HeadersExchangeBhupendra Bhusman Bhardwaj2006-10-255-22/+51
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@467700 13f79535-47bb-0310-9956-ffa450edef68
* MBean updated and corrected a code merging mistake.Bhupendra Bhusman Bhardwaj2006-10-251-4/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@467605 13f79535-47bb-0310-9956-ffa450edef68
* Cast to Throwable, not Exception.Gordon Sim2006-10-251-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@467589 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
* 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
* 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
* 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
* 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
* 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
* 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
* 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
* 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
* 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
* Amended log path to use QPID_WORK as per QPID-30Marnie McCormack2006-10-101-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@454782 13f79535-47bb-0310-9956-ffa450edef68
* Amended work dir to use $QPID_WORK, though slightly out of context without ↵Marnie McCormack2006-10-101-1/+1
| | | | | | bdb config refs as per QPID-30 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@454738 13f79535-47bb-0310-9956-ffa450edef68
* Added $QPID_WORK variable to allow configuration of writable dirs after ↵Marnie McCormack2006-10-101-1/+7
| | | | | | install as per QPID-30 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@454736 13f79535-47bb-0310-9956-ffa450edef68
* QPID-16 Removed unnecessary requeue operations.Steven Shaw2006-10-062-54/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@453539 13f79535-47bb-0310-9956-ffa450edef68
* QPID-15 JUnit3 compatibility suite() method now uses correct Test class.Steven Shaw2006-10-062-11/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@453537 13f79535-47bb-0310-9956-ffa450edef68
* Changed flow control information out put to be debug level as it is output a ↵Martin Ritchie2006-10-051-2/+2
| | | | | | lot when flow control starts. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@453196 13f79535-47bb-0310-9956-ffa450edef68
* Changed flow control information out put to be debug level as it is output a ↵Martin Ritchie2006-10-051-1/+1
| | | | | | lot when flow control starts. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@453193 13f79535-47bb-0310-9956-ffa450edef68
* Changed TxnBuffer log data to debug level.Martin Ritchie2006-10-031-3/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@452546 13f79535-47bb-0310-9956-ffa450edef68
* client/* - Only Create a Threshold Listener if if the acknowledgeMode is NO_ACKMartin Ritchie2006-10-034-176/+204
| | | | | | common/*/framing/* - White space changes from tabs to 4 spaces. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@452529 13f79535-47bb-0310-9956-ffa450edef68
* Added lines to automatically add amqj.logging.level to "info" on the command ↵Martin Ritchie2006-10-031-1/+5
| | | | | | | | | | line. As without this the level is automatically set to debug but the console only displays info level and above messages. This results is a lot of wasted cycles. If -Damqj.logging.level is present on the command line then that value will override the default of "info" Related to QPID-12 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@452430 13f79535-47bb-0310-9956-ffa450edef68
* I somehow missed an import.Martin Ritchie2006-10-031-0/+1
| | | | | | | | | | | QPID-10 #QPID-10 JIRA QPID-10 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@452334 13f79535-47bb-0310-9956-ffa450edef68
* Fix for QPID-10. Problem was a memory leak of sorts on the client. A ↵Martin Ritchie2006-10-031-14/+29
| | | | | | temporary frame listener was never removed. Hence causing longer add times and lots of "live" objects. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@452326 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status