| Commit message (Collapse) | Author | Age | Files | Lines |
... | |
|
|
|
|
|
|
| |
Applied patch from Sorin Suciu <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@981268 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
properties
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@981231 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Applied patch from Sorin Suciu <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@981106 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Applied patch from Sorin Suciu <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@981105 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Applied patch from Sorin Suciu <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@981103 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
included in the AddressHelper.java
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@980287 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
If the exchange type is not specified, then it is set to null when parsing the string.
If the exchange needs to be created, it's set to 'topic' if the exchange type is null.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@980259 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
| |
The pre-aquire flag is now computed differently for each dest syntax type.
For BURL the exchange type is also queried if the Destination is not an instance of AMQTopic.
For ADDR, if the browse mode is set, then pre-acquire is set to false irrespective of the node type.
We still continue to use pre-acquire=false if selectors are present.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@980232 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
My initial checkin was not entirely correct as it does violate the JMS spec for property type conversion, since it will now first convert all property types (except Double) to a String and then on to a Double. Only Floats, Doubles, and Strings are allowed to be read back as a Double value, everything else should throw a MessageFormatException. Thx Robbie for pointing this out.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@980143 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
Created a proxy method that calls exception() which takes a thrown
AMQException and gets the error code if it can be translated and
creates the error message description from the exception message.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@980020 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
This fixes the MemoryMessageStoreLoggingTest where a check is made for the
broker store class name.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979999 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Instead of doing Double.valueOf(Float.valueOf(value)) , I changed it to use Double.valueOf(value).
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979933 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979767 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979316 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
This is a sub-class of AMQInternalException, which encapsulates error code 541,
or INTERNAL_ERROR.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979315 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979294 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979293 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979291 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979290 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979289 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979288 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
Added a sessionRequestTimeout handler that sets expiry and responds with a
sessionTimeout, and makes sessionTimeout set expiry appropriately also. On
attach uses the expiry provided, rather than forcing a value of 0.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979283 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979213 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979212 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979208 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
setObjectProperty
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979201 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
Added the LVQTest to the java excludes list.
Eventually we should have a single test from the JMS client side that will work with both the Java and C++ brokers.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966764 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
Added a test case to create and LVQ from the JMS client using the addressing syntax.
Fixed a few bugs in QpidQueueOptions.java.
Modified the MapAccessor to allow any value to be retrieved as a String.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966763 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966755 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966752 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966724 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966722 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966681 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
setObjectProperty in Field Table and via JMS Properties
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966680 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966678 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
requests if it is set.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966677 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966637 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966634 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
You could now susbcribe to any queue using browse mode and use a regular MessageConsumer (even with a MessageListener) instead of having to use a Queue Browser.
Ex. 'my-ring-queue; {mode: browse}'
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966284 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
within the QPID_WORK directory
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@966153 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
As the initial step, all subscription queues are marked exclusive and auto-delete.
When support for reliability is added, the reliability mode will be taken into account.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@965713 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@965425 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@964998 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
The session.createQueue and session.createTopic methods will behave as
follows.
session.createQueue
===================
1. If just a queue name is passed,
1.1 If the destination syntax is BURL, a queue
by that name will be created and bound to the amq.direct exchange using
the queue name as the binding key. If published using this destination,
then the message will be sent to amq.direct with routing key set to the
queue name.
1.2 If destination syntax is ADDR, a queue is created by that name.
If published using this exchange then the message will be sent to the
defualt exchange (nameless exchange) with routing key set to the
queue name.
2. If an address string or binding url is passed, it will be passed
accordingly.
session.createTopic
===================
1. If just a topic name is passed,
1.1 If destination syntax is ADDR, a temp queue is created and bound to
the amq.topic with the topic name as binding key. If published using
this destination, then the message will be sent to amq.topic with the
topic name set to routing key. The topic name will also be set as
"qpid.subject" in the outgoing message.
1.2 Same as above except there will be no subject set.
2. If an address string or binding url is passed, it will be passed
accordingly.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@964984 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
DerbyMessageStore. Test update of queue exclusivity. Apply various fixes to allowtest to pass (correct exchange count checks, flush messages to the store, delete store directory properly, check for the proper value for selector argument, add ability to unregister virtualhosts from the registry)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@964830 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
statement execution and move its closure after use use the output ResultSet.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@964829 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@964827 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@964825 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@964824 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
processing in GenerateLogMessages, allowing builds with spaces in the full path to work
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@964073 13f79535-47bb-0310-9956-ffa450edef68
|