| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@677263 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@677262 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
likely hood of a slow machine failing the test.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@677260 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
mechanism for failover testing, as the local CruiseControl had testP2PFailoveWithMessagesLeft fail with extra messages being left on broker.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@677259 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Broker
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@677258 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@677257 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@677256 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
should JIT out if disabled. To enable set -Damqj.protocol.logging.level=info
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@676982 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
so that exceptions are not lost. In performing the changes I noted that the AMQStateManager is only used for connection creation in the 08/09 codepath. Now this may be due to the fact that we don't currently need to wait on any other states. We need to improve our testing of error conditions for all protcol versions.
Changes Summary:
The MethodHandlers had their AMQStateManager parameters swapped for AMQSession as that is what they all cared about.
The BlockingMethodFrameListener was used as a basis to create a generic BlockingWaiter which is now used by StateWaiter,
There is probably scope to refactor the AMQStateManager and the parts of the AMQProtocolHandler that deal with the _frameListeners into a generic class but that can be looked at as part of a wider client refactor.
Additionally tests were updated such as SimpleACLTest and ConnectionTest as they were expecting JMSExceptions from the constructor but the JMS API does not demand that and AMQExceptions are now correctly being thrown.
The SimpleACLTest also required a change to AMQSession.
The test calls send which will cause the connection to be closed asynchrously due to a permission violation. As this exception is not expected and is asynchorous to the client code it cannot be directly thrown. The solution is to record this exception in the AMQStateManager, it can tell that there are no waiters for the exception so it can record the value.(Potential exists to alert if the exception is overwritten but I don't think this is required right now)
When the AMQSession checks that the connection is closed it is then possible to check if the current State is CLOSED and if we have an exception sitting in the AMQStateManager. If all these are true we can attach the AMQStateManager exception to the IllegalState Exception that is normally thrown when the Session is closed.
This maintains JMS Compliance and allows us to discover the cause of the failure, SimpleACLTest was updated by removing the IllegalState catch section that was causing the test to silently fail.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@676978 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
setup and tear down of Connections.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@676973 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
QpidTestCase. Removed VMTestCase and all references to it, it was only used in JUnit4 testSuite wrappers. Rather than move QpidTestCase to a new module all client tests have that require this class have been moved to systests.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@676971 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
QpidTestCase. Removed VMTestCase and all references to it, it was only used in JUnit4 testSuite wrappers. Rather than move QpidTestCase to a new module all client tests have that require this class have been moved to systests.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@676969 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@676951 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
I have fixed the error handling and revised the while loop in IoSender based on the comments received during the code review
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@676938 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
possible between processQueue and flushSubscription
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@676887 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@676886 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@676885 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
java.target values. Added echo statements to show the targeted build Updated other info echo statements to be an info level so they will not print with -q.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@676884 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Full protocol validation of the virtualhost name has not been performed.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@676883 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Added RunAll.sh for good measure
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@676878 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@676831 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@675433 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
ConnectionEvent, this removes the overhead of creating ConnectionEvents
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@675397 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
- added batched writes of commands/controls issued on a session
- copy fragmented frames and segments rather than trying to decode
them piecemeal, removed FragmentDecoder
- added caching for str8 encode/decode
- compute sizes as we encode by going back and filling in the amount
of bytes written rather than computing it up front
- added SYNC option to commands
- renamed NO_OPTION argument to NONE
- added a timeout to Client.java
- removed use of UUID.fromString in BasicMessageProducer_0_10.java
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@675165 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Added the ability to pass in JVM ARGs.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@674976 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
message listener has been set to be delivered.
BasicMessageConsumer.java: If there are messages on the synchronous queue when a message listener is set, deliver them to it since they can no longer be consumed().
MessageListenerTest.java: Uncomment code that will make the test fail and demonstrate the bug
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@674747 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Added a README file to describe what the tests are and how they can be run.
Modified to consumers to print the iteration number instead of the message id.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@674622 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
Modified the soak tests to print latency samples and throughput rates for every iteration.
Added run_soak_client.sh soak_report.sh as an example of how to use soak test and produce a report.
Modified other scripts to add comments.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@674569 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
implement that behaiour
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@674541 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@674513 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
AmqPlainSaslServer.java: Actually check password
PlainSaslServer.java: Actually check password
SaslServerTestCase.java: base test case for testing our SASL impls
AMQPlainSaslServerTest.java: test the AMQPlainSaslServer dealie
PlainSaslServerTest.java: test the PlainSaslServer
TestPrincipalDatabase.java: Mockish TestPrincipalDatabase
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@674510 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Added the absolute path to setevn.sh, so that the following scripts can be called from any location.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@674392 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
Made minor modifications to the scripts and added a log4j file for the tests.
The scripts are now modified to use the JAVA_HOME.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@674391 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
isEmpty in the String class.
This fails the build in Java 1.5. I modified it to use str.length == 0 which has the same effect.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@674389 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
The first too JNDICheck allows the contents of a JNDI properties file to be parsed and presented as JNDI will process it.
Handly for validating the parsing of a ConnectionURL
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@674102 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@674097 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
| |
connections.
Altered the ApplicationRegistry so that when the shutdown hook is fired it:
Unbinds from the listening sockets
Then closes each virtualhost which in turn closes all the active TCP connections before closing the MessageStore thus preventing any logged errors occuring as a result of the active TCP connection performing an action on the closed store.
Test provided MessageStoreShutdownTest which uses the new InternalBrokerBaseCase and InternalTestProtocolSession classes to perform system testing of the Broker without TCP framing or client codebase.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@674085 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
so while these race conditions are addressed I've converted the ConnectionTest to QpidTestCase and use it to skip the PasswordFailureConnection.
junit.framework.AssertionFailedError: No cause set
at org.apache.qpid.test.unit.client.connection.ConnectionTest.testPasswordFailureConnection(ConnectionTest.java:145)
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@674058 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
FlowControlTest for using QpidTestCase
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@674055 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@674015 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
handling problems causing the failure
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@673947 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
AMQConnection.java: Refactor listener and stack exceptions in a list. Add get lastException, which can now be any Exception. Don't set connected, let the delegate decide.
AMQConnectionDelegate_8_0.java, AMQConnectionDelete_0_10.java: set _connected to true if we suceed
AMQProtocolHandler.java: attainState can now throw any sort of Exception
AMQStateManager.java: attainState can now throw any Exception
ConnectionTest.java: check that exception cause is not null
AMQConnectionFailureException.java: Add ability to store a Collection of Exceptions in case there are multiple possible causes of the failure. Which there shouldn't be, but it can happen.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@673688 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
from rhs"
This reverts commit 673343.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@673401 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@673351 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@673350 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
still needs love to do with railover, see QPID-959
AMQConnection.java: use 8_0 delegate for in-vm tests
AMQConnectionDelegate_0_9.java: add subclass for class.forname'ing
rename AMQConnectionDelegate_0_8.java to AMQConnectionDelegate_8_0.java to match protocol version properly
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@673347 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
| |
AMQConnection: Refactor listener and remove list, we're only interested in the most recent one anyway. Add get/set for lastException, which can now be any Exception
AMQConnectionDelegate_0_8.java: Stop masking/stackign exceptions, just throw them.
AMQProtocolHandler.java: attainState can now throw any sort of Exception
AMQStateManager.java: attainState can now throw any Exception
ConnectionTest.java: check that exception cause is not null
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@673343 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Apply patch from suran at wso2 dot com
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@673082 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@673074 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@673058 13f79535-47bb-0310-9956-ffa450edef68
|