| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
|
|
| |
accept ConnectionURL in place of AMQProtocolSession (improved information hiding, ease ability to write good unit tests). Remove unused protected constructor from AMQConnection and MockAMQConnection.
Applied patch from Keith Wall <keith.wall@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1127939 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1103899 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
The default for routing key should be based on the context.
i.e for sending it should be "" and for receiving it should be "#".
However we currently don't have a way of handling this properly. Therefore defaulting it to "".
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1103884 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
the wrong failover policy to be used. Wrote new unit test case and resolved the defect.
Applied patch from Keith Wall <keith.wall@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1103857 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1103727 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1103726 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1103725 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1103724 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Applied patch from Keith Wall <keith.wall@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1102258 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Added test cases for creating durable subscriptions for various address strings.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1102103 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Added a check to ensure that durable subscriptions are only created for Topics.
Added code to mark a destination durable. If the addressing string explicitly specified durable==false, it will be overriden.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1102102 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
Added logic to resolve the address to ensure corner cases such addresses without subjects are handled properly.
The address resolotuion code will determine the defaults for subject (and routing key) by querying the name specified in the address.
I also added null checks for getRoutingKey() method and getTopicName() method in both AMQTopic and AMQAnyDestination classes.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1102002 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Rolling back the change until we fix the deadlock issue identified in QPID-3216
Also investigate the other test failure to see if there are any other issues besides the deadlock problem.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1101861 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
| |
manipulation abilities. 1) Removed remaining jmx access functionality. 2) Removed references to security/jmx/access from all existing configuration files. 3) Made ServerConfiguration#validateConfiguration reject config files that still contain the security/jmx/access element in order to promote good end-user understanding of configuration.
For JMX:
1) setRights now throws UnsupportedOperationException with message.
2) createUser(string,string,bool,bool,bool) throws UnsupportedOperationException iff any of the bool args are true i.e. the user attempts to give a user access JMX rights
3) Deprecated createUser(string,string,bool,bool,bool) in favour of new two arg form createUser(string,string)
4) viewUsers changes to always return admin, read, and write items as false.
Applied patch from Keith Wall <keith.wall@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1101483 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
configuring 'remote' repo location, tidy up some use of literal values
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1100952 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
The ack fusher task is now cancelled when the session is closed due to an error received from the broker.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1099634 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
If the underlying AMQP session gets closed, the JMS session is now notified along with details that caused the session closure.
The JMS Session will throw an exception (with an error code and details) when a user accesses the closed session.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1099288 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
Committing the suggested fix by Gordon Sim.
All though the currentException may change by the time we call connection.exceptionReceived() it's not really a big issue.
Chance of getting two successive sessions exceptions is rare if not none at all.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1099060 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
have been merged back into place after a previous removal
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1095942 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
of the new functionality
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1095651 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1095059 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
to a staging repo in the ASF Nexus instance
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1095038 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1094445 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Changed the value of sendClose to "true" as we need to send message-cancel if the session has not encountered any errors.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1092510 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Added the nessacery null checks to avoid a NPE due to missing delivery props or headers all together.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1091507 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Changed the keyword from "alt-exchange" to "alternate-exchange".
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1090422 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Added logic to use the alternate exchange when issuing the queue-declare.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1090421 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
Added a test case to cover the above issue.
This class can use a bit of refactoring and some consolidation of test cases.
Hoping to do that soon.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1089554 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
A queue-bind is now issue when creating a queue under node props or for the subscription queue under link props.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1089552 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
support the creation of .classpath and .project files for the Eclipse IDE. Relies on http://ant-eclipse.sourceforge.net/
Applied patch from Keith Wall <keith.wall@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1088946 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Applied patch from Andrew MacBean <andymacbean@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1088934 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
class, based on review feedback from Keith Wall for QPID-3167
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1088639 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
testSubscriptionSpecificRequeueForQueueWithMultipleSubscriptions and testSubscriptionSpecificRequeueForQueueWithMultipleSubscriptions.
Applied patch from Keith Wall <keith.wall@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1088562 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Subscription) and QueueEntryImpl.requeue(QueueEntryImp, Subscription subscription). SimpleAMQQueue.requeue(QueueEntryImpl, Subscription) was last used from SubscriptionImpl.java, but this was removed on 2009-10-25.
Applied patch from Keith Wall <keith.wall@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1088561 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1087890 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
fails to pad bytes in range 0A-0F with leading zero. Add testcase to test CRAM-MD5-HEX mechanism. Guard against nulls in SASL SaslServerFactory.getMechanismNames implementations to avoid dependency on mechanism registration order.
Applied patch from Keith Wall <keith.wall@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1087249 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
when subscriptions with unique selectors are in use
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1087000 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1086769 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1086169 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
ConnectionRegistry into the setState() method to ensure it occurs in all cases. Also move registration into setState().
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1086041 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
on whether to stop delivering. Use a boolean instead of doing a 0/1 toggle and update variables to generally clarify logic. Use an int instead of a long for the iteration decrementing
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1086040 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
multiple consumers using unique selectors. Exposes issue detailed in QPID-3165.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1086039 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1085187 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
The address parser treats 'true' as a string while it treats 'True' as a boolean.
Therefore I modified the AddressHelper class to expect both forms. The MapAccessor class used for the rest of code already handles this case.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1084462 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Excluding the testGetPropertyNames test case until we make a decision on whether to apply the same fix for 0-8 codepath.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1084420 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Removed the explicit use of addressing in the test case to enable it to be run under any profile.
This seems better than excluding it from the default and 0.8 profiles as the test doesn't really have anything to do with addressing.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1084414 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
I had checked in an incomplete test case with rev 1082719
I had made certain changes to the test case for testing another potential fix, but forgot to revert it back to the original before committing.
Re applied the changes to adequately test the issue.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1084048 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1082719 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
Added a temp hack to get the testReplyToWithNamelessExchange passing with the java.0.10 test profile.
In doing so I realized that "qpid.declare_exchanges" has no affect on the producer side.
Therefore I added a check in BasicMessageProducer_0_10.java to check this flag before issuing an exchange_declare.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1082715 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
| |
Added testReplyToWithCustomExchange as a test case for QPID-3011
Removed testAddressBasedReplyTo as the above test cases cover it adequately.
Currently the testReplyToWithNamelessExchange fails with the java.0.10 test profile.
This is due to the default being BURL and the replyTo address is evaluated as a BURL and as part of the logic an exchange declare is being set.
The C++ broker does seem to ignore the exchange declare of a known type (the nameless exchange in this case), while the java broker throws an exception.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1082709 13f79535-47bb-0310-9956-ffa450edef68
|