| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
| |
Changed impl of testGetNextWithAck() to avoid unsafe assumption that pre-fetching will mean sorting will never occur. Remove unnecessary message payloads used by some test (time in ms) as this was not contributing to test.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1233125 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
be set and retrivied via a setter & getter.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1232992 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
0-10 spawned profiles
This problem is caused by the connection mbean being deregistered too late (as the TCP/IP socket)
is closed, thus creating a race between the client using JMX to observe connection state, and the
unregistering of the bean. This patch changes the 0-10 code path to unregister the bean on receipt
of ConnectionClose and before ConnectionCloseOkay is sent to the client.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1232785 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1232612 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1232611 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1232605 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1232058 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
TCP connection went away, fixes leak for forcefully clsoed 0-9-1 connections
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1232032 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Log4J automatically scanning the classpath
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1232031 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1232022 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1231141 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Sorted queue enqueue() should lock on a private rather than the lock of the object to avoid the possibility of
a deadlock with a thread performing subscription operations.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1231095 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Reorder the sequence of test to avoid the possibility that the 3rd message will go to the 'wrong' consumer.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1231094 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
0-8/9/9-1 and 0-10
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1230661 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Move testPrefetchSystemProperty to PrefetchBehaviourTest for better division of responsibilities between tests. Split AMQConnectionTest
into QueueSessionFactoryTest and TopicSessionFactoryTest. Removed AMQSSLConnectionTest as there is nothing transport specific and therefore
added nothing not already tested by SSLTest.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1230477 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
SimpleAMQQueue.QueueEntryListener assuming that all listeners are of the same type
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1230251 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
channel is suspended. This results in several test failures.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1230088 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1230013 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Robbie Gemmel
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1229996 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1229957 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1229943 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
doesn't prefetch the messages until after the first message is replaced.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1229858 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
dispatch queue (via syncDipatchQueue method) and releases both unacked
and prefetched messages, while only the former being marked redelivered.
Also all of these transfers are being marked as completed to ensure
credits don't dry up.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1229857 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1229754 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1229753 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1229619 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1229618 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1229617 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1229612 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1229578 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
things now using the thread pool are write jobs, so there is no need/benefit to request it be write-biased.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1229112 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1229111 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
commit
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1228853 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
when creating a producer
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1228843 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
qpid-config, qpid-route, qpid-tool) and store (durable) routes in the DB
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1228748 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Applied patch from Oleksandr Rudyy<orudyy@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1228583 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
downloaded automatically if not already present
Applied patch from Andrew MacBean <andymacbean@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1228192 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Session#getTransacted() on a closed session
Applied patch from Oleksandr Rudyy<orudyy@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1228109 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
consider _lastSeenEntry when determing if _releasedEntry should be retarded
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1227582 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1227373 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1227163 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Store) has no body
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1227162 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
used in 0-10
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1227142 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1226930 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
the JVM
(Note this commit also contains fixes for CurrentActorTest as it was discovered that this test was throwing uncaught exceptions from created Threads - i.e. not the main test thread)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1226557 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1226382 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
Persistence:
Store message in same transaction as enqueue if possible
Memory:
Remove unnecessary (un)boxing
Reduce unnecessary copying of message data
Cache short strings
Cache queues for a given routing key on an Exchange
(0-9) Use a fixed size buffer for preparing frames to write out
Other:
Reduce calls to System.currentTimeMillis
(0-10) Special case immutable RangeSets, in particular RangeSets of a single range/point
(0-10) Special case delivery properties and message properties in headers
(0-9) send commit-ok as soon as data committed to store
Cache publishing access control queries
(0-9) Optimised long and int typed values for FieldTables
(0-9) Retain FieldTable encoded form
(0-9) Cache queue and topic destinations
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1225178 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1224821 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
return true when testing with externally spawned Brokers.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1224789 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
| |
The following tests/test cases have been identified:
1) QueueBrowserAutoAckTest#testFailover*. These tests were running against Java 0-9-1 profiles and excluded against Java/CPP 0-10. New test cases FailoverBehaviourTest#testTransactedQueueBrowserCloseWhileFailover/testClientAcknowledge test the same code paths.
2) AcknowledgeAfterFailoverOnMessageTest/AcknowledgeAfterFailoverTest. These tests were globally excluded (Excludes file). New tests FBT.testClientAcknowledgedSessionCloseAfterFailover/testTransactedSessionCloseAfterFailover/testAcknowledgeAfterFailoverForAsynchronousConsumer cover these scenarios.
3) MessageDisappearWithIOExceptionTest. Tests were added after a defect arising from Java Broker use of MINA. Test scenario covered by FBT.testRecoverAfterFailoverInAutoAcknowledgeMode.
4) FailoverBeforeConsumingRecoverTest. Test case seemed weak: merely caused a failover then repeated the same tests as its super (RecoverTest). FBT.testRecoverAfterFailover and testRecoverWithConsumedMessagesAfterFailover are superior replacements.
5) QuickAcking. Test exercised same code paths as FBT.testMessageProducingAndRollbackAfterFailover.
CloseAfterConnectionFailureTest duplicates FailoverMethodTest#testNoFailover. The testcase was actually excluded from all profiles.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1224788 13f79535-47bb-0310-9956-ffa450edef68
|