| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
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@482733 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Worked ok.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@482243 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@482238 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Plus the implementation was broken.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@480973 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
Pulled _readable (_readableMessage) boolean up to AbstractJMSMessage.java and created (_readableProperties).
Checks are now carried out to ensure that the message is readable/writable for the operation so that the correct exception can be thrown. As per the spec.
clearBody() method had been implemented in AbstractJMSMessage.java to reset the _readableMessage as a result implementations must now implement clearBodyImpl() which is called before the _readableMessage is reset.
Test updated to check that properties and body are correctly read/write set.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@480119 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@480090 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@480089 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@480088 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Update to handle bad characters after port value.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@480032 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Moved some tests from ConnectionURLTest to BrokerDetailsTest to better reflect the actual class being tested.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@480031 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@479640 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
than once.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@479560 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@478854 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
PropertiesFileInitialContextFactoryTest. Good example (I hope) for users.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@478822 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@478444 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@478413 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
TransactedTest.java - fixed naming of setup to setUp
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@478380 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
* change notifyAll() to notify() in MultipleConnectionTest.java
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@478343 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
but commented them out! So mvn passes all tests
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@478266 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
Creations:
JMSMapMessageFactory.java
JMSMapMessage.java
MapMessageTest.java for both Object functionality and functionality being sent around.
Modifications:
AbstractJMSMessage.java - fixed propertyExists() Method not very elegant but when re-factored to use an AMQHeaderPropertyFieldTable it will be better.
made setObjectProperty throw RuntimeException as to highlight that it implemented.
removed duplicate code in checkPropertyName
JMS[Bytes|Object]Message/Factory.java - swapped parameter headers around to match the order in AbstractJMSMessage.java for consistency.
TestMessageHelper.java/MessageFactoryRegistry.java - added MapMessage type
BytesMessageTest.java - Added tests for read and writeability of message.
FieldTableMessageTest.java - Tidied imports
[Text|Object]MessageTest.java - added tests that will fail as per QPID-122
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@478253 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@477214 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@476701 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@476431 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@476414 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@475286 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@473568 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@473072 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@472173 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@472108 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@472081 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Added a sleep after VM Broker creation to allow broker to startup.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@472073 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@472069 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
AMQConnection create methods to use these adaptor classes as per QPID-66.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@470759 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
AMQSession which should return this interface. As per QPID-58. Added QueueReceiverAdaptor class now used in AMQSession.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@470742 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@470380 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
QPID-4. Other changes to allow test class inheritance for testing of this change.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@470336 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@469436 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
broker
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@469430 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
when closing the ProtocolSession to join on so that we can be sure all data has been written to the broker. A time out of 2 minutes ensures that the client doesn't hang for ever if the broker fails.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@466078 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
Added Simple JNDI SPI Class that uses a PropertiesFile to create a ContextFactory for use with in JNDI.
Added a unit test to test using properties file to get correct objects from JNDI lookup.
Modifed AMQHeadersExchange.java to allow creation from a BindingURL.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@466076 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@465166 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Use of single prefetch should be unaffected. Setting the high and low to be the same.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@464950 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
physical location).
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@463397 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
bytes are available in the message and throw the appropriate exception if not. Unit test updated to check behaviour of readXXX methods.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@463363 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
due to a race condition
where the consumers queue was not bound by the time the publisher sent messages.
This is a result of the use of nowait=true for the declare/bind/consume cycle for a BasicMessageConsumer.
To work around this in tests like these that have two connections, one consuming & one publishing, I
added a declareExchangeSynch() method to AMQSession which allows a thread to block until the session it
invokes that method on has processed all the commands up to that point.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@463309 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@462840 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@462820 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@452529 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
QPID-10
#QPID-10
JIRA QPID-10
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@452334 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
temporary frame listener was never removed. Hence causing longer add times and lots of "live" objects.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@452326 13f79535-47bb-0310-9956-ffa450edef68
|