| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
|
|
| |
address string from the replyTo construct. The application which sets
the replyTo is responsible for creating/deleting the replyTo destination
and not the one who sends messages to it.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1165702 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
strings.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1165148 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
handles the SessionException and throws a JMSException.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1163867 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1163459 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
createXAConnection method with user,password.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1163457 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1163422 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
ObjectMessage and the new CLAOIS
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1160002 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
unable to load required classes during ObjectMessage deserialization process
Applied patch from Charith Dhanushka Wickramarachchi based on the solution to this problem from the Apache ActiveMQ codebase.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1160001 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
mechanisms as 0-10.
Apply work by myself and Keith Wall
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1159255 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Refactor SSLContextFactory to be a factory, and present a useful interface for both client and server side use. Added keystore for the Java broker, renamed existing client trust/key stores for clarity. Fix SSL port configuration. Added new SSL tests, and ensure these are *always* run in the Java 0-10 profiles.
Committing work by myself and Keith Wall.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1159250 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1159198 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
QPID-3381 Changed the code to use QpidMessageProperties.QPID_SUBJECT
instead of the string literal.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1153298 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
message using getStringProperty().
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1153274 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
specific properties, rather than using string literals all over the code.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1153272 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1153164 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
current version
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1149110 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Conflicts:
qpid/java/tools/bin/perf-report
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1148935 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
NetworkTransport used to make/accept connections
Applied patch by Keith Wall <keith.wall@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1146594 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
In order to verify the uniqueness of the client ID, a dummy session is
created using client ID as it's name. This prevents any other connection
from using same client ID as the session creation will fail. However
this verification is switched off by default in order to preserve
backwards compatibility. You need to use -Dqpid.verify_client_id=true
switch verification on.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1144531 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
all protocols, remove vm:// transport support and associated forked Mina classes
Applied patch by Keith Wall and myself
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1143874 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
over to new IO interface model
Applied patch by Keith Wall and myself
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1143867 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
classes
Applied patch by Keith Wall and myself.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1143865 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1141643 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
using "x-amqp-0-10.app-id".
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1140412 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
invocation of asEnumeration().
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1138296 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
passed into when creating the ConnectionMetaData.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1138295 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
an integer.
Added a test case to cover the JIRA. There was an existing test case (testUsingOnMessage) that had delivery mode in it's selector, but for some reason it was commented out.
I decided to add a new one as I was not sure why the delivery mode was taken out of the selector in that test case.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1137804 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
AMQDestinations, truncate exception messages with length over 255 before sending them over the wire in AMQChannelException and AMQConnectionException.
Applied patch by Oleksandr Rudyy <orudyy@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1133037 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
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
|
| |
|
|
|
|
|
|
|
| |
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
|
| |
|
|
|
|
|
|
| |
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
|
| |
|
|
|
|
|
| |
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
|
| |
|
|
|
|
|
| |
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
|