| Commit message (Collapse) | Author | Age | Files | Lines |
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/jmsselectors@726140 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/jmsselectors@488302 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/jmsselectors@488291 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
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
|
|
|
|
|
|
|
|
|
|
| |
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
|
|
|
|
|
|
|
| |
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
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/jmsselectors@488251 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/jmsselectors@488232 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Renamed filter table to arguments.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/jmsselectors@488226 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
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/jmsselectors@488000 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
|
|\
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/jmsselectors@483032 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
2006-12-05 Jim Meyering <meyering@redhat.com>
Improve --help output. Add --version option.
* lib/broker/Configuration.cpp: Include <config.h>.
(Configuration::Configuration): Use the active voice.
Handle --version.
(Configuration::usage): Add Usage:... and bug-reporting address.
Output short+long options like "-o, --option ...", so that help2man
will format them properly.
* lib/broker/Configuration.h:
(class Configuration) [version, programName]: New members.
(parse): Update prototype.
(isVersion, setValue): New prototypes.
* src/qpidd.cpp: Include <config.h>.
(programName): New file-scoped global.
(handle_signal, main): Emit diagnostics to stderr.
(main): Pass program name to config.parse.
(main): Handle new --version option.
Also updated ConfigurationTest to use the modified parse() method.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482958 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| | |
* src/qpidd.cpp (main): Remove now-pointless FIXME comments.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482773 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| | |
* src/qpidd.cpp (main): Remove now-pointless FIXME comments.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482772 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
|
| |
| |
| |
| |
| |
| |
| |
| | |
Define policy based on these settings.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482723 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482697 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| | |
released from memory.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482639 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
2006-12-05 Jim Meyering <meyering@redhat.com>
* gen/Makefile.am (timestamp): Remove unnecessary "; \",
that could have obscured a failure.
(gen-src.mk): Use echo 'var = '\\, rather than 'var = \'.
Both work, but emacs' font-lock mode mishandles the latter.
* bootstrap: Give JAVA and JAVAC default values, and export them.
Don't define abs_srcdir; no longer needed.
Also filter out gen/Makefile.am's echo warning: ...
Add comments.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482637 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482571 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482570 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482557 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482555 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482369 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
Changes to make "make distcheck" pass.
* gen/Makefile.am (DISTCLEANFILES): List gen-src.mk here,
rather than distributing it.
(gen-src.mk): Guard emitted java_sources and cxx_templates
templates with "if BUILD_IN_MESSAGE_TREE" conditional.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482367 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482365 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
* 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
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482263 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
This patch improves the performance of my test by about 20%
It removes a lot of unnecessary string creation, as ...::check(...) is called for every CHECK_APR_SUCCESS(), and they are very frequent.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482262 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
* configure.ac: Use an automake conditional to indicate when we
have access to files outside of the current hierarchy, and when
we have the tools (java and javac) to build some generated files.
* gen/Makefile.am: Don't use $(abs_srcdir); not needed.
(timestamp): Depend on java sources and C++ template files,
if we're building in a qpid tree.
Use $(JAVA) and $(JAVAC), rather than hard-coding those names.
(gen-src.mk) [$(java_sources), $(cxx_templates)]: New rules to
generate these lists of file names.
* bootstrap: Also generate gen/gen-src.mk.
But do that only if we're in a qpid hierarchy.
Redirect make's stdout to /dev/null.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482255 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482254 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
* configure.ac: Check for cppunit (>= 1.11.4).
Set/substitute CPPUNIT_CXXFLAGS.
* tests/Makefile.am (extra_libs): Use $(CPPUNIT_LIBS),
rather than hard-coding -lcppunit.
(AM_CXXFLAGS): Add $(CPPUNIT_CXXFLAGS).
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482252 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482249 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482248 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| | |
Worked ok.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482243 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482240 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
|
| |
| |
| |
| |
| |
| | |
parser must support "host" name. Use "default" when you don't want to really supply one.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482237 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482233 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482194 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482181 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| | |
Java client doesn't have it either and AMQP 0.9 will bring changes in this area).
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482145 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@481442 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@481381 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| | |
building the source distro. The latter needs work.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@481335 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| | |
More svn:ignore properties.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@481333 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@481312 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@481305 13f79535-47bb-0310-9956-ffa450edef68
|