summaryrefslogtreecommitdiff
path: root/java/broker
Commit message (Collapse)AuthorAgeFilesLines
* 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
* Further fixes and some extra tests for transactions.Gordon Sim2006-10-1914-338/+666
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@465549 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-1718-103/+1041
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | - 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
* 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
* QPID-18. Removed unused experimental code that had direct dependencies on ↵Robert Greig2006-10-123-14/+9
| | | | | | 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
* 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
* 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
* 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
* Optimised Transaction handling.Martin Ritchie2006-10-033-9/+39
| | | | | | When using a a transaction don't start a store transaction on a commit UNLESS a persistent message has been sent. As non-persistent messages are not stored. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@452323 13f79535-47bb-0310-9956-ffa450edef68
* File incorrectly transferred from etp.108.redhat.com at time of initial port.Kim van der Riet2006-10-021-40/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@452140 13f79535-47bb-0310-9956-ffa450edef68
* Changes for JMX layer-Martin Ritchie2006-10-0222-265/+1081
| | | | | | MBeans are decorated with descriptions using annotations for attributes, operations and operation parameters. Introspection added for management interface. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@451932 13f79535-47bb-0310-9956-ffa450edef68
* Moved delivery tag retrieval and addition to Unack'd list back to ↵Martin Ritchie2006-09-272-20/+16
| | | | | | SubscriptionImpl as the synchronized block must include writing the frame to the wire. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@450401 13f79535-47bb-0310-9956-ffa450edef68
* AMQProtocolSession.java - white space changesMartin Ritchie2006-09-274-52/+90
| | | | | | | | | | | | BasicMessageProducer.java - white space changes BasicMessageConsumer.java - white space changes AMQSession.java - added a comment MemoryMessageStore.java - white space changes SubscriptionImpl.java AMQChannel.java - Removed race condition where two messages could get the same delivery tag and when using acks where messages can be added to the UnackMap out of sequence, Causing unknown message to ack exceptions. DestNameExchange.java - white space/style changes. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@450384 13f79535-47bb-0310-9956-ffa450edef68
* Changed default instance id to 1 to make getInstance simpler.Martin Ritchie2006-09-261-3/+9
| | | | | | Added ability to specify default ApplicationRegistry git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@449942 13f79535-47bb-0310-9956-ffa450edef68
* AMQPFastProtocolHandler.java - Added (Integer appRegId) constructor to allow ↵Martin Ritchie2006-09-2511-25/+229
| | | | | | | | | | | | | the AMQPFastProtocolHandler to request the ApplicationRegistry instance. ApplicationRegistry.java - Modified to allow multiple ARs to exist each indexed by an integer id. Default AR of 0 always exists. NullApplicationRegistry.java - Copied from Test cases but modified to have a simple MemoryMessageStore. MemoryMessageStore.java - Added a configure() that uses the class defaults. NullAuthenticationManager.java - Moved from Test Renamed NullApplicationRegistry.java to TestApplicationRegistry.java for the Test cases. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@449643 13f79535-47bb-0310-9956-ffa450edef68
* made the default config use the memory message storeRafael H. Schloming2006-09-191-3/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@448008 13f79535-47bb-0310-9956-ffa450edef68
* Import of qpid from etp:Rafael H. Schloming2006-09-19167-0/+16915
URL: https://etp.108.redhat.com/svn/etp/trunk/blaze Repository Root: https://etp.108.redhat.com/svn/etp Repository UUID: 06e15bec-b515-0410-bef0-cc27a458cf48 Revision: 608 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@447994 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status