summaryrefslogtreecommitdiff
path: root/java/broker
Commit message (Collapse)AuthorAgeFilesLines
* clean up warnings about unused variablesStephen Vinoski2006-12-183-4/+3
| | | | | | | | Remove all warnings in common, broker, client, and systests regarding unused variables, as indicated by Eclipse builds. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488450 13f79535-47bb-0310-9956-ffa450edef68
* QPID-212 QPID-214 Patch supplied by Rob GodfreyRobert Greig2006-12-182-9/+15
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488377 13f79535-47bb-0310-9956-ffa450edef68
* null check added for null header propertiesBhupendra Bhusman Bhardwaj2006-12-181-7/+14
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488279 13f79535-47bb-0310-9956-ffa450edef68
* QPID-211 : Patch supplied by Rob Godfrey - Perform null check against ↵Robert Greig2006-12-181-1/+1
| | | | | | routing key before looking in the map git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488188 13f79535-47bb-0310-9956-ffa450edef68
* remove unused importsStephen Vinoski2006-12-186-10/+0
| | | | | | | | | Remove unused imports for common, broker, client, and systests as reported by Eclipse. Note that this includes imports in the Java XSL template used to generate the framing code in common. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488134 13f79535-47bb-0310-9956-ffa450edef68
* QPID-183 Patch supplied by Rob Godfrey. Major changes to durable topic ↵Robert Greig2006-12-157-17/+302
| | | | | | subscription handling. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@487562 13f79535-47bb-0310-9956-ffa450edef68
* git-svn-id: ↵Bhupendra Bhusman Bhardwaj2006-12-142-6/+7
| | | | https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@487299 13f79535-47bb-0310-9956-ffa450edef68
* QPID-190 Bhupendra Bhusman Bhardwaj2006-12-144-539/+734
| | | | | | Refactored the broker MBean classes git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@487268 13f79535-47bb-0310-9956-ffa450edef68
* Added comments about possible RejectedExecutionException that may occur when ↵Martin Ritchie2006-12-132-2/+12
| | | | | | starting to process aSync deliveries as the broker closes its execution pools. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486642 13f79535-47bb-0310-9956-ffa450edef68
* set logging level with propertyStephen Vinoski2006-12-121-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486206 13f79535-47bb-0310-9956-ffa450edef68
* QPID-95 : Patch supplied by Rob Godfrey - throws correct exception when ↵Robert Greig2006-12-121-1/+12
| | | | | | encountering a non-routable mandatory message git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486132 13f79535-47bb-0310-9956-ffa450edef68
* fix misplaced double quoteStephen Vinoski2006-12-111-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@485490 13f79535-47bb-0310-9956-ffa450edef68
* FieldTable change.Martin Ritchie2006-12-052-2/+4
| | | | | | | | | | | | | | | | | | | | | | | | | | FieldTable is now an interface with a PropertyFieldTable.java implementation. This PropertyFieldTable has been updated to handle the wire level encoding and decoding of the underlying map. It also allows XML encoding of the data as used by JMSMapMessage. Currently the AMQP doesn't support all the Java primitives as a result all values are written out as XML using a prefix of 'X'. (See QPID-9 for further details) Changes where not specified are changes from new FieldTable() to FieldTableFactory.newFieldTable() AbstractJMSMessage.java - the type prefixing of properties is now not requried as all the functionality has been moved to PropertyFieldTable.java. In addition set/getObjectProperty is now implemented as PFT does this. basic Tests have been updated to send all property values. FieldTableKeyEnumeration.java has been removed as it is nolonger required. The PFT handles this internally. ToDo: The Tests need to be consolidated so that there is a clear view of the code coverage. QPID-158 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482733 13f79535-47bb-0310-9956-ffa450edef68
* QPID-148Martin Ritchie2006-12-041-0/+5
| | | | | | | | | | | | | | | AMQMinaProtocolSession.java - updated comment AbstractJMSMessage.java - removed a lot of getHeaders() == null checks. Updated logic accordingly.. Now a request for a property that doesn't exist will be consistent with calls on an empty table rather than just creating a default value. BasicContentHeaderProperties.java - the culprit for QPID-148 changed new FieldTable() to setHeaders(new FieldTable()) to ensure propertyFlag is set to write headers to the wire. Added PropertyValueTest.java - that tests all the valid values on the Message. *NOTE*: A number of the tests are commented out as AMQP and therefore the FieldTable do not support these values. QPID-9 Added SVN ignores for the target directories. Updated AbstractJMSMessage.java _readableProperties to be set correctly in the constructor. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482238 13f79535-47bb-0310-9956-ffa450edef68
* QPID-129 Bhupendra Bhusman Bhardwaj2006-11-2711-586/+403
| | | | | | MBeans updated with improved features, like AMQQueue mbean now has separate features for sending message header and message content. ( other details are in JIRA) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@479686 13f79535-47bb-0310-9956-ffa450edef68
* properly limit scope for test-only dependenciesStephen Vinoski2006-11-241-7/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@479050 13f79535-47bb-0310-9956-ffa450edef68
* use the right names for the qpid-incubating jarsStephen Vinoski2006-11-242-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478964 13f79535-47bb-0310-9956-ffa450edef68
* change name for launcher jarsStephen Vinoski2006-11-242-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478963 13f79535-47bb-0310-9956-ffa450edef68
* Removed the includes as it wasn't picking up the test cases. The includes ↵Martin Ritchie2006-11-221-3/+0
| | | | | | from mvn should be ok. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478270 13f79535-47bb-0310-9956-ffa450edef68
* Changed logging from warn to infoMartin Ritchie2006-11-221-25/+30
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478264 13f79535-47bb-0310-9956-ffa450edef68
* QPID-108: remove obsolete ant build filesStephen Vinoski2006-11-223-344/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478023 13f79535-47bb-0310-9956-ffa450edef68
* QPID-118. Now passes arguments through to the java process.Robert Greig2006-11-201-1/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@477341 13f79535-47bb-0310-9956-ffa450edef68
* broker/pom.xml - removed test scope from junit to remove warning in build log.Martin Ritchie2006-11-201-63/+91
| | | | | | | | | | | | | | TransportConnection.java/AMQQueue.java - change log level on a print statement from warn to info log4j.properties - updated threashold to be 'all' so we can set the logging level with amqj.logging.level client/pom.xml - fixed mvn test run output. It wasn't using our log4.properties file. systests/pom.xml - added log4j.properties configuration broker/pom.xml - added log4j.properties configuration common/pom.xml - skipped tests as there are none, and it caused the build to fail Also adjusted spaceing to be 4 space per tab (and no tabs) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@477214 13f79535-47bb-0310-9956-ffa450edef68
* convert tests to junit3Stephen Vinoski2006-11-198-234/+35
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@476701 13f79535-47bb-0310-9956-ffa450edef68
* complete bringing initial maven work to trunkStephen Vinoski2006-11-183-49/+170
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@476431 13f79535-47bb-0310-9956-ffa450edef68
* directory moves required for maven mergeStephen Vinoski2006-11-18137-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@476414 13f79535-47bb-0310-9956-ffa450edef68
* Removed local development code that made it into the repositoryMartin Ritchie2006-11-151-13/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@475297 13f79535-47bb-0310-9956-ffa450edef68
* QPID-92 Changes to bring MINA use up to MINA-Head (1.1.0) compatibility.Martin Ritchie2006-11-151-38/+61
| | | | | | Sorry forgot this file. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@475294 13f79535-47bb-0310-9956-ffa450edef68
* * added top-level systests directory for non-unit testsStephen Vinoski2006-11-1235-4116/+1
| | | | | | | | * moved some tests into systests to eliminate dependencies between test subdirectories (required for maven) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@473889 13f79535-47bb-0310-9956-ffa450edef68
* update Apache licenses to the current versionStephen Vinoski2006-11-10183-2353/+2933
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@473568 13f79535-47bb-0310-9956-ffa450edef68
* Removed bdbstore referenceMartin Ritchie2006-11-101-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@473338 13f79535-47bb-0310-9956-ffa450edef68
* Created module.vm.version to set X-Compile-Source-JDK in jars default is 1.4 ↵Martin Ritchie2006-11-101-0/+1
| | | | | | Broker overrides to 1.5 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@473283 13f79535-47bb-0310-9956-ffa450edef68
* Updated propertiesStephen Vinoski2006-11-091-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@473072 13f79535-47bb-0310-9956-ffa450edef68
* QPID-69Martin Ritchie2006-11-078-296/+748
| | | | | | | Made an interface from the current DeliveryManager.java. The original DeliveryManager is now the SynchronizedDeliveryManager.java where the deliver() method now has synchronization to solve the race condition. An alternative DeliveryManager - ConcurrentDeliveryManager.java uses a modified ConcurrentLinkedQueue (Modified to maintain the current queue size) this uses a compare and swap methods to allow concurrent access to each end of the queue. Additional locking is required once the queue has been depleted to ensure that a thread is not in the process of appending to the queue. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@472060 13f79535-47bb-0310-9956-ffa450edef68
* Replaced by ManagedConnection.javaBhupendra Bhusman Bhardwaj2006-11-071-33/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@472037 13f79535-47bb-0310-9956-ffa450edef68
* AMQQueueMBean updated. The message content is sent with header attributes. ↵Bhupendra Bhusman Bhardwaj2006-11-012-85/+117
| | | | | | New management operation added to view message content for a particular messageId. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@470012 13f79535-47bb-0310-9956-ffa450edef68
* Channel is not an MBean. The getObjectName is removed. The SessionMBean is ↵Bhupendra Bhusman Bhardwaj2006-11-012-43/+4
| | | | | | updated accordingly. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@469954 13f79535-47bb-0310-9956-ffa450edef68
* Additions to build system to cause junit to produce a reportMartin Ritchie2006-10-312-17/+25
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@469504 13f79535-47bb-0310-9956-ffa450edef68
* Additions to build system to cause junit to produce a reportMartin Ritchie2006-10-311-0/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@469491 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
* 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
* 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-243-40/+159
| | | | | | | | | | 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
* 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
View Lorry Controller Status