summaryrefslogtreecommitdiff
path: root/java
Commit message (Collapse)AuthorAgeFilesLines
* QPID-213Bhupendra Bhusman Bhardwaj2007-01-052-2/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@492956 13f79535-47bb-0310-9956-ffa450edef68
* moved some distribution filesStephen Vinoski2007-01-056-7/+13
| | | | | | | | moved some files around underneath the distribution directory, and changed some assemblies to pick them up git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@492902 13f79535-47bb-0310-9956-ffa450edef68
* Fixed C++ client sending protocol version 0-0 over the wire. Minor fixes and ↵Kim van der Riet2007-01-042-19/+4
| | | | | | tidy-up in related code. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@492756 13f79535-47bb-0310-9956-ffa450edef68
* QPID-248 Modified field table types to not conflict with the officially ↵Rafael H. Schloming2007-01-044-86/+65
| | | | | | specified definitions. Also reorganized type definitions to clearly distinguish between official and extended types and reenabled the AmqPlain authentication mechanism. This change allows the python interop test suite to run. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@492718 13f79535-47bb-0310-9956-ffa450edef68
* QPID-213Bhupendra Bhusman Bhardwaj2007-01-046-34/+198
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@492514 13f79535-47bb-0310-9956-ffa450edef68
* QPID-213Bhupendra Bhusman Bhardwaj2007-01-038-190/+380
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@492184 13f79535-47bb-0310-9956-ffa450edef68
* Added automatic build of generator; added dependency check on source XML ↵Kim van der Riet2007-01-022-5/+18
| | | | | | files that prevents generation if not needed git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@491879 13f79535-47bb-0310-9956-ffa450edef68
* QPID-233 : Patch from Rob Godfrey - fix to lock.unlock() bugRobert Greig2007-01-011-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@491673 13f79535-47bb-0310-9956-ffa450edef68
* QPID-232 Added the service request/reply testRobert Greig2007-01-014-0/+556
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@491577 13f79535-47bb-0310-9956-ffa450edef68
* Reduced logging level to debug to avoid performance sapping outputRobert Greig2006-12-291-10/+38
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@491120 13f79535-47bb-0310-9956-ffa450edef68
* QPID-232 Created a simple module and added the topic testRobert Greig2006-12-2915-0/+1166
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@491072 13f79535-47bb-0310-9956-ffa450edef68
* QPID-213Bhupendra Bhusman Bhardwaj2006-12-291-0/+106
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@491031 13f79535-47bb-0310-9956-ffa450edef68
* QPID-213Bhupendra Bhusman Bhardwaj2006-12-294-33/+217
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@491029 13f79535-47bb-0310-9956-ffa450edef68
* test queue and exchange names changed.Bhupendra Bhusman Bhardwaj2006-12-291-16/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@490985 13f79535-47bb-0310-9956-ffa450edef68
* apply patch for QPID-231Stephen Vinoski2006-12-281-4/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@490872 13f79535-47bb-0310-9956-ffa450edef68
* git-svn-id: ↵Bhupendra Bhusman Bhardwaj2006-12-282-54/+132
| | | | https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@490734 13f79535-47bb-0310-9956-ffa450edef68
* QPID-188 Bhupendra Bhusman Bhardwaj2006-12-282-12/+91
| | | | | | Unit tests added git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@490709 13f79535-47bb-0310-9956-ffa450edef68
* MBean created as a separate classBhupendra Bhusman Bhardwaj2006-12-282-167/+201
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@490708 13f79535-47bb-0310-9956-ffa450edef68
* add snapshot repository for distributionStephen Vinoski2006-12-271-0/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@490605 13f79535-47bb-0310-9956-ffa450edef68
* QPID-213Bhupendra Bhusman Bhardwaj2006-12-273-54/+56
| | | | | | improving the management GUI look and feel git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@490505 13f79535-47bb-0310-9956-ffa450edef68
* QPID-227 Renamed version.properties to qpidversion.properties due to clash ↵Robert Greig2006-12-262-10/+44
| | | | | | with a dependency also using version.properties. Also improved robustness where properties file does not contain expected properties. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@490373 13f79535-47bb-0310-9956-ffa450edef68
* QPID-229 Fixed spurious import in test classRobert Greig2006-12-221-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489804 13f79535-47bb-0310-9956-ffa450edef68
* QPID-229 : Patch supplied by Rob Godfrey - Change implementation of FieldTableRobert Greig2006-12-221-45/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489754 13f79535-47bb-0310-9956-ffa450edef68
* QPID-229 : Patch supplied by Rob Godfrey - Change implementation of FieldTableRobert Greig2006-12-2220-1798/+1677
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489748 13f79535-47bb-0310-9956-ffa450edef68
* File tidy-up for AMQP version code: Removed old XSLT files; moved ↵Kim van der Riet2006-12-2213-985/+1
| | | | | | cluster.asl into spec directory; renamed spec files to better reflect version notation; updated java, c++ and python files to reference new names. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489715 13f79535-47bb-0310-9956-ffa450edef68
* AMQP version using new generator - Part 1. In these changes, all places ↵Kim van der Riet2006-12-2261-270/+643
| | | | | | where version-specific info is required, it has been hard-wired to major=8, minor=0. The next phase of changes will connect the version info to that obtained from ProtocolInitiation for the current session. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489691 13f79535-47bb-0310-9956-ffa450edef68
* git-svn-id: ↵Robert Greig2006-12-225-701/+1150
| | | | https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489644 13f79535-47bb-0310-9956-ffa450edef68
* QPID-227Bhupendra Bhusman Bhardwaj2006-12-216-10/+104
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489403 13f79535-47bb-0310-9956-ffa450edef68
* QPID-188 Bhupendra Bhusman Bhardwaj2006-12-211-1/+2
| | | | | | test updated git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489331 13f79535-47bb-0310-9956-ffa450edef68
* QPID-188 Bhupendra Bhusman Bhardwaj2006-12-215-47/+22
| | | | | | Unit test for AMQProtocolSession mbean updated and closeChannel() method removed from mbean because it didn't seem to be a required feature for management console. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489330 13f79535-47bb-0310-9956-ffa450edef68
* add clover support, fix logging level variablesStephen Vinoski2006-12-204-9/+27
| | | | | | | | Added support for the clover plugin to the top-level pom, and eliminated redundant amqj.logging.level variables from module poms. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489215 13f79535-47bb-0310-9956-ffa450edef68
* conf file for jpackageRafael H. Schloming2006-12-201-0/+49
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489204 13f79535-47bb-0310-9956-ffa450edef68
* QPID-225Martin Ritchie2006-12-201-1/+14
| | | | | | Applied Patch for queue browsing with client acknowledgement git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489140 13f79535-47bb-0310-9956-ffa450edef68
* renamed the jarBhupendra Bhusman Bhardwaj2006-12-201-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489113 13f79535-47bb-0310-9956-ffa450edef68
* QPID-101Martin Ritchie2006-12-2014-75/+579
| | | | | | | | | | | | | | | | | | | | | Initial Implementation of Queue Browsing by Robert Godfrey and Martin Ritchie AMQChannel.java - record messages browsed so not to discard them on ack. FilterManagerFactory.java - Added a NoConsumerFilter ConcurrentSelectorDeliveryManager.java - Update to send browsers messages without taking the message from other consumers Subscription.java - Added autoClose and isBrowser methods SubscriptionTestHelper.java / RemoteSubscriptionImpl.java / SubscriptionImpl.java - implemented new interface methods Added NoConsumerFilter.java Patches from Rob Godfrey for client implmentation AMQSession.java - Added AUTO_CLOSE and NO_CONSUME properties to arguments FieldTable for consume method. BasicMessageConsumer.java - updates to correctly close consumer when an BasicCancel is received from the broker. AMQProtocolSession.java - method to allow cancellation of the client AMQStateManager.java - added handler for BasicCancelOkMethodHandler.java Added new AMQQueueBrowser.java BasicCancelOkMethodHandler.java git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489106 13f79535-47bb-0310-9956-ffa450edef68
* Updated FilterTypes to be more accurate NO_CONSUME and AUTO_CLOSEMartin Ritchie2006-12-201-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489083 13f79535-47bb-0310-9956-ffa450edef68
* QPID-223Martin Ritchie2006-12-206-34/+59
| | | | | | Applied patch from Rupert Smith git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489082 13f79535-47bb-0310-9956-ffa450edef68
* Added new enum for AMQP Filter typesMartin Ritchie2006-12-201-0/+39
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489078 13f79535-47bb-0310-9956-ffa450edef68
* QPID-21 outstanding issues:Martin Ritchie2006-12-206-40/+126
| | | | | | | | | | | | | Fixed an issue where a consumer with no_local set would not have its filters applied to messages. Fixed problem where new consumers would start with an empty PDQ rather than checking the existing queue of messages for messages of interest. AMQQueue.java - Added code check exisiting queue data for messages for the new subscriber with a filter. DeliveryManager.java - added populatePreDeliveryQueue SynchronizedDeliveryManager.java/ConcurrentDeliveryManager.java - implemented new DeliveryManager.java interface SubscriptionImpl.java - fixed issue with no_local subscribers had their filters ignored. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489070 13f79535-47bb-0310-9956-ffa450edef68
* QPID-222Martin Ritchie2006-12-191-1/+3
| | | | | | ensured that the TXBuffer of a message is set to null when re queuing. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488726 13f79535-47bb-0310-9956-ffa450edef68
* Maven output clean up.Martin Ritchie2006-12-191-21/+26
| | | | | | Mainly removed exception stack traces from expected exceptions. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488715 13f79535-47bb-0310-9956-ffa450edef68
* Maven output clean up.Martin Ritchie2006-12-194-11/+16
| | | | | | Mainly removed exception stack traces from expected exceptions. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488713 13f79535-47bb-0310-9956-ffa450edef68
* QPID-216Martin Ritchie2006-12-1915-78/+210
| | | | | | | | | | | | | | | | | | BasicConsumeMethodHandler.java - Pulled the nolocal param from the method body and passed down channel to subscription. SubscriptionFactory.java / AMQQueue.java/AMQChannel.java - passed the nolocal parameter through to the Subscription ConnectionStartOkMethodHandler.java - Saved the client properties so the client identifier can be used in comparison with the publisher id to implement no_local AMQMinaProtocolSession.java - added _clientProperties to store the sent client properties. AMQProtocolSession.java - interface changes to get/set ClientProperties ConcurrentSelectorDeliveryManager.java - only need to do hasInterset as this will take care of the hasFilters optimisation check. SubscriptionImpl.java - Added code to do comparison of client ids to determin insterest in a given message. SubscriptionSet.java - tidied up code to use hasInterest as this is where the nolocal is implemented. ConnectionStartMethodHandler.java - Moved literal values to a ClientProperties.java enumeration and a QpidProperties.java values. QpidConnectionMetaData.java - updated to get values from QpidProperties.java MockProtocolSession.java - null implementation of new get/set methods git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488712 13f79535-47bb-0310-9956-ffa450edef68
* QPID-188 Bhupendra Bhusman Bhardwaj2006-12-191-0/+123
| | | | | | Unit test for Exchange MBeans git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488711 13f79535-47bb-0310-9956-ffa450edef68
* QPID-188 Bhupendra Bhusman Bhardwaj2006-12-191-0/+118
| | | | | | Adding unit tests for Java broker JMX functionality git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488705 13f79535-47bb-0310-9956-ffa450edef68
* QPID-188 Bhupendra Bhusman Bhardwaj2006-12-192-1/+3
| | | | | | Adding unit tests for Java broker JMX functionality git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488701 13f79535-47bb-0310-9956-ffa450edef68
* QPID-21Martin Ritchie2006-12-1948-102/+4255
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Added: SelectorParser.jj - ActiveMQ selector javacc grammar used to generate SelectorParser.java server/filter - Selector Filtering code from ActiveMQ project adjusted to suite our class and package structure. server/message - Decorator classes to allow access to the JMSMessage inside the AMQMessage ConcurrentSelectorDeliveryManager.java - A new DeliveryManager that utilises PreDeliveryQueues to implement selectors AMQInvalidSelectorException.java - thrown on client and broker when the Selector text is invalid. Common: log4j.properties to remove error log4j warnings on Common tests. Modified: broker/pom.xml - to generate SelectorParser.java AMQChannel.java - Addition of argument fieldtable for filter setup. BasicConsumeMethodHandler.java - writing of InvalidSelector channel close exception. AMQMessage.java - Added decorator to get access to the enclosed JMSMessage AMQQueue.java - Enhanced 'deliverymanager' property to allow the selection of the ConcurrentSelectorDeliveryManager. Subscription.java - Enhanced interface to allow a subscription to state an 'interest' in a given message. SubscriptionFactory.java - Added method to allow passing of filter arguments. SubscriptionImpl.java - Implemented new Subscription.java methods. SubscriptionManager.java - Added ability to get a list of current subscribers. SubscriptionSet.java - augmented nextSubscriber to allow the subscriber to exert the new hasInterest feature. SynchronizedDeliveryManager.java - fixed Logging class AMQSession - Added filter extraction from consume call and pass it on to the registration. ChannelCloseMethodHandler.java - Handle the reception and correct raising of the InvalidSelector Exception AbstractJMSMessage.java - Expanded imports BlockingMethodFrameListener.java - added extra info to a debug output line. SocketTransportConnection.java - made output an info not a warn. PropertiesFileInitialContextFactory.java - updated to allow the PROVIDER_URL to specify a property file to read in for the initial values. ClusteredSubscriptionManager.java - Implementation of SubscriptionSet.java NestedSubscriptionManager.java - Implementation of SubscriptionManager.java RemoteSubscriptionImpl.java - Implementation Subscription.java AMQConstant.java - Added '322' "Invalid Selector" SubscriptionTestHelper.java - Implementation of Subscription.java Edited specs/amqp-8.0.xml to add field table to consume method. Thanks to the ActiveMQ project for writing the initial SelectorParser.jj and associated filter Expressions. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488624 13f79535-47bb-0310-9956-ffa450edef68
* QPID-215 : Patch supplied by Rob Godfrey - Implement custom JMSX propertiesRobert Greig2006-12-197-46/+233
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488596 13f79535-47bb-0310-9956-ffa450edef68
* Name correctedBhupendra Bhusman Bhardwaj2006-12-191-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488594 13f79535-47bb-0310-9956-ffa450edef68
* clean up warnings about unused variablesStephen Vinoski2006-12-1813-37/+13
| | | | | | | | 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