| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qmfv2@892292 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@889271 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@889022 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
|
| |
|
|
|
|
| |
tables for the Destination type when JMS_QPID_DESTTYPE has not been set.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@887994 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@887951 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
| |
JMSDestinationTest to cover more test cases:
- Recieving a msg via Queue,Topic
- Recieving a msg via Queue with a MessageListener
- Recieving a msg on a queue that was sent to a topic, requires JMX interface to perform message move.
Excluded test from 0-8 profile until the problem has been resolved
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@887948 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@886890 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@835135 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@831671 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@830102 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@829106 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
topic publication easier, added MultiMessageDispatcher class to allow parameterised sending of messages to a queue or a topic
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@829102 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@828019 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@826646 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@826639 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
bt the StateManager and will prvent the connection from working. During failover check and see if the Connection had been marked closed if so remove any set exception.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@826638 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@825362 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
configuring retry rather than using the default failover URL that has multiple brokers defined. Whilst this may not stop the test failing it will make the log files simpler.
Updated FailoverHandler to ensure that any pending write is sync'd if possible. Also updated Test to perform a synchronous operation after the ack to ensure it arrives at the broker, QPID-2138 highlights that it doesn't get there due to what appears to be Mina propagating the exception ahead of the data.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@824704 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@824129 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
new createConsumer() method.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@823149 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
not signify that the socket has closed. So the broker had two open connections to send messages on. Change was to ensure that the previous Socket/IOSession has been closed before failover starts. Also added protected to ChannelOpenHandler to guard against out of order frames causing a NPE.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@823087 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Updated AcknowldegeAfterFailoverTest to correctly cover the failure cases. Sending messages on a dirty transaction and Receiveing messagges on a dirty session.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@821824 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@821823 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
and the old one has not been consumed
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@821817 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
0-8/0-9 client
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@820739 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@819592 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
deadlock issue with 0-10 rollback method and onMessage usage. Moved 0-10 rollback strategy to the abstract AMQSession and updated 0-8 to use that approach.
0-8 Still excluded from test runs as the race condition is not that the dispatcher would hold a message and reject after the TxRollback. The problem is the Java Broker sends a message out after the FlowOk message so the Dispatcher then sits on it, see QPID-2116. This exact problem was hidden due to the way the Dispatcher is stopped. This problem has not been addressed. The request to stop the dispatcher can only actually stop the dispatcher whilst it is in the middle of processing a message. The stop needs to interrupt the _queue.take() and hold the dispatcher AFTER the processing of any message that it needs to do: see QPID-2117.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@819590 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
I had missed this bit when I committed last night.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@817867 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Added a check in the getNextBrokerDetails method to return null when the current broker equals the only remaining broker in the list
A test case for this will be added once I finalized the test case for the failover exchange method
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@817487 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
I have also added a simple check for the default message priority in an existing test in JMSPropertiesTest
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@817478 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
I didn't meddle with the existing log4j.properties file present in the common module as it maybe used in the broker.
However a cursory glance at the etc directory revealed that the the broker too has a log4j.xml file.
So perhaps the log4j.properties files in the common module is not really needed.
(The settings given i the log4j.xml under the client module could be overriden by explicitly specifying a log4.xml file using -Dlog.configuration property)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@817457 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
sync on the failoverMutex in AMQSession that was causing the notification of the close to be blocked until a TimeOutException occured.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@812153 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
be set on a per session basis
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@811748 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
fixed the issue with ChannelCloseExceptions by closing the channel and not sending the ChannelClose when the Channel has already been closed by the broker.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@811472 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
the mina exception notification thread and the clients main thread blocking for a frame. Occasionally, the client will start blocking just after the notification and so will Timeout. This update ensures that blocking does not occur if the connection has been marked closing or is closed. The lastException set on the StateManager is thrown instead.
The connection close also needed to take into consideration this fact. The syncWrite on for ChannelClose and ConnectionClose are now only down if we are not in a closing situation. As the 0-10 code path does not use the StateManager the changes were applied to the 0-8 Session. Further testing may be needed to validate that the 0-10 client code path does not also have this race condition.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@811471 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
I added a flag to disable flow control when max prefetch is zero. This will also prevent unnessacery suspend/resume actions (and hence extra threads being spawned) when the non meaningful thresholds (for the above case) are passed.
I also think that adjusting the count and puting the message into the queue should be an atomic operation. This means notifying the listener will also need to be squeezed insde the same sync block. Another point to note is that this is redundent in the 0-10 codepath as we have protocol level flow control. Since a more complete overhaul is needed in this area, for the time being I have only done the bare minimum.
I also added a timeout for all sync receives in the DurableSubscriptionTest. This will prevent the whole test suite from hanging if messages don't arrive as expected.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@807292 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
as client examples.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@805418 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@797705 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
|
| |
|
|
|
|
| |
underneath build/scratch
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@792094 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@788179 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@787231 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
PropertiesFileInitialContextFactory
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@786269 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
I incorporated the review comments and made the following changes.
The current time is generated only if ttl is set or disable Timestamp is set to false.
If ttl is set we set it and also calculate the expiration as current_time + ttl.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@781515 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
selector test where message ids were being set to the string 'ID:null' when message-ids are disabled.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@781507 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
The SelectorTest contains a test case to catch this as the JMS tck does not have one.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@781244 13f79535-47bb-0310-9956-ffa450edef68
|