| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
| |
Added test to Check changing message listeners
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@502261 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
| |
Patched the problem where the dispatcher would hang. The previous logic was flawed.
Patch worked on by Robert Godfrey and Martin Ritchie.
Added test to ensure that the connection is not automatically started.
(Only added the test last time by mistake. This is the actual fix)
With a test for the DispatcherTest
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@502253 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
Patched the problem where the dispatcher would hang. The previous logic was flawed.
Patch worked on by Robert Godfrey and Martin Ritchie.
Added test to ensure that the connection is not automatically started.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@502248 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
AMQTopic.java - whitespace
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@502172 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
Updated MessageConverter to have a constructor that takes a Message type.
Updated MessageConverterTest to use the new NonQpidMessage to test it out.
JMSHeaderAdapter.java - whitespace changes and comment noting that null return is required.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@501917 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
message does not get through
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@501007 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
causes a failure in RecoverTest owing to messages sticking around.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@500310 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
junit.framework.ComparisonFailure: expected:<B> but was:<C> (or similar) from occurring on either the commit or rollback portion of the test. The error occurs when the test consumer testConsumer1 bind frames arrive at the server before the message bodies with A,B,C and cause queue 1 to start a round-robin distribution for these messages when they finally do arrive.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@500264 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Test classes to reproduce problem with missing correlation id on incoming messages from non-Qpid broker
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@499979 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@499490 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@499446 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
wait for a max of 2 seconds
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@497813 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@496658 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
| |
Added DispatcherCallback and MessageConsumerPair to allow Processed Messages to be returned to the consumer for redelivery whilst pausing the dispatcher.
AMQSession updated to create the callback and populate the queue.
Created two test cases that check the messages are correctly delivered with and without message listeners for 1 and 2 clients.
Minor non-JIRA related.
PropertiesFileInitialContextFactory dropped a warn log to info.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@496641 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Updated AMQConnection and AMQBrokerDetails to check the host:port and add tcp:// if there is no protocol specified.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@495517 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
more of the Python tests
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@494769 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
AMQConnectionException
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@494655 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
AMQShortString rather than converting to String
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@494121 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
new persistent stores
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@493872 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@489804 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@489748 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Mainly removed exception stack traces from expected exceptions.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@488713 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
Added:
SelectorParser.jj - ActiveMQ selector javacc grammar used to generate SelectorParser.java
server/filter - Selector Filtering code from ActiveMQ project adjusted to suite our class and package structure.
server/message - Decorator classes to allow access to the JMSMessage inside the AMQMessage
ConcurrentSelectorDeliveryManager.java - A new DeliveryManager that utilises PreDeliveryQueues to implement selectors
AMQInvalidSelectorException.java - thrown on client and broker when the Selector text is invalid.
Common: log4j.properties to remove error log4j warnings on Common tests.
Modified:
broker/pom.xml - to generate SelectorParser.java
AMQChannel.java - Addition of argument fieldtable for filter setup.
BasicConsumeMethodHandler.java - writing of InvalidSelector channel close exception.
AMQMessage.java - Added decorator to get access to the enclosed JMSMessage
AMQQueue.java - Enhanced 'deliverymanager' property to allow the selection of the ConcurrentSelectorDeliveryManager.
Subscription.java - Enhanced interface to allow a subscription to state an 'interest' in a given message.
SubscriptionFactory.java - Added method to allow passing of filter arguments.
SubscriptionImpl.java - Implemented new Subscription.java methods.
SubscriptionManager.java - Added ability to get a list of current subscribers.
SubscriptionSet.java - augmented nextSubscriber to allow the subscriber to exert the new hasInterest feature.
SynchronizedDeliveryManager.java - fixed Logging class
AMQSession - Added filter extraction from consume call and pass it on to the registration.
ChannelCloseMethodHandler.java - Handle the reception and correct raising of the InvalidSelector Exception
AbstractJMSMessage.java - Expanded imports
BlockingMethodFrameListener.java - added extra info to a debug output line.
SocketTransportConnection.java - made output an info not a warn.
PropertiesFileInitialContextFactory.java - updated to allow the PROVIDER_URL to specify a property file to read in for the initial values.
ClusteredSubscriptionManager.java - Implementation of SubscriptionSet.java
NestedSubscriptionManager.java - Implementation of SubscriptionManager.java
RemoteSubscriptionImpl.java - Implementation Subscription.java
AMQConstant.java - Added '322' "Invalid Selector"
SubscriptionTestHelper.java - Implementation of Subscription.java
Edited specs/amqp-8.0.xml to add field table to consume method.
Thanks to the ActiveMQ project for writing the initial SelectorParser.jj and associated filter Expressions.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@488624 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@488596 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Remove all warnings in common, broker, client, and systests regarding
unused variables, as indicated by Eclipse builds.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@488450 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@488377 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
acknowledges messages that have actually been consumed
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@488159 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
Remove unused imports for common, broker, client, and systests as
reported by Eclipse. Note that this includes imports in the Java XSL template
used to generate the framing code in common.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@488134 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
as per JMS spec
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@487903 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@487849 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
different session.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@487821 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@487804 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@487801 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
JMSMapMessage
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@487779 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
message to it's initial state (_data = null), for which getObject() correctly returns null.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@487778 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
subscription handling.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@487562 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
| |
AbstractJMSMessage.java - updated to use getJMSHeaders
JMSMapMessage.java - JMSPropertyFieldTable.java - Moved functionality of setting and retrieving a JMS property. Now shared by the Headers and MapMessageTest.java
MapMessageTest.java - Updated the exceptions that are caught as all methods should throw a JMSException i.e. MessageFormatException
TextMessageTest.java - Added tests for the Message Properties
common/pom.xml - Added JMS dependency for the JMSPropertyFieldTable.java and associated tests
EncodingUtils.java - changed comments and changed getencodedCharLength return to an int
PropertyFieldTable.java - Cleaned up and now uses enum for prefixs. Created comprehensive test of both PropertyFieldTable classes.
AMQPInvalidClassException.java - created to throw a runtime exception when trying to add a non-primative value. Forcing clients to handle this would break the Map usage of the FieldTable.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@487481 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@487368 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
sophisticated since simple null check is not adequate.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@486731 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
createTextMessage overloaded method.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@486722 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
replyTo destination was invalid when using TemporaryQueues as the getEncodingName was using a simple method for encoding the Destination. This has been updated to use a BindingURL as this is more transportable. getEncodingName removed from all AMQDestination subclasses and now is implemented in AMQDestination as a call to toURL()
Created static Destination.createDestination(BindingURL) to create the correct destination from a BindingURL. PropertiesFileInitialContextFactory.java and AbstractJMSMessage.java updated to use this.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@486647 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
buffer for StreamMessage when clearBody is called
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@486594 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@486574 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
limit is set correctly.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@486255 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@486254 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
publisher methods did not appear to be done.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@486198 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
StreamMessage.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@486118 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
* a couple more directory moves
* remove inclusions and exclusions from surefire config in pom.xml
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@486010 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@486008 13f79535-47bb-0310-9956-ffa450edef68
|