| Commit message (Collapse) | Author | Age | Files | Lines |
... | |
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@886031 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@884619 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@834259 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
Rob had already added the null check.
I added a ProtocolViolationException, that will be thrown if we receive any frames for an already detached session.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@832441 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@829944 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@829675 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@825362 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@824129 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@820314 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@815206 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
property -DPNAME="".
Ensured value is quoted to allow spaces in QPID_PNAME. i.e QPID_PNAME="Production Broker"
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@814544 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
instead of wrapping as them runtime exceptions
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@805016 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
stages of Open can be correctly logged.
Client ID is not initially provided so we would be unable to log the protocol negotiation without removing this
Modified ProtocolVersion Template to include a toString value to make it easier to log.
There are two templates to update one in gentools/templ.java and one in common/templates
Exposed verification methods to allow systests to reuse the code
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@800363 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@797705 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
Provided static CurrentActor for accessing ThreadLocal.
Included Test to validate setting of ThreadLocals.
Added Test for AMQPActor
Added getRootMessageLogger() to IApplicationRegistry
Adjusted *ProtocolSessions to start counting at 0.
Allowed Setting of Vhost on the MockProtocolSession
Created a fixed Principle in MockProtocolSession
Changes to MockProtocolSession, prevent NPEs when the AMQPActor creates its log string.
Converted CurrentActor to use a Stack allowing a variety of actors to take their turn on a thread.
Improved package structure
Added testing for Actors
Moved FileMonitorTools functionality to FileUtils and provided a Test
Converted Log4jMessageLoggerTest to a proper UnitTest
Moved Test cases to test package
Updated other broker tests to set the authenticated user before setting the virtualhost,
Whilst the logging could output null as the username it would be better if the tests correctly set the authorizedID.
Update to include tests for disabled logging
Fully tested LogSubjects
Updated MockAMQQueue to be able to take a Virtualhost as per a normal Queue.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@796650 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
bundle task only to run
for required modules
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@793184 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
underneath build/scratch
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@792094 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
it should no longer hang
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@790161 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@789887 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
PropertiesFileInitialContextFactory
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@786269 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@782633 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
The BindingURLParser is updated to grab the clientID and subscription to form the queue name.
I also added a test case to cover this.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@779651 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
The sender.close is now surrounded with a try catch to handle the exception thrown by the IoSender.close().
The ideal situation would have been to pass false to the IoSender.close(boolean reportException) method which will then not throw the exception up the stack.
But that method is not exposed in the Sender interface.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@774817 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
finnaly block we can remove the socket.close after the while loop inside the run method.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@774812 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
We now create a new session id, instead of reusing the same when it tries to attach the session after failover.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@774452 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
I have added a sender.close() inside the closed() method in the Connection.java
This ensures the sender is closed and the IoSender thread is shutdown gracefully.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@774305 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@774297 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
I added a timeout (that could be configured via qpid.ssl_timeout if needed) to notify the application,
1) if the broker fails to respond in a timely manner
2) if there was an error and the broker has already closed the connection.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@771470 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@764076 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
replacing previously incorrect literal value used in conditional statement and thus preventing the reversal of delivery mode status. Also update other broker classes making similar comparisons using a literal value to use a constant
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@764026 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758017 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
The method connect(host, port, vhost, username, password, false,"PLAIN"); is using the hardcoded value false for the ssl paramter.
This commit modified the code to use ssl as the parameter instead.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@757640 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
before copying; added a BBEncoder test; made unrecognized mime types default to BytesMessage; added logging of exception root cause to AMQSession; fixed miscelaneous test failures
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756328 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
I am removing them to avoid any confusion they may cause.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756231 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
provided by java.io. Attempting to delete an non-existent file returns false. The caller must handle this correctly. If client provides a null value then the call will throw a NPE which is a valid java response.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@751720 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@751636 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
null, it would previously have thrown a NPE which was erroneously caught this and declared the delete to have failed. If there is nothing to delete (signified by the Null File object) then the delete should pass.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@750946 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
execution exception
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749740 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
externally deleted. Also noted success return value was never propogated correctly, Updated : Test needed.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749330 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748594 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748119 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
before returning null. Also modified AMQQueueBrowser to use receiveNoWait() when browsing queues using 0-10. These changes uncovered numerous second order bugs, mostly in failover. These are also fixed. This fixes QPID-1642 and QPID-1643.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747963 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
1000 ms by default, this is configurable by qpid.session.max_ack_delay
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@745892 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
replay buffer, and made the buffer length configurable
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@743455 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Conflicts:
qpid/java/common/src/main/java/org/apache/qpid/util/NetMatcher.java
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@743304 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@743029 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
some point.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@743015 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
several annoynmous classes that did all the same work.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@742496 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
for QPID-1649
Missed the modifications to ServerDelegate during the cleanup done in rev 742269
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@742278 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@742269 13f79535-47bb-0310-9956-ffa450edef68
|