delta/python-packages/qpid-python.git/java/broker/src, branch jmsselectors git.apache.org: qpid.git FilterManagerFactory/JMSSelectorFilter.java - Added throw AMQInvalidSelectorException to be passed back to BasicConsumeMethodHandler.java and then to the Client. 2006-12-18T13:09:22+00:00 Martin Ritchie ritchiem@apache.org 2006-12-18T13:09:22+00:00 e787eba0d8b10f61e39fa7a6d8a6f12a00977d36 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 
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
AMQMessage.java - added take/release 2006-12-17T16:23:38+00:00 Martin Ritchie ritchiem@apache.org 2006-12-17T16:23:38+00:00 4595a9c2daebff1975f70b53ac35821a71535873 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 
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
QPID-21 2006-12-06T15:55:10+00:00 Martin Ritchie ritchiem@apache.org 2006-12-06T15:55:10+00:00 539571e411b4071a24e0568bc21d01eeae9706c6 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 
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. 2006-12-05T18:37:18+00:00 Martin Ritchie ritchiem@apache.org 2006-12-05T18:37:18+00:00 3e0bb26f85f3b06898eb71dced013dc5a1a076ab 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 
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
QPID-148 2006-12-04T16:38:10+00:00 Martin Ritchie ritchiem@apache.org 2006-12-04T16:38:10+00:00 ab09bbfdd27265f67d1f5e83c3f8953f2cacdf0d 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 
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
QPID-129 2006-11-27T16:51:44+00:00 Bhupendra Bhusman Bhardwaj bhupendrab@apache.org 2006-11-27T16:51:44+00:00 306988f998d552a03fa44a639cf743f1bdd5e794 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 
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
Changed logging from warn to info 2006-11-22T18:07:57+00:00 Martin Ritchie ritchiem@apache.org 2006-11-22T18:07:57+00:00 11decdf3b362aecb8ccb44ce123aa64449960952 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478264 13f79535-47bb-0310-9956-ffa450edef68 
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478264 13f79535-47bb-0310-9956-ffa450edef68
convert tests to junit3 2006-11-19T04:14:42+00:00 Stephen Vinoski vinoski@apache.org 2006-11-19T04:14:42+00:00 26f3bd59751462922e4c3268392a526a60ef7b2f git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@476701 13f79535-47bb-0310-9956-ffa450edef68 
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@476701 13f79535-47bb-0310-9956-ffa450edef68
complete bringing initial maven work to trunk 2006-11-18T03:48:15+00:00 Stephen Vinoski vinoski@apache.org 2006-11-18T03:48:15+00:00 be9f473e274d6cfe4cf8d8b04dd3f5a171ba9de4 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@476431 13f79535-47bb-0310-9956-ffa450edef68 
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@476431 13f79535-47bb-0310-9956-ffa450edef68
directory moves required for maven merge 2006-11-18T02:12:32+00:00 Stephen Vinoski vinoski@apache.org 2006-11-18T02:12:32+00:00 1db5a8a2329ec064d1683294ee1a3d8d233de42d git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@476414 13f79535-47bb-0310-9956-ffa450edef68 
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@476414 13f79535-47bb-0310-9956-ffa450edef68