summaryrefslogtreecommitdiff
path: root/java/systests
Commit message (Collapse)AuthorAgeFilesLines
* Merged revisions 575811 via svnmerge from Rupert Smith2007-09-191-0/+19
| | | | | | | | | | | | | 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
* Changes made to performance test parameters.Rupert Smith2007-08-071-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@563435 13f79535-47bb-0310-9956-ffa450edef68
* Extensive refactoring of the distributed test framework.Rupert Smith2007-08-0133-545/+2004
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@561855 13f79535-47bb-0310-9956-ffa450edef68
* Changes to POMs.Martin Ritchie2007-07-311-0/+3
| | | | | | | | | | | | 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
* Refactored packaging of test framework.Rupert Smith2007-07-2522-132/+58
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@559458 13f79535-47bb-0310-9956-ffa450edef68
* Removed redundant method.Rupert Smith2007-07-251-5/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@559456 13f79535-47bb-0310-9956-ffa450edef68
* Added to comments.Rupert Smith2007-07-251-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@559455 13f79535-47bb-0310-9956-ffa450edef68
* Refactored interop tests into general distributed test framework. Moved ↵Rupert Smith2007-07-2528-166/+3456
| | | | | | framework under systests from integrationtests. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@559419 13f79535-47bb-0310-9956-ffa450edef68
* Update fix incorrect license headers.Martin Ritchie2007-07-182-22/+28
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@557306 13f79535-47bb-0310-9956-ffa450edef68
* updated comment to refelect property valuesMartin Ritchie2007-07-181-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@557281 13f79535-47bb-0310-9956-ffa450edef68
* Completed javadoc for test framework.Rupert Smith2007-07-1313-42/+133
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@556024 13f79535-47bb-0310-9956-ffa450edef68
* Moved test framework into its own package and cleaned it up.Rupert Smith2007-07-1319-795/+1723
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@556011 13f79535-47bb-0310-9956-ffa450edef68
* Fixed test state carrying over to mandatory message test from immediate. ↵Rupert Smith2007-07-054-33/+45
| | | | | | Also added in-vm clean up to other tests. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@553432 13f79535-47bb-0310-9956-ffa450edef68
* QPID-509 Mandatory messages not returned outside a transaction. They are now.Rupert Smith2007-06-263-119/+183
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@550849 13f79535-47bb-0310-9956-ffa450edef68
* Immediate and mandatory flag tests added.Rupert Smith2007-06-262-56/+437
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@550773 13f79535-47bb-0310-9956-ffa450edef68
* Added Immediate and Mandatory message tests.Rupert Smith2007-06-223-0/+1103
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@549849 13f79535-47bb-0310-9956-ffa450edef68
* Added minimal checkstyle to project reports. Fixed some problems with site ↵Rupert Smith2007-06-212-0/+7
| | | | | | generation. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@549530 13f79535-47bb-0310-9956-ffa450edef68
* Various License header updates.Martin Ritchie2007-06-184-0/+84
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@548276 13f79535-47bb-0310-9956-ffa450edef68
* Removed log4j dependency from client. Using slf4j instead, end-user to ↵Rupert Smith2007-06-111-0/+9
| | | | | | supply logging implementation as desired. Log4j used for tests. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@546190 13f79535-47bb-0310-9956-ffa450edef68
* QPID-402: FailoverException falling through to client. All blocking ↵Rupert Smith2007-06-012-274/+278
| | | | | | operations now wrapped in failover support wrappers. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@543496 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3 Topic Matching with testsMartin Ritchie2007-05-151-1/+1
| | | | | | | | | 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
* QPID-25 TimeToLive Basic implementation. Martin Ritchie2007-05-092-0/+151
| | | | | | | | | | | | | 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
* Moved MaxChannelsTest.java to the correct package.Martin Ritchie2007-05-091-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@536498 13f79535-47bb-0310-9956-ffa450edef68
* Comments and Test changesMartin Ritchie2007-05-012-8/+12
| | | | | | | | 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
* QPID-290 - Java broker does not honor maximum number of channels thresholdMartin Ritchie2007-04-231-0/+75
| | | | | | Applied patch from Nuno Santos git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@531526 13f79535-47bb-0310-9956-ffa450edef68
* Update to system test so that the run as part of the build process as they ↵Martin Ritchie2007-04-237-15/+41
| | | | | | | | 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
* QPID-436 - topic exchange doesn't obey the mandatory flagMartin Ritchie2007-04-231-3/+137
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@531513 13f79535-47bb-0310-9956-ffa450edef68
* Added addition log when broker is ready to process.Martin Ritchie2007-04-201-3/+3
| | | | | | Updated HeapExhaustion - to use system.out.println so you can set amqj.logging.level=warn to speed up test. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@530838 13f79535-47bb-0310-9956-ffa450edef68
* QPID-459 - NoLocal broken when messages already exist on queue from ↵Martin Ritchie2007-04-191-1/+1
| | | | | | | | | | | | | | consumer. With test. AMQChannel remove comment around setPublisher - this is used by noLocal implementation. Subscription - rename of hasFilters to filtersMessages AMQQueue/RemoteSubscriptionImpl/SubscriptionTestHelper/SubscriptionSet - rename of hasFilters to filtersMessages SubscriptionImpl - rename of hasFilters to filtersMessages and changes to include noLocal in that check. TopicSessionTest - Additional testing for NoLocal to ensure. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@530432 13f79535-47bb-0310-9956-ffa450edef68
* refining the mbean operationsBhupendra Bhusman Bhardwaj2007-04-121-3/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@527959 13f79535-47bb-0310-9956-ffa450edef68
* Added a test to check that Persistent Queues do actually persist.Martin Ritchie2007-04-101-0/+276
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@527053 13f79535-47bb-0310-9956-ffa450edef68
* Stopped throwing away exception causes.Robert Greig2007-04-091-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@526776 13f79535-47bb-0310-9956-ffa450edef68
* git-svn-id: ↵Bhupendra Bhusman Bhardwaj2007-04-091-1/+1
| | | | https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@526694 13f79535-47bb-0310-9956-ffa450edef68
* QPID-416 Update to Access control to allow simply read/write permissions per ↵Martin Ritchie2007-04-061-2/+3
| | | | | | | | | | | | | | | Virtual host. access - updated file to have examples of access control. Changed AMQProtocolSession to record an authorized Principal not just a String. - Required Added AccessRights files needed for VirtualHostAccess control. Updated ConnectionOpenMethodHandler to allow Principals with any access to connect not just read. UsernamePrincipal - Added a toString git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@526117 13f79535-47bb-0310-9956-ffa450edef68
* QPID-308 Updated HeapExhaustion to be able to be run from command lineMartin Ritchie2007-04-051-14/+135
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@525804 13f79535-47bb-0310-9956-ffa450edef68
* QPID-308 Added test case to demonstrate heap exhaustion of broker. Can't be ↵Martin Ritchie2007-04-052-0/+354
| | | | | | run InVM as it kills the broker. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@525766 13f79535-47bb-0310-9956-ffa450edef68
* QPID-70 InVM Authentication QPID-419 Access Control QPID-423 Authentication ↵Martin Ritchie2007-03-163-8/+43
| | | | | | | | | | | | | | per virtualhost Restructured auth package. Enabled InVM Authentication Initial changes to allow authenticators per virtualhost. Initial access control classes. Initial work to allow access control testing through inVM broker. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@518988 13f79535-47bb-0310-9956-ffa450edef68
* Short pause to help ensure connection.close comes after last message ack, ↵Robert Greig2007-03-151-3/+5
| | | | | | added to PropertyValueTest git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@518667 13f79535-47bb-0310-9956-ffa450edef68
* MBean test moved to broker module because it relates very closely to the Broker.Bhupendra Bhusman Bhardwaj2007-03-141-135/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@518086 13f79535-47bb-0310-9956-ffa450edef68
* QPID-411 : ClearQueue functionality of AMQQueue doesn't reset the queue depthBhupendra Bhusman Bhardwaj2007-03-131-228/+0
| | | | | | AMQQueueMBeanTest.java moved to Broker tests git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@517745 13f79535-47bb-0310-9956-ffa450edef68
* QPID-346,QPID-386,QPID-403, QPID-410 Rollback, Basic-Reject, QueueBrowser ↵Martin Ritchie2007-03-132-0/+267
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | NO_ACK. QPID-346 Message loss after rollback\recover QPID-386 Updated Transactional Tests to cover underlying AMQP/Qpid state. QPID-403 Implement Basic.Reject QPID-410 Queue Browsers should use not acknowledge messages. ------------------------------------- Broker TxAck - Added comment and fixed white space UnacknowledgedMessage - Added comment for messageDecrement AMQChannel - Added extra debugging. + Created a NonTransactionalContext for requeuing messages as using txContext will tie the requeue to any runing transaction. + Updated message reference counting. So it is in terms of queues don't increment when giving to client. BasicCancelMethodHandler - Added Debug log. BasicConsumeMethodHandler - Reverted to directly writes frames to the session, throwing ChannelException caused problems. Added Trace and debug logging. BasicRejectMethodHandler, ChannelCloseHandler, ConnectionCloseMethodHandler - Added Debug logging AMQPFastProtocolHandler - moved error log to before session.write AMQMessage - Added additional debug via debugIdentity() and comments AMQQueue - Decoupled reference counting from dequeue operation. ConcurrentSelectorDeliveryManager - Added comments and increased info in debug logging SubscriptionImpl - Disabled use of acks for browsers. For now put setDeliveredToConsumer back in the finally block. commented that I'm not sure this is correct as even an error writing to client will cause msg to be marked delivered to consumer. + On Close ensured that it is only called once. + Had problem where closing browser was causing two CancelOk frames to be sent back to client. RequiredDeliveryException - Added comment to explain incrementReference LocalTransactionalContext - Commented out incrementReference as it shouldn't be required here. NonTransactionalContext - Removed incrementReference on deliver + - Fixed bug where browsers - acks would cause messages to be discarded. new JIRA this needs tidied up. TxnBuffer - Added debug logging. Client ------ AMQQueueBrowser - Added comments AMQSession - Added comments and debug + Updated to cause closed consumer to reject messages rather than receive them. + Prevented NoConsumer's from rollingback and rejecting.. they simply clear their SyncQueue - JIRA to ensure clean state with rollback BasicMessageConsumer - Added trace level debuging on close calls + Forced noConsume-rs to use NO_ACK + added more logging Closeable - Updated to use isClosed rather than directly calling _closed.get() to aid in future work on ensuring multi threaded close still allows pending acks to be processed first. ChannelCloseOkMethodHandler - updated comment AMQProtocolSession - Update comments,whitespace TransportConnection - removed static block FlowControllingBlockingQueue - Added isEmpty() Method PropertyValueTest - Added VM Broker setup + Updated test to run once and 50 times to pull out delivery tag problems that were occuring. + Adjusted logging level to be more helpful. moved some info down to trace and debug. MessageRequeueTest - Moved QpidClientConnection its own file. + Fixed it so it actually runs more than one consumer, concurrently.Now 3 was 1. ConcurrentLinkedMessageQueueAtomicSize - Implemented iterator(). Added QueueBrowserTest to system tests to test QueueBrowsering. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@517638 13f79535-47bb-0310-9956-ffa450edef68
* Fixed the test failures due to changes in the broker codeBhupendra Bhusman Bhardwaj2007-03-093-40/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@516412 13f79535-47bb-0310-9956-ffa450edef68
* 1. Fixed the AMQQueueMBeanTest failures due to changes in ↵Bhupendra Bhusman Bhardwaj2007-03-071-9/+11
| | | | | | | | | | | | | | | | | | | | AMQQueuMBean.getQueueDepth() from queueDepth/1000 to (queueDepth >> 10) 2. Revision: 513748 Author: bhupendrab Date: 13:26:51, 02 March 2007 Message: QPID-390 Added test case for all the AMQQueue alerts ---- Modified : /incubator/qpid/branches/perftesting/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java Added : /incubator/qpid/branches/perftesting/qpid/java/systests/src/test/java/org/apache/qpid/server/queue/AMQQueueAlertTest.java git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@515539 13f79535-47bb-0310-9956-ffa450edef68
* QPID-403 QPID-346 QPID-355 QPID-386 QPID-389 Updates to fix Transactional ↵Martin Ritchie2007-03-061-1/+2
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Rollback. QPID-346 Message loss after rollback\recover QPID-355 Closing a consumer does not ensure messages delivery will stop for that subscription QPID-386 Updated Transactional Tests to cover underlying AMQP/Qpid state. QPID-389 Prefetched message are not correctly returned to the queue QPID-403 Implement Basic.Reject Broker UnacknowledgedMessage - Added toString for debug UnacknowledgedMessageMapImpl - Removed resendMessages method as all sending should go via DeliveryManager and Subscription. AMQChannel - Updated resend and requeue methods so they do not directly write messages to a subscriber. This was violating the suspension state. - Used a local non-transactional context to requeue messages as the internal requeuing of messages on the broker should not be part of any client transaction. - Maked messages as resent. - Removed warnings from IDE about missing JavaDoc text etc. BasicAckMethodHandler - Added debugging BasicRecoverMethodHandler - Removed session from the resend call. BasicRejectMethodHandler - Initial implementation. Hooks left for possible 'resend' bit. ChannelCloseHandler - Fixed bug where channel wasn't marked as fully closed on reception of a close from the client. TxRollbackHandler - Removed session from resend call. AMQMinaProtocolSession - Fixed bug where channel was marked as awaiting closure before it had actually been closed. This causes problems as the close looks up the channel by id again which will return null after it has been marked as awaiting closure. AMQMessage - Initial implementation of Rejection. Currently inactive in hasInterest() as we are miss-using reject to requeue prefetched messages from the client. AMQQueue - Removed debug method as it made reading the log very difficult as all the logs had the same line number ConcurrentSelectorDeliveryManager - Fixed clearAllMessages() as it didn't actually remove the messages. - Fixed bad logic in getNextMessage when using null subscriber. (as done by clearAllMessages) - Added more logging messages. Made more frequent logging a trace value. - Added debugIdentity() method to reduce over head in calculating standard log prefix. - Allowed messages to be added to the front of the queue. - Added currentStatus() to an overview of the queue's current state. SubscriptionImpl - Updated to handle closure correctly (QPID-355) -Updated the deliver method so it doesn't use a try->finally to do msg.setDeliveredToConsumer() as this would be done even in the event of an error. - Created an additional logger to log suspension calls rather than through the SI logger which logs a lot of detail. Client pom.xml - Excluded older version of log4j that commons-collections exposes. AMQSession - Added ability for dispatcher to start in stopped state. - Added dispatcher logger - Added checks around logging - Added message rejection if the dispatcher receives a message that it doesn't have a consumer for. - Updated message rejection to allow the dispatcher to perform the rejection if running this ensures that all queued messages are processed correctly and rejection occurs in order. - rollback() before calling rollback all pending queued messages must be rejected as rollback will clear unacked map which the rejects caused by rollback() will need. - fixed closedProducersAndConsumers so that it will rethrow any JMS Exception - recover() as for rollback() the rejects need to be done before the Recover Call to the broker. - Allowed delclareExchange to be done synchronously programatically - Updated confirmConsumerCancelled to use the dispatcher to perform the clean up. This required the creation of the dispatcher in stopped mode so that it does not start and message attempted to be delivered while the subscriber is being cancelled. BasicMessageConsumer - Updated close not to perform the deregistration. This is done in via BasicCancelOkMethodHandler - Added guards on logging - Record all messages that have been received so they can be rejected if rollback occurs. so had to change impl of acknowledgeLastDelivered. - Updated Rollback to initially reject all received messages that are still unAcked. - Added a recursive call should the queue not be empty at the end of the rollback.. with a warning. BasicCancelOkMethodHandler - White space changes to meet style guide. Added guard on logging. UnprocessedMessage - White space changes to meet style guide. StateWaiter - Added comment about timeout bug. FlowControllingBlockingQueue - Tidied imports RecoverTest - Updated as declareExchange is now Synchronous ChannelCloseTest - added guard on logging MessageRequeueTest - Added to better test underlying AMQP/Qpid state QPID-386 StreamMessageTest - Updated as declareExchange is now Synchronous CommitRollbackTest - added Additional test case to ensure prefetch queue is correctly purged. TransactedTest - Added logging and additional tests. Cluster SimpleClusterTest - updated in line with AMQSession.delcareExchange changes Common AMQConstant - Fixed error code 'not allowed' should be 530 not 507. ConcurrentLinkedMessageQueueAtomicSize - Updated to beable to get the size of messages on the 'head' queue along with additional debug Systests ReturnUnroutableMandatoryMessageTest - Updated as declareExchange is now Synchronous git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@515127 13f79535-47bb-0310-9956-ffa450edef68
* QPID-391 : Broker Refactoring - initial tidy... add some mechanisms for ↵Robert Godfrey2007-02-251-0/+6
| | | | | | multi version git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@511389 13f79535-47bb-0310-9956-ffa450edef68
* QPID-346 Message loss after rollbackMartin Ritchie2007-02-235-15/+40
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | QPID-348 Problems of prefetching messages QPID-355 Closing a consumer does not ensure messages delivery will stop for that subscription BROKER AMQChannel - updated requeue to either resend via the Delivery Manager not directly via msg.writedeliver. BasicRejectMethodHandler - initial place holder. TxRollbackHandler - Added comment AMQMessage - added ability to record who has taken the message so that it can be resent to that subscriber on resend/requeue. AMQQueue - added the queue reference to the Subscription creation ConcurrentSelectorDeliveryManager - Added methods to correctly monitor the size of queue messages. Including messages on the resend queue of a Subscriber. Additional locking to ensure that messages are not sent to the subscriber after Closure. QPID-355 DeliveryManager - adjusted deliver call to allow delivery to the head of the queue. Subscription - changes to allow selction of queue(resend or predelivery) methods to add to resend and getSendLock to ensure that sending to the Subscription is allowed. SubscriptionFactory - changes to allow the AMQQueue to be passed to the Subscription. SubscriptionImpl - implementation of the interfaces. Local storage of messages to be resent and requeuing of the messages during closure. SubscriptionSet - changes to retrieve the actual stored Subscription when performing removeSubscriber. So we have access to the the resend queue. AMQStateManager - Added BasicRejectMethodHandler TransactionalContext - Added option to deliver the messages to the front of the queue. LocalTransactionalContext - cleared the _postComitDeliveryList on rollback. Added option to deliver the messages to the front of the queue. NonTransactionalContext - Added option to deliver the messages to the front of the queue. DeliverMessageOperation.java DELELTED AS NOT USED. CLIENT AMQSession - added ability to get the pervious state of the dispatcher when settting Stopped, fixed the channel suspension problems on broker so uncommented clean up code in rollback and recover. BasicMessageConsumer - updated the rollback so that it sends reject messages to server. AbstractJMSMessage - whitespace + added extra message properties to the toString() AMQProtocolHandler - whitespace + extra debug output TransactedTest - updated expect to prevent NPEs also added extra logging to help understand what is going on. CLUSTER ClusteredQueue - AMQQueue changes for message deliveryFirst. RemoteSubscriptionImpl - Implementation of Subscription SYSTESTS AbstractHeadersExchangeTestBase - AMQQueue changes for message deliveryFirst. AMQQueueMBeanTest - changes for message deliveryFirst. ConcurrencyTest - changes for message deliveryFirst. DeliveryManagerTest - changes for message deliveryFirst. SubscriptionTestHelper - Implementation of Subscription WhiteSpace only UnacknowledgedMessageMapImpl.java git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@510897 13f79535-47bb-0310-9956-ffa450edef68
* QPID-325 : Persist durable exchange information in the storeRobert Godfrey2007-02-209-89/+290
| | | | | | QPID-318 : Remove hardcoding of version numbers (as applies to store) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@509628 13f79535-47bb-0310-9956-ffa450edef68
* QPID-372 Broker doesn't wait for ChannelClose-Ok.Martin Ritchie2007-02-161-0/+10
| | | | | | Updated AMQProtocolSession to have new methods to query and release a channel from the awaiting close-ok state. Once a channel has been signalled to be closed any further methods on that channel are ignored until a close-ok is sent. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@508366 13f79535-47bb-0310-9956-ffa450edef68
* QPID-366 : Reference counting not being decremented correctly and other ↵Robert Godfrey2007-02-154-9/+12
| | | | | | persistence issues git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@508235 13f79535-47bb-0310-9956-ffa450edef68
* Applied patch from Jonathan Anstey <janstey@iona.com> to fix trivial compile ↵Gordon Sim2007-02-061-1/+1
| | | | | | error. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@504025 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status