summaryrefslogtreecommitdiff
path: root/java/common
Commit message (Collapse)AuthorAgeFilesLines
* Conversion of client/BasicMessageProducer to new Message classKim van der Riet2007-01-171-1/+14
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497138 13f79535-47bb-0310-9956-ffa450edef68
* Created wiring to client RequestManagers and ResponseManagers, refactored ↵Kim van der Riet2007-01-162-4/+4
| | | | | | all frame write code to use new write mechanisms. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496873 13f79535-47bb-0310-9956-ffa450edef68
* fixed several encoding/decoding bugsRafael H. Schloming2007-01-165-11/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496812 13f79535-47bb-0310-9956-ffa450edef68
* added request/response factories to AMQDataBlockDecoderRafael H. Schloming2007-01-164-2/+15
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496768 13f79535-47bb-0310-9956-ffa450edef68
* fixed broker compile errorsRafael H. Schloming2007-01-163-9/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496586 13f79535-47bb-0310-9956-ffa450edef68
* Changed the RequestManager to use AMQMethodListener instead of the old ↵Kim van der Riet2007-01-154-46/+27
| | | | | | AMQResponseCallback. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496499 13f79535-47bb-0310-9956-ffa450edef68
* Added a request/response id to the MethodEvent class that is used to ↵Kim van der Riet2007-01-152-6/+13
| | | | | | dispatch incoming messages to the handlers. Corrected some compile errors. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496456 13f79535-47bb-0310-9956-ffa450edef68
* Changed static method AMQMethodBody.createAMQFrame() to createMessageBody() ↵Kim van der Riet2007-01-153-11/+11
| | | | | | for all generated classes so that it can be used with the new Request and Response handlers. (Don't forget to update the gentools dir.) Created new methods AMQMinaProtocolSession.writeRequest() and writeResponse() as new entry points for Request and Response framing. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496439 13f79535-47bb-0310-9956-ffa450edef68
* Request and Respone managers now use the new common AMQMethodListener classKim van der Riet2007-01-153-66/+44
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496389 13f79535-47bb-0310-9956-ffa450edef68
* Merged the refactor to a common AMQMethodListener class on trunk, plus the ↵Kim van der Riet2007-01-151-0/+48
| | | | | | race condition fix of Robert Godfrey. This opens the way for Request and Response managers to use a common event dispatch for both client and server. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496326 13f79535-47bb-0310-9956-ffa450edef68
* Refactored to create a common AMQMethodEvent class; Added clinet Method* ↵Kim van der Riet2007-01-126-91/+183
| | | | | | handlers, removed old Basic* handlers. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@495581 13f79535-47bb-0310-9956-ffa450edef68
* Split the RequestResponseManager into RequestManager and ResponseManager ↵Kim van der Riet2007-01-113-48/+230
| | | | | | since these two functions are independent of each other. Also added a new exception. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@495251 13f79535-47bb-0310-9956-ffa450edef68
* Created new common interfaces to support the RequestResponseManager on both ↵Kim van der Riet2007-01-103-24/+83
| | | | | | client and server git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@495000 13f79535-47bb-0310-9956-ffa450edef68
* First version of RequestResponseHandler for an idea of how the ↵Kim van der Riet2007-01-103-27/+267
| | | | | | RequestResponse frames will be managed... Not quite complete, still need to find a means of writing the frames that is common to both client and server. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@494962 13f79535-47bb-0310-9956-ffa450edef68
* Oops - fixed a rather glaring compile error that I should not have missed :-(Kim van der Riet2007-01-092-6/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@494554 13f79535-47bb-0310-9956-ffa450edef68
* Corrected errors in AMQResponseBodyKim van der Riet2007-01-092-6/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@494549 13f79535-47bb-0310-9956-ffa450edef68
* New broker Messafe class handelrs added, removed old Basic* handlers; New ↵Kim van der Riet2007-01-093-25/+9
| | | | | | framing Request and Response classes added git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@494541 13f79535-47bb-0310-9956-ffa450edef68
* Completed first version of new Content class and the two new framing classes ↵Kim van der Riet2007-01-0813-1251/+117
| | | | | | AMQRequest and AMQResponse. Removed old Basic* and Content* classes. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@494181 13f79535-47bb-0310-9956-ffa450edef68
* New framing classes for AMQP 0-9 request and responseKim van der Riet2007-01-052-0/+172
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@493157 13f79535-47bb-0310-9956-ffa450edef68
* Updated hardwired version occurrences in java from major=8 minor=0 to ↵Kim van der Riet2007-01-052-3/+3
| | | | | | major=0 minor=9 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@493049 13f79535-47bb-0310-9956-ffa450edef68
* Merged changes from trunk to fix C++ client version 0-0 bug. Changes to ↵Kim van der Riet2007-01-051-12/+0
| | | | | | cpp/lib/common/Makefile.am, so bootstrap, configure required to remake Makefiels. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@493020 13f79535-47bb-0310-9956-ffa450edef68
* svn merge -r492717:492730 from the trunkRafael H. Schloming2007-01-043-85/+64
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@492777 13f79535-47bb-0310-9956-ffa450edef68
* Changes to lick off the 0-9 generation. Note that the new spec file ↵Kim van der Riet2007-01-041-2/+2
| | | | | | specs/amqp-nogen.0-9.xml causes the classes basic, file and stream not to generate. There are plenty of compile errors to sort through... git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@492634 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-227 Renamed version.properties to qpidversion.properties due to clash ↵Robert Greig2006-12-261-6/+40
| | | | | | 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 : 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-2211-1716/+1525
| | | | 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-2213-131/+77
| | | | | | 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
* QPID-227Bhupendra Bhusman Bhardwaj2006-12-211-6/+44
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489403 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
* 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
* Maven output clean up.Martin Ritchie2006-12-191-2/+2
| | | | | | 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-192-0/+75
| | | | | | | | | | | | | | | | | | 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-21Martin Ritchie2006-12-194-7/+69
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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
* remove unused importsStephen Vinoski2006-12-183-8/+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-201 : Fix to throw correct exception when getting char as null in ↵Robert Greig2006-12-163-63/+48
| | | | | | JMSMapMessage git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@487779 13f79535-47bb-0310-9956-ffa450edef68
* QPID-199 Patch supplied by Rob GodfreyRobert Greig2006-12-151-9/+23
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@487627 13f79535-47bb-0310-9956-ffa450edef68
* Changed name of getType() method to avoid clash with generated method of ↵Kim van der Riet2006-12-156-6/+6
| | | | | | same name git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@487579 13f79535-47bb-0310-9956-ffa450edef68
* QPID-182Martin Ritchie2006-12-152-64/+21
| | | | | | Fixed the incorrect exception being thrown by JMSPropertyFieldTable.java. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@487548 13f79535-47bb-0310-9956-ffa450edef68
* QPID-181 QPID-180Martin Ritchie2006-12-159-548/+2653
| | | | | | | | | | | | | | AbstractJMSMessage.java - updated to use getJMSHeaders JMSMapMessage.java - JMSPropertyFieldTable.java - Moved functionality of setting and retrieving a JMS property. Now shared by the Headers and MapMessageTest.java MapMessageTest.java - Updated the exceptions that are caught as all methods should throw a JMSException i.e. MessageFormatException TextMessageTest.java - Added tests for the Message Properties common/pom.xml - Added JMS dependency for the JMSPropertyFieldTable.java and associated tests EncodingUtils.java - changed comments and changed getencodedCharLength return to an int PropertyFieldTable.java - Cleaned up and now uses enum for prefixs. Created comprehensive test of both PropertyFieldTable classes. AMQPInvalidClassException.java - created to throw a runtime exception when trying to add a non-primative value. Forcing clients to handle this would break the Map usage of the FieldTable. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@487481 13f79535-47bb-0310-9956-ffa450edef68
* QPID-179 Patch supplied by Rob Godfrey. Field table remove was fundamentally ↵Robert Greig2006-12-131-17/+10
| | | | | | broken. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486793 13f79535-47bb-0310-9956-ffa450edef68
* QPID-9Martin Ritchie2006-12-133-26/+38
| | | | | | | | Updated EncodingUtils.java to include a single Character field so we can tell the difference between a char and a string of length 1. Tests changed accordingly. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486648 13f79535-47bb-0310-9956-ffa450edef68
* QPID-172Martin Ritchie2006-12-131-1/+7
| | | | | | Applied the same change to the second call to <threadpool>.execute() to be sure that a RejectedExecutionException doesn't appear. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486626 13f79535-47bb-0310-9956-ffa450edef68
* QPID-172Martin Ritchie2006-12-131-1/+44
| | | | | | The PoolingFilterTest.java would throw an ugly NullPointerException. This was due to there being no next filter. So Created a NoOpFilter that prevents this. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486610 13f79535-47bb-0310-9956-ffa450edef68
* QPID-172Martin Ritchie2006-12-133-1/+335
| | | | | | | | | | | | | | | RejectedExecutionException. In fireEvent added additional checks :_poolReference.getPool() != null && !_poolReference.getPool().isShutdown() to if (job.activate()) As active jobs were being put on a pool that was shutdown. Included a test to check that the RejectedExecutionException doesn't occur. (add ignore for example/target) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486596 13f79535-47bb-0310-9956-ffa450edef68
* QPID-9Martin Ritchie2006-12-132-4/+22
| | | | | | | | Added ability to send NULL Strings. EncodingUtils.java now returns an empty string for a zero lengthed String. To send a null string use prefix 'n' MapMessageTest.java - Updated to test emptyString and nullString behave correctly. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486574 13f79535-47bb-0310-9956-ffa450edef68
* QPID-164Martin Ritchie2006-12-124-84/+330
| | | | | | | | | | | JMSMapMessage.java - fixed incorrect exceptions and return values. Data now sent as a Bytes message. MapMessageTest.java - updated to be more through with the testing of the returned message EncodingUtils.java - added unsignedIntegerLength() FieldTableFactory.java - removed specific PropertyFieldTable reference PropertyFieldTable.java - fixed encoding issues that were causing BufferOverflow errors. PropertyFieldTableTest.java - added test to ensure that the encoding size is correct for ALL types. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486254 13f79535-47bb-0310-9956-ffa450edef68
* Corrected compile errorKim van der Riet2006-12-111-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@485788 13f79535-47bb-0310-9956-ffa450edef68
* Added stubs for new Content interface to support new AMQP 0-9 transportKim van der Riet2006-12-112-0/+43
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@485730 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status