| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@909641 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Added a log message in IoTransport to denote successfull creation of SSL Sender and Receiver
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@909150 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@906156 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Added the Accessor.java to abstract the access strategies. Added several acess strategies including one which takes a list of Accessors.
Added a constrcutor in the QpidProperty class to take an Accessor. The other constructor defaults to SystemPropertyAccessor
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@906135 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@904934 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@904566 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@904375 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
to implement a property toString
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@904162 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
The SASL encryption layer is not fully functional, however it's dormant unless explicitly enabled using the jvm arg "qpid.sasl_encryption" or the connection parameter "sasl_encryption".
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@903942 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
I added use_legacy_map_msg_format as a connection paramter to force the client to use the old map message format.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@903940 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
python address usage
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@902095 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
| |
QPID-2352
- Modified Connection.java to add more than one ConnectionListener. This was done to facilitate the SASL encryption patch - QPID-2352.
- Changed the access modifier for getSaslClient method to "public" to allow the SaslClient to be retrieved by the SASL encryption code -QPID-2352.
- Introduced ConnectionSettings object to hold all the configuration options. Previous constructor methods remains unchanged.
- Modified the ClientDelegate to handle heartbeat and idelTimeout value properly.
- Added support to specify config options via the connection URL - QPID-2351
- Added support to handle the heartbeat/idle_timeout options properly in the 0-10 code - QPID-2350. However once QPID-2343 is completed, the code will be further simplified.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901506 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901448 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@901268 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@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/qpid@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/qpid@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/qpid@900595 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@898634 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@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/qpid@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/qpid@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/qpid@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/qpid@897323 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@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/qpid@891805 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@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/qpid@888345 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
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
|
| |
|
|
|
|
| |
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
|
| |
|
|
| |
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
|
| |
|
|
|
|
| |
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
|