summaryrefslogtreecommitdiff
path: root/java/broker
Commit message (Collapse)AuthorAgeFilesLines
...
* QPID-3774 : allow out of order completion of persistent enqueues / dequeuesRobert Godfrey2012-01-206-41/+484
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1234111 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3756: ManagedConnectionMBeanTest.testChannels occasionally fails on ↵Keith Wall2012-01-181-19/+31
| | | | | | | | | | | 0-10 spawned profiles This problem is caused by the connection mbean being deregistered too late (as the TCP/IP socket) is closed, thus creating a race between the client using JMX to observe connection state, and the unregistering of the bean. This patch changes the 0-10 code path to unregister the bean on receipt of ConnectionClose and before ConnectionCloseOkay is sent to the client. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1232785 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3720 : Fix issue with default group assignment pointed out by RobbieRobert Godfrey2012-01-161-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1232058 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3762: make sure to close the IoSender when the IoReciever indicates the ↵Robert Gemmell2012-01-161-1/+8
| | | | | | TCP connection went away, fixes leak for forcefully clsoed 0-9-1 connections git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1232032 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3761: rename the fallback config to ensure it isnt just picked up by ↵Robert Gemmell2012-01-162-5/+5
| | | | | | Log4J automatically scanning the classpath git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1232031 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3697: SortedQueue synchronisation can cause deadlockKeith Wall2012-01-134-3/+86
| | | | | | | Sorted queue enqueue() should lock on a private rather than the lock of the object to avoid the possibility of a deadlock with a thread performing subscription operations. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1231095 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3753 : [Java Broker] Improve automatic conversion of messages between ↵Robert Godfrey2012-01-126-27/+88
| | | | | | 0-8/9/9-1 and 0-10 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1230661 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3720 : Fix bug which causes failure in 0-9-1 tests, namely ↵Robert Godfrey2012-01-111-3/+3
| | | | | | SimpleAMQQueue.QueueEntryListener assuming that all listeners are of the same type git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1230251 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3720 : Remove debugging log statementsRobert Godfrey2012-01-111-3/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1230013 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3720 : Add alternative (C++ style) grouping and apply comments from ↵Robert Godfrey2012-01-114-144/+489
| | | | | | Robbie Gemmel git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1229996 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3717 - Fixes based on review by Robbie GemmellRobert Godfrey2012-01-111-9/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1229943 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3730: remove ReadWriteJobQueue, it is no longer necessary as the only ↵Robert Gemmell2012-01-095-50/+8
| | | | | | things now using the thread pool are write jobs, so there is no need/benefit to request it be write-biased. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1229112 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: remove unused codeRobert Gemmell2012-01-092-5/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1229111 13f79535-47bb-0310-9956-ffa450edef68
* QPID-946 , QPID-2379 : QMF and Federation fixes (now works again with ↵Robert Godfrey2012-01-0726-143/+1178
| | | | | | qpid-config, qpid-route, qpid-tool) and store (durable) routes in the DB git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1228748 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3715: Fix the receiving of an empty ObjectMessage (without a body)Keith Wall2012-01-073-89/+2
| | | | | | Applied patch from Oleksandr Rudyy<orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1228583 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3704: OutOfOrderQueue#checkSubscriptionsNotAheadOfDelivery cannot ↵Keith Wall2012-01-051-7/+3
| | | | | | consider _lastSeenEntry when determing if _releasedEntry should be retarded git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1227582 13f79535-47bb-0310-9956-ffa450edef68
* QPID-464 : Attempt to log error using log4j before shutting downRobert Godfrey2012-01-041-0/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1227163 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3714 : Fix for NPE when a transient message (or when using the Memory ↵Robert Godfrey2012-01-041-0/+8
| | | | | | Store) has no body git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1227162 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3714 : Fix for NPE in the SecurityManager when a null routing key is ↵Robert Godfrey2012-01-041-1/+9
| | | | | | used in 0-10 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1227142 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3720 : [Java Broker] Implement Message GroupingRobert Godfrey2012-01-038-44/+301
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1226930 13f79535-47bb-0310-9956-ffa450edef68
* QPID-464 : Set the default uncaught exception handler to abruptly terminate ↵Robert Godfrey2012-01-023-27/+91
| | | | | | | | the JVM (Note this commit also contains fixes for CurrentActorTest as it was discovered that this test was throwing uncaught exceptions from created Threads - i.e. not the main test thread) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1226557 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3713 : Implement producer side flow control for 0-10 in Java BrokerRobert Godfrey2012-01-026-16/+115
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1226382 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3714 : [Java] Performance ImprovementsRobert Godfrey2011-12-2887-2288/+2660
| | | | | | | | | | | | | | | | | | | | | | | | | | | | Persistence: Store message in same transaction as enqueue if possible Memory: Remove unnecessary (un)boxing Reduce unnecessary copying of message data Cache short strings Cache queues for a given routing key on an Exchange (0-9) Use a fixed size buffer for preparing frames to write out Other: Reduce calls to System.currentTimeMillis (0-10) Special case immutable RangeSets, in particular RangeSets of a single range/point (0-10) Special case delivery properties and message properties in headers (0-9) send commit-ok as soon as data committed to store Cache publishing access control queries (0-9) Optimised long and int typed values for FieldTables (0-9) Retain FieldTable encoded form (0-9) Cache queue and topic destinations git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1225178 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3707: Fix ClassCastException when processing QueueUnbind for 0-9-1 ↵Keith Wall2011-12-221-5/+18
| | | | | | protocol. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1222502 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3698: remove unnecessary test - MessageStoreShutdownTestKeith Wall2011-12-201-81/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1221313 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3682: Shutdown Plugin ImprovementsKeith Wall2011-12-163-34/+33
| | | | | | | | | | | | | Various improvements to shutdown plugin: 1) Give the ShutdownPlugin instance a name to allow it to be permission via ACL METHOD rules. 2) Refactored to extend DefaultManagedObject. 3) Added method/parameter annotations to improve usability from the UI. 4) Fix date format parsing pattern used by the plugin Applied patch from Andrew MacBean <andymacbean@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1215112 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3687 : Improve Java Broker performanceRobert Godfrey2011-12-1516-186/+770
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1214760 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3684: Remove the Message Store Tool and its associated script and ↵Keith Wall2011-12-1520-3520/+0
| | | | | | | | configuration Applied patch from Andrew MacBean <andymacbean@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1214670 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3680: Header exchange bindings not being created via JMX Management ConsoleKeith Wall2011-12-142-39/+129
| | | | | | Applied patch from Andrew MacBean <andymacbean@gmail.com> and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1214206 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3676: Correct issues found by findbugs marked as blockersKeith Wall2011-12-132-121/+122
| | | | | | Applied patch from Andrew MacBean <andymacbean@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1213636 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3489: Attempt to load all custom exchanges rather than returning at ↵Andrew Donald Kennedy2011-12-061-1/+1
| | | | | | first failure git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1211059 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2243: 0-10 protocol connections do not have a matching JMX MBean to ↵Robert Gemmell2011-12-019-99/+822
| | | | | | | | allow management. Applied patch from Andrew MacBean <andymacbean@gmail.com> and Oleksandr Rudyy<orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1209052 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: update scripts to reference current deps etcRobert Gemmell2011-11-301-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1208480 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: copy optional module scripts if the module is requestedRobert Gemmell2011-11-301-3/+15
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1208479 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: remove unused 'qpid.passwd' file, update 'md5passwd' file to align ↵Robert Gemmell2011-11-306-214/+2
| | | | | | users with the 'passwd' file. Remove unused out of date debug log4j config file. Remove old unused conf files. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1208478 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3642: Fix for redelivery regression found by python testsKeith Wall2011-11-302-8/+7
| | | | | | Applied patch from Andrew MacBean <andymacbean@gmail.com> and Oleksandr Rudyy<orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1208435 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3601: Occasional failure to delete queue on broker shutdownKeith Wall2011-11-302-8/+35
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1208434 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3641: rename configuration element aclv2 => acl.Keith Wall2011-11-281-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1207407 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3489: Added org.apache.qpid.server.message to exported packages for brokerAndrew Donald Kennedy2011-11-281-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1207096 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3642, QPID-3640: Add Dead Letter Queue functionality for 0-10 path. ↵Keith Wall2011-11-285-12/+77
| | | | | | | | Also, it fixes issue with setting of redelivered flag for pre-fetched messages as DLQ functionality relies on this flag being set correctly. Applied patch from Andrew MacBean <andymacbean@gmail.com> and Oleksandr Rudyy<orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1207031 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3642,QPID-3643: Add Dead Letter Queue functionality for 0-8/0-9/0-9-1 ↵Keith Wall2011-11-2828-113/+1355
| | | | | | | | paths, fixes isBound methods on FanoutExchange Applied patch from Keith Wall <keith.wall@gmail.com>, Andrew MacBean <andymacbean@gmail.com> and Oleksandr Rudyy<orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1207029 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3474: Maintain connectionid/username Map from only ↵Keith Wall2011-11-252-16/+31
| | | | | | JMXManagedObjectRegistry (Improved separation of concerns). git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1206086 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3474: Use JMX notification handback data to ensure that open/close/fail ↵Keith Wall2011-11-242-13/+73
| | | | | | events are logged with username only, rather than a complete list of pricipals. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1205911 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3641: ACLV2 Simplifications and Improvements for Java BrokerKeith Wall2011-11-2410-109/+213
| | | | | | | | | | | | | Improvements and simplifications to ACL V2 for the Java Broker: 1) Removed 'EXECUTE' operation (we now just have ACCESS and UPDATE like C++ broker) 2) Enable users with management rights for a procedure to complete that procedure without matching AMQP rights (configurable) 3) Fix up system tests (make clearer, remove need for lots of support files) 4) Fix disparity in DENY_LOG and DENY-LOG values between brokers. 5) Get rid of transitive/expand permission rules Work from Robbie Gemmell and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1205782 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3559: SimpleDateFormat used in thread unsafe manner in JMX Managed ↵Keith Wall2011-11-202-102/+180
| | | | | | | | Queue interface. Resolved thread safe issue. Added supporting unit and system test. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1204296 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3622: Add Sorted Queue funtionalityKeith Wall2011-11-2033-478/+2145
| | | | | | Applied patch from Andrew MacBean <andymacbean@gmail.com> and Oleksandr Rudyy<orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1204295 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: add missing licence headers to various files in the java treeRobert Gemmell2011-11-173-0/+60
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1203385 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2703: 0-8..0-9-1 Transaction rollback/recover does not restore consumer ↵Keith Wall2011-11-177-17/+26
| | | | | | | | | credit. This change restores consumer credit after rollback/recover by restoring credit on reciept of basic.reject from the consumer. This change is basically as QPID-2506, but with additional changes to avoid the 0-10 path. Work by Robbie Gemmell and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1203137 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3617: AMQQueueMBean.viewMessages: Viewing message without priority set ↵Keith Wall2011-11-171-1/+1
| | | | | | ends with NullPointerException git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1203135 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3592: ensure that the 'used credit' values are decremented when message ↵Robert Gemmell2011-11-1112-53/+105
| | | | | | transfer commands 'completed' following a message.stop command attempt to restore their credit (to no effect due to the 0 credit limit) when using 0-10 Window credit mode. Add unit test, and break CreditManager dependency on ServerMessages by passing the required size value rather than the message itself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1200801 13f79535-47bb-0310-9956-ffa450edef68