| Commit message (Collapse) | Author | Age | Files | Lines |
... | |
|
|
|
|
|
|
|
| |
Updated EncodingUtils.java to include a single Character field so we can tell the difference between a char and a string of length 1.
Tests changed accordingly.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486648 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
Applied the same change to the second call to <threadpool>.execute() to be sure that a RejectedExecutionException doesn't appear.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486626 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
The PoolingFilterTest.java would throw an ugly NullPointerException. This was due to there being no next filter. So Created a NoOpFilter that prevents this.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486610 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
RejectedExecutionException.
In fireEvent
added additional checks :_poolReference.getPool() != null && !_poolReference.getPool().isShutdown()
to if (job.activate())
As active jobs were being put on a pool that was shutdown.
Included a test to check that the RejectedExecutionException doesn't occur.
(add ignore for example/target)
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486596 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
Added ability to send NULL Strings. EncodingUtils.java now returns an empty string for a zero lengthed String.
To send a null string use prefix 'n'
MapMessageTest.java - Updated to test emptyString and nullString behave correctly.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486574 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
| |
JMSMapMessage.java - fixed incorrect exceptions and return values. Data now sent as a Bytes message.
MapMessageTest.java - updated to be more through with the testing of the returned message
EncodingUtils.java - added unsignedIntegerLength()
FieldTableFactory.java - removed specific PropertyFieldTable reference
PropertyFieldTable.java - fixed encoding issues that were causing BufferOverflow errors.
PropertyFieldTableTest.java - added test to ensure that the encoding size is correct for ALL types.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486254 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@485788 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@485730 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
* changed the name of the output directory for generated sources
* temporary workaround to restore build avoidance wrt code generation
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@484848 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
use more than one version at the same time with this change in place (until the new generator is integrated, that is...)
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@483645 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
Added checks on the field names
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@483559 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
| |
BasicContentHeaderPropertiesTest.java & PropertyFieldTableTest.java updated to use EncodingUtils.java to calculate expected Sizes.
PropertyFieldTable.java - Updated to use wider range of encoded values, Rather than very wasteful XML encoding.
EncodingUtils.java - updated to centralise the new encodings.
added target to ignore on eclipse-plugin folder
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@483503 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@483404 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
FieldTable is now an interface with a PropertyFieldTable.java implementation.
This PropertyFieldTable has been updated to handle the wire level encoding and decoding of the underlying map. It also allows XML encoding of the data as used by JMSMapMessage.
Currently the AMQP doesn't support all the Java primitives as a result all values are written out as XML using a prefix of 'X'. (See QPID-9 for further details)
Changes where not specified are changes from new FieldTable() to FieldTableFactory.newFieldTable()
AbstractJMSMessage.java - the type prefixing of properties is now not requried as all the functionality has been moved to PropertyFieldTable.java. In addition set/getObjectProperty is now implemented as PFT does this.
basic Tests have been updated to send all property values.
FieldTableKeyEnumeration.java has been removed as it is nolonger required. The PFT handles this internally.
ToDo: The Tests need to be consolidated so that there is a clear view of the code coverage. QPID-158
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482733 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
AMQMinaProtocolSession.java - updated comment
AbstractJMSMessage.java - removed a lot of getHeaders() == null checks. Updated logic accordingly.. Now a request for a property that doesn't exist will be consistent with calls on an empty table rather than just creating a default value.
BasicContentHeaderProperties.java - the culprit for QPID-148 changed new FieldTable() to setHeaders(new FieldTable()) to ensure propertyFlag is set to write headers to the wire.
Added PropertyValueTest.java - that tests all the valid values on the Message.
*NOTE*: A number of the tests are commented out as AMQP and therefore the FieldTable do not support these values. QPID-9
Added SVN ignores for the target directories.
Updated AbstractJMSMessage.java _readableProperties to be set correctly in the constructor.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@482238 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
Plus the implementation was broken.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@480973 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
When the custom headers are empty no field table would be created. This null value would cause problems for various methods in AbstractJMSMessage. Simply create an empty FieldTable to save handling the null value.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@480912 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@479050 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
pom.xml removed skip test item and added junit dependency.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478260 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
in AbstractJMSMessage to a central location, FieldTable should be refactored to AMQHeaderPropertyFieldTable extending PropertyFieldTable limiting insertions to values that can be placed in the headers so that AbstractJMSMessage can then utilise that class.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478242 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@478023 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
TransportConnection.java/AMQQueue.java - change log level on a print statement from warn to info
log4j.properties - updated threashold to be 'all' so we can set the logging level with amqj.logging.level
client/pom.xml - fixed mvn test run output. It wasn't using our log4.properties file.
systests/pom.xml - added log4j.properties configuration
broker/pom.xml - added log4j.properties configuration
common/pom.xml - skipped tests as there are none, and it caused the build to fail
Also adjusted spaceing to be 4 space per tab (and no tabs)
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@477214 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@476431 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@476414 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@475286 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@473568 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
on saxon license.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@473288 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@473282 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@473274 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@473273 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@473272 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@473271 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@472041 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
http://dcl.mathcs.emory.edu/util/backport-util-concurrent/
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@472033 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
Also resolves a race condition where an messages could be sent out of order.
Modification of the Java ConcurrentLinkedQueue to provide a constant time size() method
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@469424 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@467589 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
| |
Enabled buffer compression on delivery queue as a configuration option from the xml.(advanced.compressBufferOnQueue)
Changed DeliveryManager.java to use ConcurrentLinkedQueueNoSize.java this is the standard ConcurrentLinkedQueue but where the size() method returns 0(empty) or 1(has content) as it is an expensive operation.
Previously there was a race condition with the use of the _queueing boolean. Under load the consumer would sometimes stop getting messages. This was due to the messages being enqueued without starting the Worker thread.
There is still an issue (QPID-54) on high receiving load messages rate received by a client drops.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@467313 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@466127 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
Addition to be used from DeliveryManager.java to reduce the size of the ByteBuffer when queuing messages to reduce overall memory footprint.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@466082 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@466045 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
MINA-0.9.5 and upgraded to MINA-1.1.0 snapshot.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@463403 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
install as per QPID-30
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@454736 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
common/*/framing/* - White space changes from tabs to 4 spaces.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@452529 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
| |
line. As without this the level is automatically set to debug but the console only displays info level and above messages. This results is a lot of wasted cycles.
If -Damqj.logging.level is present on the command line then that value will override the default of "info"
Related to QPID-12
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@452430 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@452163 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
Updated Setup to create a VMConnectionFactory
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@449720 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@449636 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@448224 13f79535-47bb-0310-9956-ffa450edef68
|
|
URL: https://etp.108.redhat.com/svn/etp/trunk/blaze
Repository Root: https://etp.108.redhat.com/svn/etp
Repository UUID: 06e15bec-b515-0410-bef0-cc27a458cf48
Revision: 608
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@447994 13f79535-47bb-0310-9956-ffa450edef68
|