| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
|
|
| |
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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@963232 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
custom PrincipalDatabase's which cant actually return password data, and revert r961923 changes.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@962870 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
protected method
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@961923 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@961869 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@961866 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
The producer now checks for the presense of qpid.subject in the header and uses it as the routing-key if sending to an exchange.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@961862 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
The SSL receiver now logs the error and also reports it up the stack.
It also notifies the sender not to wait any longer.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@961860 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Applied patch from Andrew Kennedy <andrew.international@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@961820 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@960767 13f79535-47bb-0310-9956-ffa450edef68
|