| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@760953 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Relax MessageFactory to allow out of order. Updated test
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@760952 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
message references so that the underlying TransactionLog need not worry about that.
Updated MemoryMS to use this even to ensure that the code is exercised.
To ensure that the new BaseTransactionLog was correctly used when used by a TransactionLog. The configure() method now returns an Object(TransactionLog) that is the newly configured TL. Existing tests and code where the original TL reference was used have been changed to use the output of the configure() call.
NOTE: the return type should be changed to TransactionLog but until we have completely split the TransactionLog and RoutingTable implementations then this is not possible.
The implementation also includes a number of items from the Flow To Disk review:
- The old get* Methods have been removed from the TransactionLog interface.
- Rollback should now rollback enqueues. (No test provided)
- StoreContext now has enqueue/dequeue methods that track the messageId/Queue pairing
- The linked list per message has been reduced to a link list per message that is enqueued on multiple queues. Messages that exist on only one queue have no additional overhead.
- Optimisation also included to:
Include message delete in 'dequeue transaction' where the message was only ever enqueued on a single queue.
All other message deletes are peformed as part of an asynchrounous commit.
The asynchrounous commit is setup via the StoreContext, which has had some work done to move it towards becomming a Qpid Transaction Object where all operations are performed against rather than going via the TransactionLog.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@760951 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@760919 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@760477 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Added an ant target called test-interop
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@760312 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@760305 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@759297 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
connection retry but only on the initial connection. Failover will not be attempted after an established connection is lost. Updated FailoverMethodTest to test this behaviour.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@759097 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758820 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758748 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
for a FlowableBaseQueueEntryList to delegate its accounting to a parent QueueEntryList. This results in the PriorityQueueEntryList using the same FtD algorithm as SimpleQELs.
- New Messages on a flowed queue are pushed optimistically pushed to disk, this should potentially be removed and just rely on the purger to flush the correct message which in the Priority case may not be the last message in.
- When space is available messages are loaded in queue order, so in this case Priority order.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758742 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758733 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758730 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
load/unload, Updated FQBS to adhere to the thread safety specified by the interface. QueueEntry was updated to return the AMQMessage from the load() to complete the getMessage() interface. As in a flowed state the message may be purged before a reference can be taken. Added new Test QueueEntryImplThreadingTest that should later be run for longer but aims to show that load always returns the message even when unloads are occuring asynchronously.
Commit from 0.5-release : r758388
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758397 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
causing FtD to fail. Annoyingly the tests work as they used the method with the extra functionality.
Commit from 0.5-release : r758382
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758395 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
the running platform and the result of currentTimeMillis() it can be a close to allowing expiry
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758377 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758017 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
all messages are on broker and aging before we start our sleep cycle. The transacted session won't affect the way messages age.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@757696 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Fixed the verify files to use the correct paths for log4j file, python and c++ examples.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@757641 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
The method connect(host, port, vhost, username, password, false,"PLAIN"); is using the hardcoded value false for the ssl paramter.
This commit modified the code to use ssl as the parameter instead.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@757640 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
the relevant exception message
Merged from branches/0.5-release : r757268
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@757270 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Merged from branches/0.5-release : r757257
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@757258 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
in r748516
Merged from branches/0.5-release : r756506
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756518 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
before copying; added a BBEncoder test; made unrecognized mime types default to BytesMessage; added logging of exception root cause to AMQSession; fixed miscelaneous test failures
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756328 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
I am removing them to avoid any confusion they may cause.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756231 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
The AbstractBytesMessage will now use the toString method from AbstractJMSMessage
Also I have modified the toBodyString method in AbstractBytesMessage to use a function that can handle unprintable charachters and print contents upto a maximum of 100 bytes.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756228 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756072 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756071 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
!!! HACK ALERT !!!
These files have long contained a default path used in one particular vendor's installation. We need to fix this! Today's fix makes the default correct for at least that one vendor, but we need to find a better way to do this.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756032 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@755324 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
KBytes, make size descriptions in other methods consistent
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@755256 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
JMX and Java broker roots
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@755187 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@754958 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@754934 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
of directly in user home directory
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@754807 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
purpose to users
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@754803 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
before we had fully initialised it.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@753253 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
persistent recovery as we do not have a working persistent module.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@753220 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
file from disk then recover from the persistent strore. This approach applies the vhost configuration and then applies the persistent state from the store to those objects rather than recreating them. The new inner classes on VirtualHost are to be removed once we have fully extracted the RoutingTable from the legacy MessageStores as this is the root of the problem. The Store needs to be open to create new durable objects but the current stores must recover their state before new entries are added. So now the persistent state is being loaded on to a broker in a consistent state after it has configured a) its default exchanges and b) loaded the queue config from the config file. Eventually we will only have one location for queue config and all will be right in the world.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@753219 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
can flow to disk transient queues with Apache store
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@752845 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Simplest solution here is to disable the management interface for these tests. The more complex change to ensure the MC is shut down correctly and port freed during test startup will not be a problem for production. It only occurs here as we start a broker then stop and start a new one immediately.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@752810 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@752529 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@752528 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
will increase our memory usage. Instead add a close method on the BackingStore that is called when the queue closes and clean up the backing then. Also moved the QueueHousekeeping thread stop to before we do any queue closing in the VHost. This will ensure that we are not causing any operations that might inadvertadly load a message, and so prevent the backing file from being deleted. This should of course now not occur as all getMessage() calls have been removed.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@751722 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
provided by java.io. Attempting to delete an non-existent file returns false. The caller must handle this correctly. If client provides a null value then the call will throw a NPE which is a valid java response.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@751720 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
message to be read in to memory from disk. In all instances the reason was to perform methods that exist on the the QueueEntry. Added accessor to MessageID on QueueEntry. Outstanding getMessage() calls have been left in to perform NO_LOCAL work. Moving Publisher and PublisherClient identifer to the QEI would remove this need.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@751718 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Priority queues.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@751714 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@751636 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
The fix is a bit of a hack, but I don't see another way to handle it.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@751061 13f79535-47bb-0310-9956-ffa450edef68
|