| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
|
| |
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
|
| |
|
|
|
|
|
| |
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
|
| |
|
|
|
|
|
| |
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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1087890 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@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
|
| |
|
|
|
|
|
|
|
| |
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
|
| |
|
|
|
|
|
|
|
|
|
| |
Removed the line which sets the create option to 'always'. Please note that the default create option is set to 'never'.
Therefore if just a queue name is specified the client will throw an exception if that queue is not present in the broker.
However this check will only be performed when a producer or consumer is created using that destination.
Also modified the existing test case to verify the default and the explicit create case.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1081460 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
The reliability mode is now used on the producer side to determine replay.
Any messages transfers sent to a destination marked unreliable will not be added to the replay buffer.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1079408 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1079402 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1079059 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Port of QPID-2864 changes from 0.5.x-dev branch to trunk.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1079042 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Set the default reliability modes for Topics and Queues.
The code now throws an exception if at-least-once is specified for Topics as we don't support it properly atm.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1078971 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Added a null check for the destination in both MessageConsumer and MessageProducer close methods.
According to the JMS spec the MessageProducer can be created with a null destination and still be used properly by specifying a destination on the send. Therefore this null check especially important on the message producer side.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1078961 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1078098 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Only UNRELIABLE and AT_LEAST_ONCE is supported.
Currently the reliability mode is used only for determining the accept-mode.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076800 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
The isQueueExist method is modified to handle the exception when a queue has been deleted.
Both the Message producer and consumer now delete the queue if the delete option is selected and will not check if the queue is empty or if there are any subscribers on it.
Also added test cases.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076670 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
- Change error checks so that don't throw an incorrect exception in getters
when the queue is null. This should only happen when sending.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076642 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
The getPropertyNames method will filter out any property names whose values are not allowed as per the JMS spec.
I could have used the ALLOWED map to check if a value is a valid type.
But unfortunately that map contains byte[] as a valid type, which is not correct as per the JMS spec.
I did not want to modify that map or the behaviour of the setObjectProperty or getObjectProperty methods as there might be applications out there that is depending on it.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076532 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Instead of checking if it's an instance of AMQQueue, the code the now checks if it's an instance of AMQDestination and javax.jms.Queue to cover the AMQAnyDestination case. The same check is done for topics. Added test cases for QueueReceivers, TopicSubscribers and DurableTopicSubscribers using the new addressing scheme.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076516 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
Added logic to look for the 'host' in the authority field if getHost returns null.
Looking at the code that follows, you could definitely make more improvements.
However since we are close to the 0.10 release I'd leave things as it is for the time being.
I have also added test cases to cover the issues highlighted by the respective JIRA.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076011 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
This commit allows a MapMessage to accept an UUID object in it's setObject method.
Added test cases for directly setting UUID objects or inside Maps and Lists that gets set into the MapMessage body.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1075961 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
available plugins for 0-10 codepath.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1075871 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071631 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Refactor test and fix 0-10 client session to flush acks
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071620 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071462 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Modified the code to use the correct system property name.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1069998 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
connection during connection handshake. Enable/make the 0-10 client use channel numbers 0 to N-1 in line with the spec, rather than 1-N.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1067210 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
the permature termination of Qpid client threads.
Applied patch from Keith Wall <keith.wall@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1067108 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
minor differences between 0-10 and 0-9 behaviour
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1064086 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
The createMessageProducer method now throws a JMSException.
The MessageProducer constructors now throw an AMQException allowing any exceptions caught during destination validation to be propogated back to the createMessageProducer method.
Fixed the exception handling for the 0-10 code path where all exceptions are chained properly. This allows the user to get all the relavent information by examing the stack trace.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1063123 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
Commiting a fix as per the solution outlined in the above JIRA.
A null check is added in the generateDestination method in AbstractAMQMessageDelegate.java where an ExchangeInfo object is created with just the exchange name to allow the destination to be created. The correct information will be querried when a consumer or producer is created with that destination.
If a replyTo address is available then the exchange info for that is querried and updated within the updateExchangeTypeMapping method in AMQMessageDelegate_0_10.java
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1061577 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
When the session is marked transactional, message transfers are not replayed.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1057460 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
If the exchange or routing key is null, it's now being set to empty string.
If set to empty string the message will be sent to the nameless exchange.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1038773 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1037923 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
convenience archive
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1037881 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1037878 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1037877 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1035028 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
longer exist
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1035027 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1032374 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1029523 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Committed patch from SorinS <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1003984 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Release lock before sleeping.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1002993 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
JNDI lookups
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1002675 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
Converts the argument Map to a FieldTable and add as an argument to messageSubscribe
Patch from <sorins@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1000407 13f79535-47bb-0310-9956-ffa450edef68
|