summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* move qpid to tlpevent-queue-2006-12-20Joe Schaefer2008-12-120-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/event-queue-2006-12-20@726140 13f79535-47bb-0310-9956-ffa450edef68
* cpp/tests: remmoved redundant scripts, get topictest running in VPATH build.Alan Conway2006-12-215-99/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/event-queue-2006-12-20@489404 13f79535-47bb-0310-9956-ffa450edef68
* Simplify EventChannel.cpp: remove unnecessary DispatchEvent feature.Alan Conway2006-12-213-57/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/event-queue-2006-12-20@489249 13f79535-47bb-0310-9956-ffa450edef68
* EventChannel.cpp: Simplified handling of wakeups for multiple events byAlan Conway2006-12-213-28/+45
| | | | | | | | using epoll's level-triggered behavior to "put back" an event and let it wake up later. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/event-queue-2006-12-20@489237 13f79535-47bb-0310-9956-ffa450edef68
* EventChannel.cpp: Fixed error handling problems causing EBADF exceptions.Alan Conway2006-12-202-38/+26
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/event-queue-2006-12-20@489225 13f79535-47bb-0310-9956-ffa450edef68
* EventChannel.h/cpp: Simpler event completion, events are always returned on Alan Conway2006-12-205-76/+160
| | | | | | | | | | | | | | | first wakeup even if they have not read/written all required data. Application is responsible for re-posting the event or posting new events as required. EventChannelConnection::endWrite(): re-posts writeEvent till entire frame is written (required by simplificationa above.) Added EventChannel::shutdown(): causes EventChannel::wait() to throw an EventChannel::ShutdownException() to all waiting threads. Simplified EventChannelThreads::shutdown() to take advantage of this. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/event-queue-2006-12-20@489218 13f79535-47bb-0310-9956-ffa450edef68
* Fix compile error.Alan Conway2006-12-201-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/event-queue-2006-12-20@489168 13f79535-47bb-0310-9956-ffa450edef68
* Current state of event channel code.Alan Conway2006-12-2041-779/+1108
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/event-queue-2006-12-20@489159 13f79535-47bb-0310-9956-ffa450edef68
* Branch for event channel work in progress.Alan Conway2006-12-200-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/event-queue-2006-12-20@489152 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
* Adding files for EventChannel implementation.Alan Conway2006-12-207-0/+835
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489110 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
* make rpm in cpp directory builds qpidc RPMs in default locations.Alan Conway2006-12-205-28/+77
| | | | | | | | | Note: you need to chown or chmod the directories under /usr/src/redhat/RPMS/i386 to be writable for this to work, there is probably a better solution. Building RPMs as root is a Bad Idea. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489103 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
* Removed LinkedHashTable.cs from Qpid.Client project as it is supplied by the ↵Steven Shaw2006-12-192-217/+0
| | | | | | | | | | Qpid.Common project. Note that LinkedHashTable.cs was not being compiled by the VS.NET 2005 project as it was not part of Qpid.Client.csproj. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488852 13f79535-47bb-0310-9956-ffa450edef68
* Fixed warning.Steven Shaw2006-12-192-29/+20
| | | | | | | FailoverTxTest now using connection URI for configuration. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488844 13f79535-47bb-0310-9956-ffa450edef68
* Added Qpid.Client.Transport.Socket.Blocking project to MonoDevelop files.Steven Shaw2006-12-1917-46/+64
| | | | | | | Fixed some compiler warnings. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488830 13f79535-47bb-0310-9956-ffa450edef68
* Added Mono-Develop IDE filesSteven Shaw2006-12-198-0/+478
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488810 13f79535-47bb-0310-9956-ffa450edef68
* [For Andrew Stitcher] inlined qpid::sys::check() in APRBase.h; This is ↵Kim van der Riet2006-12-192-10/+12
| | | | | | called a lot - for every call to an APR call, inlining this seems to give about 8% speed in my tests (even though originally check() only seemed to use 1-2% of the time). I think this must be a 2nd order instruction caching effect. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488808 13f79535-47bb-0310-9956-ffa450edef68
* [For Andrew Stitcher] Made the generator generate non-virtual inheritance; ↵Kim van der Riet2006-12-193-3/+3
| | | | | | it doesn't create a noticeable speed up in itself, but it's not needed where it's used. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488801 13f79535-47bb-0310-9956-ffa450edef68
* Code tidy-up in code generatorKim van der Riet2006-12-1913-321/+180
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488799 13f79535-47bb-0310-9956-ffa450edef68
* Print program locations with versions.Alan Conway2006-12-191-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488771 13f79535-47bb-0310-9956-ffa450edef68
* * cpp/gen/Makefile.am: fixed generated code dependencies.Alan Conway2006-12-199-35/+41
| | | | | | | | * *Channel,SessionHandlerImpl,FramingTest: added FieldTable argument to consume() to conform to updated XML. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488745 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-1949-102/+4263
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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
* QPID-212 QPID-214 Patch supplied by Rob GodfreyRobert Greig2006-12-186-27/+187
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488377 13f79535-47bb-0310-9956-ffa450edef68
* QPID-213 Bhupendra Bhusman Bhardwaj2006-12-186-271/+270
| | | | | | management GUI improvements git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488352 13f79535-47bb-0310-9956-ffa450edef68
* [For Jim Meyering] Added new utility to download and build required tools to ↵Kim van der Riet2006-12-182-7/+235
| | | | | | build the C++ version git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488343 13f79535-47bb-0310-9956-ffa450edef68
* Added additional svn:ignore properties for cpp/gen to accomodate new ↵Kim van der Riet2006-12-180-0/+0
| | | | | | generated files. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488314 13f79535-47bb-0310-9956-ffa450edef68
* Added additional files AMQP_HighestVersion.h/.cpp to identify the highest ↵Kim van der Riet2006-12-185-1/+84
| | | | | | available version for client use. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488304 13f79535-47bb-0310-9956-ffa450edef68
* QPID-188 Bhupendra Bhusman Bhardwaj2006-12-181-0/+179
| | | | | | Adding unit tests for Java broker JMX code git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488281 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-209 Fix to clear unacked message list on recover()Robert Greig2006-12-182-17/+23
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488249 13f79535-47bb-0310-9956-ffa450edef68
* Not needed.Bhupendra Bhusman Bhardwaj2006-12-181-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488217 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
* QPID-125Bhupendra Bhusman Bhardwaj2006-12-1823-112/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488164 13f79535-47bb-0310-9956-ffa450edef68
* QPID-209 : Patch supplied by Rob Godfrey - Fix acknowledge so it only ↵Robert Greig2006-12-184-30/+108
| | | | | | acknowledges messages that have actually been consumed git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488159 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status