| Commit message (Collapse) | Author | Age | Files | Lines |
| ... | |
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@597918 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
As this will cause the headers to be re-encoded it can be disabled in the config.xml. Default is enabled as the sample config.xml should have all features enabled so that testing can observe the interactions.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@592729 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
process if a msg is queued that has the potential to be delivered.
Delayed the restart until the Filtering subscribers have the message enqueued to their PDQs.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@586489 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
additional synchronisation to ensure that a new subscriber can start the async if required. As currently the start request can be missed.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@585906 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@585642 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
process if a msg is queued that has the potential to be delivered.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@585575 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
message is released. This flag is now used by more than the immediate delivery. It is also used to understand if the message has been delivered so that we can tell the message should not be purged.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@585570 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
that have been taken.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@585565 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
consumer.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@583808 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
RejcectHandler throwing NPE when it too tries to discard the message.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@583415 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@583088 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
causes a leak. Here is a new test provided by Aidan Skinner and a simple fix that will prevent OOME when only selectors are connected to the Queue.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@582263 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
condition when using NO_ACK. This is due to the Queue Total Size being updated after the send, but after the send and NO_ACK the msg data is purged and so there is no size to retrieve. Changed all references to msg.dequeue to queue.dequeue where appropriate so we can use that single point in the future for updating the Queue Total Size.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@580993 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
supplied by Aidan Skinner
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@580265 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
AMQQueueMBeanTest to verify the contents of the MessageStore after clearing.
All the MC features only dequeued the message and didn't correctly decrementReference.
The MessageReturnTest was failing due to the TimeToLive test causing messages to be left on the store. The expired messages were not having the reference decremented.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@579574 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
augmented the python test_get to send persistent messages and used debugger to verify that messages were correctly removed. Verified that prior to this commit they would remain in the store. We need a management exchange to fully validate this with a python tests.
NOTE: The setting of "delivery mode" property on M2.1 is not the same as on trunk where _ is use such as "delivery_mode".
There is also no error that you have sent an incorrect property.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@579229 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
for the tests to use that broker.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@579198 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
TestableMemoryMessageStore to allow it to query the MemoryMessageStore in use by the broker.
New MessageReturnTest to verify no leak after messages have been returned.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@579147 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@578845 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
conditions. This was
particularly affecting systests which use the in-VM broker.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@578058 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@577773 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
the message has been sent. This was previously done inside dequeueMessage() but when the reference counting was reworked earlier in the year it was moved out of that method.. but all the uses of dequeueMessage were not evaluated. The existing AckTest didon't detect this error as it only occurs with persistent messages which the client sends by default. The AckTest however only tests transient messages. Updated Test for NO_ACK raised JIRA QPID-602 to cover updating the rest of the AckTests
(Updated log to show correct JIRA QPID-531 not QPID-573)
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@575811 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
the ordering problem.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@575738 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
ConcurrentSelectorDeliveryManager that resolves the ordering problem.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@574902 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@574585 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@574504 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.0.1@568924 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@562124 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@561794 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
| |
Client pom now builds a single jar with all dependancies included in the single bundle.
systests/pom.xml adjusted to include only *Test.class items. This will fix the current Error on OptOutTestCase
management/eclipse-plugin/pom.xml - editied to include there required MANIFEST.MF to identify plugin to eclipse
distribution/src/main/assembly/management-eclipse-plugin.xml editied to include there required MANIFEST.MF to identify the plugin
distribution/pom.xml - white space
Also updated log4j.xml default to create an alert.log file from the AMQQueue alerting. Added a debug.log4j.xml that gives example of debugging the broker via log4j.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@561278 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
expired() method call.
ConcurrentSelectorDeliveryManager - Update to reflect expired() call change. Created new _reaperContextStore to be used when performing reaper operations such as message dequeue due to expiration. Removed old commented code.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@559427 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
framework under systests from integrationtests.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@559419 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@557306 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@557276 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
held by the AMQShortStrings.
Patch submitted by Robert Godfrey to intern() the AMQSSs to reduce memory usage. Current implementation *will* impact performance due to the usage of a static Map for storage. However, a thread local implementation is in the works.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@556890 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
-m or --mport
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@556888 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@556871 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
the ConcurrentSelectorDeliveryManager that have been delivered via a Subscribers _messageQueue. Ensuring that any expired messages are still correctly handled. i.e. the Queue size/depth is reduced and the message correctly dequeued from the underlying store.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@556869 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@556861 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Updated to remove the AMQExceptions that will be removed from the Exchange class.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@556847 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Use broker logger at error level as well as System.out
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@556845 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@556628 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@554964 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
command.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@553482 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Added Copy command.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@553480 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@553265 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
Small changes to the Exchanges to allow the extraction of currently listed items.
Extracted initial broker configuration mechanism to a reusable class. Have modified broker to use it.
Move the Passwd.java to new tools package structure on the broker.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@553248 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@553172 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@552499 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@551176 13f79535-47bb-0310-9956-ffa450edef68
|