summaryrefslogtreecommitdiff
path: root/java
Commit message (Collapse)AuthorAgeFilesLines
* Trunk MergesMartin Ritchie2006-12-1823-112/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/jmsselectors@488302 13f79535-47bb-0310-9956-ffa450edef68
* Updated imports as VMBroker has changed to testutil.Martin Ritchie2006-12-183-2/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/jmsselectors@488291 13f79535-47bb-0310-9956-ffa450edef68
* AMQInvalidSelectorException.java - used by both client and server for ↵Martin Ritchie2006-12-181-0/+31
| | | | | | reporting when the selector is invalid git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/jmsselectors@488274 13f79535-47bb-0310-9956-ffa450edef68
* FilterManagerFactory/JMSSelectorFilter.java - Added throw ↵Martin Ritchie2006-12-1820-577/+1451
| | | | | | | | | | AMQInvalidSelectorException to be passed back to BasicConsumeMethodHandler.java and then to the Client. Addition of ConcurrentSelectorDeliveryManager.java. This uses the additional methods on Subscription (hasFilters, hasInterest) to implement selectors. Trunk Merges git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/jmsselectors@488264 13f79535-47bb-0310-9956-ffa450edef68
* AMQSession - Modified to correctly throw : InvalidSelectorMartin Ritchie2006-12-18158-1872/+5943
| | | | | | | PropertiesFileInitialContextFactory.java - augmented to load properties file from PROVIDER_URL if it is specified. Trunk Merges git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/jmsselectors@488262 13f79535-47bb-0310-9956-ffa450edef68
* Trunk MergesMartin Ritchie2006-12-1826-573/+3717
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/jmsselectors@488251 13f79535-47bb-0310-9956-ffa450edef68
* Trunk MergesMartin Ritchie2006-12-1856-620/+1113
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/jmsselectors@488232 13f79535-47bb-0310-9956-ffa450edef68
* AMQMessage.java - added take/releaseMartin Ritchie2006-12-1714-35/+171
| | | | | | | | | | | | | AMQQueue.java - enabled parameterisation of DeliveryManager Subscription.java - added PreDeliveryQueues SubscriptionImpl.java - Implementeted PDQs and added Selector/filter hooks SubscriptionManager.java - added ability to get all Subscriptions SubscriptionSet.java - updated getNextSub*Impl to take filters in to account. SynchronizedDeliveryManager.java - Fixed Logger Class AMQSession.java - Fieldtable Changes git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/jmsselectors@488002 13f79535-47bb-0310-9956-ffa450edef68
* pom.xml - added jms and junit referencesMartin Ritchie2006-12-171-1/+23
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/jmsselectors@488000 13f79535-47bb-0310-9956-ffa450edef68
* QPID-21Martin Ritchie2006-12-0637-76/+3765
| | | | | | | | | | | | | | | | | | | | | | | | | | Broker Pom - Added geronimo jms jar - and javacc plugin for selectors. AMQMessage.java - Added decorator to extract JMS information. AMQQueue.java - Mainly whitespace - added filter argument to session registration Subscription.java - Added hasFilters and isInterested to enable the filtration process SubscriptionFactory.java - new constructor that takes the FieldTable of filters. {Test|Remote}Subscription{Impl}.java - Implementation of Subscription{Factory}.java features. SubscriptionSet.java - White space and added hasFilter/isInterested calls to determine nextSubscriber. AMQSession.java - Create FilterTable for basic.consume. AbstractJMSMessage.java - Updated println to provide further jms header details. URLHelper.java - whitespace URLSyntaxException.java - tidied up output amqp-8.0.xml - augmented consume to have argument field table Server/filter - Filtration classes from ActiveMQ and new FilterManager.java to drive them. message/jms - Decorator implementation MessageDecorator.java - Handles decoration of AMQMessages - currently hardwired but could be used to scan classpath. SelectorTest.java - Simple test to see that selectors work. Not exhaustive. FieldTableInTextMessageTest.java - Test that the Fieldtable (properties)in a TextMessage work as expected. (QPID-9) Reinvestigate wrt QPID-158 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/jmsselectors@483127 13f79535-47bb-0310-9956-ffa450edef68
* FieldTable change.Martin Ritchie2006-12-0523-734/+1102
| | | | | | | | | | | | | | | | | | | | | | | | | | 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
* use gnu mode for tarLongFileMode to avoid warnings about long pathnamesStephen Vinoski2006-12-051-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482697 13f79535-47bb-0310-9956-ffa450edef68
* QPID-51Bhupendra Bhusman Bhardwaj2006-12-054-29/+96
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482571 13f79535-47bb-0310-9956-ffa450edef68
* QPID-51Bhupendra Bhusman Bhardwaj2006-12-051-0/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482570 13f79535-47bb-0310-9956-ffa450edef68
* Added eclipse license info to the notice fileMarnie McCormack2006-12-051-0/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482557 13f79535-47bb-0310-9956-ffa450edef68
* Added license for Eclipse binariesMarnie McCormack2006-12-051-0/+88
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482555 13f79535-47bb-0310-9956-ffa450edef68
* add qpid.targetDir property to control where assemblies goStephen Vinoski2006-12-041-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482369 13f79535-47bb-0310-9956-ffa450edef68
* changes to support the assembly:directory goalStephen Vinoski2006-12-041-86/+99
| | | | | | | | | | | | | * Allow the assembly:directory goal to be used to create an install directory under the target directory. This directory basically contains the contents of the qpid-java-bin tar/zip artifacts, and is suitable as a spot from which to execute the broker or other qpid applications directly, by setting QPID_HOME to point there and adding the bin directory therein to your PATH. * Reformatted this pom file to 4-space indents, to match the other pom files git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482289 13f79535-47bb-0310-9956-ffa450edef68
* Changed JMSReplyTo Queue to test temporary queue values to verify QPID-149Martin Ritchie2006-12-041-2/+16
| | | | | | Worked ok. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482243 13f79535-47bb-0310-9956-ffa450edef68
* QPID-51 Bhupendra Bhusman Bhardwaj2006-12-041-0/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482240 13f79535-47bb-0310-9956-ffa450edef68
* QPID-148Martin Ritchie2006-12-044-184/+354
| | | | | | | | | | | | | | | 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
* git-svn-id: ↵Bhupendra Bhusman Bhardwaj2006-12-0487-0/+7933
| | | | https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482181 13f79535-47bb-0310-9956-ffa450edef68
* first cut at client-only packagingStephen Vinoski2006-12-012-0/+90
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@481442 13f79535-47bb-0310-9956-ffa450edef68
* FieldTable.java no longer has a keys() method as it already has a keySet(). ↵Martin Ritchie2006-11-302-13/+18
| | | | | | Plus the implementation was broken. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@480973 13f79535-47bb-0310-9956-ffa450edef68
* QPID-139Martin Ritchie2006-11-301-2/+9
| | | | | | | | When the custom headers are empty no field table would be created. This null value would cause problems for various methods in AbstractJMSMessage. Simply create an empty FieldTable to save handling the null value. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@480912 13f79535-47bb-0310-9956-ffa450edef68
* QPID-122Martin Ritchie2006-11-289-72/+263
| | | | | | | | | | Pulled _readable (_readableMessage) boolean up to AbstractJMSMessage.java and created (_readableProperties). Checks are now carried out to ensure that the message is readable/writable for the operation so that the correct exception can be thrown. As per the spec. clearBody() method had been implemented in AbstractJMSMessage.java to reset the _readableMessage as a result implementations must now implement clearBodyImpl() which is called before the _readableMessage is reset. Test updated to check that properties and body are correctly read/write set. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@480119 13f79535-47bb-0310-9956-ffa450edef68
* Redundant files removedMarnie McCormack2006-11-283-297/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@480090 13f79535-47bb-0310-9956-ffa450edef68
* Further example tidy upMarnie McCormack2006-11-284-48/+91
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@480089 13f79535-47bb-0310-9956-ffa450edef68
* Further example tidy upMarnie McCormack2006-11-284-39/+44
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@480088 13f79535-47bb-0310-9956-ffa450edef68
* QPID-71Martin Ritchie2006-11-281-10/+43
| | | | | | Update to handle bad characters after port value. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@480032 13f79535-47bb-0310-9956-ffa450edef68
* QPID-71Martin Ritchie2006-11-282-34/+93
| | | | | | | Moved some tests from ConnectionURLTest to BrokerDetailsTest to better reflect the actual class being tested. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@480031 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
* Changes for JMS TCK TestingRajith Muditha Attapattu2006-11-274-3/+217
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@479640 13f79535-47bb-0310-9956-ffa450edef68
* Fixed the situation where a closed session could try and close itself more ↵Martin Ritchie2006-11-271-20/+28
| | | | | | than once. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@479560 13f79535-47bb-0310-9956-ffa450edef68
* properly limit scope for test-only dependenciesStephen Vinoski2006-11-246-42/+14
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@479050 13f79535-47bb-0310-9956-ffa450edef68
* fix assembly plugin file permissions bug number noted in commentStephen Vinoski2006-11-241-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@479030 13f79535-47bb-0310-9956-ffa450edef68
* fix name of qpid-incubating.jarStephen Vinoski2006-11-241-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478975 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
* Initial example class overhaul - still some way to go.Marnie McCormack2006-11-2420-365/+293
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478854 13f79535-47bb-0310-9956-ffa450edef68
* Added example.properties file and amended tests to use for ↵Marnie McCormack2006-11-242-10/+76
| | | | | | PropertiesFileInitialContextFactoryTest. Good example (I hope) for users. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478822 13f79535-47bb-0310-9956-ffa450edef68
* speed up testStephen Vinoski2006-11-231-7/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478444 13f79535-47bb-0310-9956-ffa450edef68
* Fix for Java TCK using createTopicConnection(username,password)Martin Ritchie2006-11-231-4/+18
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478413 13f79535-47bb-0310-9956-ffa450edef68
* client/pom.xml - removed TransactedTest.java from exclude Listener.javaMartin Ritchie2006-11-222-2/+1
| | | | | | TransactedTest.java - fixed naming of setup to setUp git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478380 13f79535-47bb-0310-9956-ffa450edef68
* * use VMBrokerSetup test helper class where appropriateStephen Vinoski2006-11-223-14/+12
| | | | | | | * change notifyAll() to notify() in MultipleConnectionTest.java git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478343 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
* [Text|Object]MessageTest.java - added tests that will fail as per QPID-122 ↵Martin Ritchie2006-11-222-19/+19
| | | | | | but commented them out! So mvn passes all tests git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478266 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
* PropertyFieldTableTest.java - Removed system.out.printlnMartin Ritchie2006-11-222-11/+10
| | | | | | pom.xml removed skip test item and added junit dependency. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478260 13f79535-47bb-0310-9956-ffa450edef68
* QPID-119Martin Ritchie2006-11-2217-34/+1008
| | | | | | | | | | | | | | | | | | | Creations: JMSMapMessageFactory.java JMSMapMessage.java MapMessageTest.java for both Object functionality and functionality being sent around. Modifications: AbstractJMSMessage.java - fixed propertyExists() Method not very elegant but when re-factored to use an AMQHeaderPropertyFieldTable it will be better. made setObjectProperty throw RuntimeException as to highlight that it implemented. removed duplicate code in checkPropertyName JMS[Bytes|Object]Message/Factory.java - swapped parameter headers around to match the order in AbstractJMSMessage.java for consistency. TestMessageHelper.java/MessageFactoryRegistry.java - added MapMessage type BytesMessageTest.java - Added tests for read and writeability of message. FieldTableMessageTest.java - Tidied imports [Text|Object]MessageTest.java - added tests that will fail as per QPID-122 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478253 13f79535-47bb-0310-9956-ffa450edef68