| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
|
|
|
|
|
|
|
| |
https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1
........
r575811 | ritchiem | 2007-09-14 23:47:52 +0100 (Fri, 14 Sep 2007) | 1 line
QPID-531 : NO_ACK fix. Added a decrementReference in SubscriptionImpl after 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
........
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.0.0.0_patch@577300 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.0.0.0_patch@576914 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@561794 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
|
| |
|
|
|
|
|
|
|
| |
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@550849 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
generation.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@549530 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
comments.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@549011 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
than empty queue
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@548381 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Update to PrincipalDatabase's to ensure they work correctly with # comments.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@548302 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@548276 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@541247 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@540107 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
linux FC5
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@539470 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
subscribers by creating new ones was causing a problem as the closing channel had been closed before the unsubscribe call.
Java now passes all python tests
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@538912 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
to fail.
Replaced long while control with a method call that is easier to understand and has more comments.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@538882 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
A simple naive approach. Similar to C++ to be included for M2.
More elaborate pre-evaluated version will have to wait.
Once benchmarks have been performed we can evaluate performance advantages if any of that approach.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@538240 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
| |
Messages are not automatically purged rather they are checked as they are selected for delivery. If they have expired they are dequeued.
AMQChannel - Update to call setExpiration on the message so the time can be adjusted if client & broker clocks are out of sync.
AMQMessage - Caches the _expiration time for internal use, adjusted for broker time. This leaves message headers unchanged so receiving client can see actual value requested by producer.
ConcurrentSelectorDeliveryManager - Updated to check for expired messages when getNextMessage is called. Immediate messages are NOT expired.
Subscription - Added method to getChannel that this Subscription is attatched to so we can retrieve the StoreContext for dequeue-ing the message.
TimeToLiveTest - Test of Time to live. Sends 50 msgs. 1 non-timed 48 1 second and 1 non-timed ensure only 2 msgs come back after 2 seconds
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@536506 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@536480 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
ConcurrentSelectorDeliveryManager
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@536008 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@534763 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@534478 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Exception handling of management console updated for SecurityException.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@534473 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
VirtualHost Added comments
HeapExhaustion - Updated to send transient messages.
QpidClientConnection - Allowed specification of type of message to send.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@534117 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
than null. As this causes NPE on MC.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@533078 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
applied to disk before storing in memory
Reversed the effects of the requested change if the changes cannot be persisted to disk
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@533075 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Copied handling from SecureOkMethod handler.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@532728 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@531937 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
jmxremote.jar from sun which is not Apache license friendly.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@531859 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Applied patch from Nuno Santos
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@531526 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@531524 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@531518 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@531517 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
were not running.
Change to AMQMessage to ensure that the TxAckTest passes. Was failing as the reference count was being changed out of the increment/decrementReference methods
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@531515 13f79535-47bb-0310-9956-ffa450edef68
|