| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901267 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
I have added the basis for using a single config source for resolving property names.
We could now add a set of new properties that follows the naming convention agreed on the list while providing support for old property names.
Next step is to dig the code for all the properties and populate the correct tables in ClientProperties.java
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901002 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
The socket interface takes the so_timeout as an int and also the AMQP heartbeat interval is taken as an int.
This change will help simplify the code that handles heartbeats.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901000 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
The common module also contains code for the client, and therefore contains configuration required for the client to be accessible from within the common module. Therefore the ClientProperties.java is best be placed inside the common module.
The goal is to have a place holder for all configuration properties.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900595 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@898634 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@898570 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
I couldn't find any straight forward way to grab the proper ID from the SASL client.
Therefore I had to use the java GSSAPI classes to create a security context to grab the ID.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@898505 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
The qpid.client_process could also be set to something more descriptive as follows using a jvm argument.
-Dqpid.client_process="My Billing App"
Currently added the prop names as plain strings. They will be moved to a single location as part of wider effort in organizing our configuration.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@897985 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
The fix allows an idle_timeout of zero to be set as the heartbeat interval with a warning message to say heartbeats are disabled.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@897922 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Due to the mistake a get operation could reference an index out of bounds or it could print fewer items than what is required.
This commit corrects that mistake.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@897323 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@892301 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
I have removed the checkReadable() method from the toBodyString()
This will enable the toString() method to be used any time on message.
I have also modified the Functions.str() to take in an additional parameter to denote to the starting position of the buffer.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@891805 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@889271 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
messages.
This update required a change to the FieldTable to clear any _encodedBuffer when setting a new value
Provided test in JMSDestintationTest. This test requires a broker that supports both 0-8/9 and 0-10 as we must first use a 0-10 connection to send a message, which does not set JMS_QPID_DESTTYPE, then receive the message on 0-8/9. This allows us to validate that messages recieved without JMS_QPID_DESTTYPE set will can correctly set the value without a BufferOverflow Exception when simply forwarding the message.
Excluded test from all cpp and InVM runs as test requires a 0-8/9 and 0-10 capable broker. Can reinstate to InVM when multiprotocol testing is capable.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@888345 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@886031 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@884619 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@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@832441 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@829944 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@829675 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@825362 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@824129 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
instead of wrapping as them runtime exceptions
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@805016 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@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@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@793184 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
it should no longer hang
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@790161 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@789887 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
PropertiesFileInitialContextFactory
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@786269 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@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@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@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@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@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@774305 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@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@771470 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@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@764026 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@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@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@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@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@751720 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@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@750946 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
execution exception
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@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@749330 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@748594 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@748119 13f79535-47bb-0310-9956-ffa450edef68
|