Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-09 03:25:33 +00:00
Code Issues Packages Projects Releases Wiki Activity
9,605 Commits 22 Branches 100 Tags
Commit Graph

720 Commits

Author SHA1 Message Date
Timothy Bish
c1b58d3373 https://issues.apache.org/jira/browse/AMQ-6239 
Refactor the iterator implementation in the PrioritizedPendingList to
not copy elements and instead use the level iterators.  Add some
additional tests.
 2016-04-12 11:35:03 -04:00
gtully
2a8218a9a8 https://issues.apache.org/jira/browse/AMQ-6151 - retain list for redeliveries and combine for dispatch/iteration such that redeliveries retain per priority order after prefetch 2016-04-06 15:09:36 +01:00
gtully
a3a8c1c525 https://issues.apache.org/jira/browse/AMQ-6215 - support 0 maxBrowsePageSize and maxExpirePageSize such that lazyDispatch ensures highest priority messages is available to a pull consumer 2016-04-05 13:23:06 +01:00
Christopher L. Shannon (cshannon)
b2327db3b7 https://issues.apache.org/jira/browse/AMQ-6133 
Disabling async queue message store when persistJMSRedelivered is turned
on for a destination.  That flag will cause a sync update later on
dispatch which can cause a race condition if the original message add is
processed after the update.  This can cause a duplicate message to be
stored.
 2016-04-01 16:40:45 +00:00
Timothy Bish
48ba714b30 https://issues.apache.org/jira/browse/AMQ-6210 
Clean up and apply filtering for temp destinations to removeConsumer as
well.  

This closes #175
 2016-03-28 14:40:00 -04:00
Timothy Bish
f3ecc293f0 https://issues.apache.org/jira/browse/AMQ-6210 
Don't cache selectors for temp destinations.
 2016-03-28 14:34:20 -04:00
Timothy Bish
c53b99c14d NO-JIRA Fix test such that the broker ports are selected dynamically 
instead of hardcoded.
 2016-03-23 10:23:10 -04:00
Christopher L. Shannon (cshannon)
75990ef14a https://issues.apache.org/jira/browse/AMQ-6222 
Moving clearedMarshalledState execution to the async listener on an
async add to the message store.  This is necessary to make sure this
logic doens't execute until after the message is marshalled for the
store.
 2016-03-22 17:54:13 +00:00
Dejan Bosanac
a4c748883a https://issues.apache.org/jira/browse/AMQ-6211 - synchronize creating of jmx composite types 2016-03-14 17:10:13 +01:00
gtully
ae441cbc7d https://issues.apache.org/jira/browse/AMQ-6208 - fix and test 2016-03-11 12:01:18 +00:00
Christopher L. Shannon (cshannon)
a2781e3966 https://issues.apache.org/jira/browse/AMQ-6204 
Fixing the removal logic on virtual destination remove inside of
Advisory Broker to clean up virtual destination maps properly.  Added a
test to verify.  Also added new debug logging to help track down any
future issues.
 2016-03-09 19:54:08 +00:00
Timothy Bish
8b23e072ee https://issues.apache.org/jira/browse/AMQ-5785 
Avoid holding the intrinsic lock on the cursor when expiring the
messages.
 2016-03-08 13:37:58 -05:00
gtully
078f39f589 https://issues.apache.org/jira/browse/AMQ-6199 - apply CursorMemoryHighWaterMark to topic subscriptions 2016-03-08 16:45:06 +00:00
gtully
67ae2bd8a4 https://issues.apache.org/jira/browse/AMQ-6070 - fix npe in org.apache.activemq.usecases.ExpiredMessagesWithNoConsumerTest#testExpireMessagesForDurableSubscriber 2016-03-07 16:44:33 +00:00
gtully
13ec994939 Revert "https://issues.apache.org/jira/browse/AMQ-4495 - revisit. Reinstate check for space on pagein, so that highWaterMark is respected and full state is not reached, hense pfc is not triggered in error" 
This reverts commit d8cf54b0a9eee4b86db1ffef2cb3dd1171067307.
 2016-03-07 16:26:25 +00:00
Christopher L. Shannon (cshannon)
903dec615c https://issues.apache.org/jira/browse/AMQ-6194 
Fixing an issue that caused statistics for a transactional temporary
queue to be updated twice by mistake.  Moved the statistics update into
tryOrderedCursorAdd so that the update is called immediately only if
not inside a transaction.
 2016-03-07 14:15:35 +00:00
gtully
d8cf54b0a9 https://issues.apache.org/jira/browse/AMQ-4495 - revisit. Reinstate check for space on pagein, so that highWaterMark is respected and full state is not reached, hense pfc is not triggered in error 2016-03-01 11:44:41 +00:00
Brian D. Johnson
552c0f0f7a https://issues.apache.org/jira/browse/AMQ-6188 - reset BaseDestination.lastActiveTime each time a message is delivered to the broker. 2016-02-26 20:46:32 +00:00
Timothy Bish
c2ad0c3251 AMQ-6183 Add isDispatchSync to the subscription view and deprecate the 
meaningless one in the producer view
 2016-02-24 17:25:01 -05:00
Jeff Genender
49974279a7 AMQ-6175 - Web console needs to only obtain lists of MBeans that are not 
suppressed.
 2016-02-18 14:25:30 -07:00
gtully
b0c0441d09 https://issues.apache.org/jira/browse/AMQ-6171 - fix vm transport replacement of : from brokerName in error, fix networkConnector retry logic in the event of localTransport creation failure 2016-02-15 14:14:19 +00:00
gtully
499e39e52c https://issues.apache.org/jira/browse/AMQ-6164 - allow journal write batching on a single destination 2016-02-09 12:50:27 +00:00
Timothy Bish
386210fafe https://issues.apache.org/jira/browse/AMQ-6159 
Ensure proper repeat counts are scheduled.
 2016-02-04 17:16:58 -05:00
Christopher L. Shannon (cshannon)
33dded13df https://issues.apache.org/jira/browse/AMQ-6036 
Slight refactoring to make the WildcardFinder class use a static method
so that we don't have to allocate throw away objects that will
immediately be garbage collected.
 2016-02-04 16:53:02 +00:00
Patrik Dudits
278d29dadc https://issues.apache.org/jira/browse/AMQ-6036 
Parsing message selector for wildcard matches for ignoreWildcardSelectors feature
 2016-02-04 16:51:51 +01:00
gtully
c17b7fdc7f add trace level log to shared file locker keepAlive 2016-02-04 13:28:59 +00:00
Marc Breslow
4a937def7d Fix Impossible Cast issues in MemoryTopicSub: 
- recoverSubscription()
-- map is defined as LinkedHashMap<MessageId, Message>
-- msg is defined as <map> entry.getValue() so must be a Message
-- condition if (msg.getClass() == MessageId.class) could never be true
-- no need to cast at all when using generics

- recoverNextMessages()
-- basically same code copy/pasted so same fix

Removed 2 conditions from ServerSessionPoolImpl that would result in impossible casts. Conditions removed were trying to cast ActiveMQQueueSession and ActiveMQTopicSession to ActiveMQSession which is illegal.

Since it isn't obvious what to do if you get an ActiveMQQueueSession or ActiveMQTopicSession from getServerSession() I make it fall back to the else condition which raises an async exception. This is better than getting a ClassCastException at runtime.

Remove impossible cast in MemoryMessageStore
 2016-02-01 12:57:50 +00:00
gtully
5af5b59d3b https://issues.apache.org/jira/browse/AMQ-6151 - respect prioritizeMessages for pending and redelivered messages 2016-02-01 12:19:49 +00:00
Daniel Kulp
a772b0ef72 Remove a printStackTrace for an exception that is also logged. Produces noise on console 2016-01-27 10:06:36 -05:00
Timothy Bish
4ecff14030 NO-JIRA Update master version to 5.14.0-SNAPSHOT to match the eventual 
release version.
 2016-01-20 12:40:20 -05:00
Christopher L. Shannon (cshannon)
7b7e362465 https://issues.apache.org/jira/browse/AMQ-6129 
fixing typo
 2016-01-15 15:09:37 +00:00
Christopher L. Shannon (cshannon)
10c998b0bc https://issues.apache.org/jira/browse/AMQ-6129 
Adding NetworkBridgeStatistics and also a received count for bridges
when they are in duplex mode.
 2016-01-15 14:54:04 +00:00
gtully
2b84cd60ba https://issues.apache.org/jira/browse/AMQ-6128 - fix and test - fix values on priority ordered pending - messages assigned to browsers need to be ordered 2016-01-15 14:31:09 +00:00
Timothy Bish
505a76a8bb https://issues.apache.org/jira/browse/AMQ-6059 
Ensure that a message sent to the store for the DLQ is rewritten so that
its updated values are written to prevent exirpation loops and loss of
reollback cause etc.
 2016-01-12 11:51:48 -05:00
Timothy Bish
66cfc7bab3 AMQ-6121 
AMQ-6122

Prevent messages on DLQ for looping back onto the same DLQ.  Prevents
expired messages from bouncing back and duplicate messages from the
store from causing a deadlock.
 2016-01-11 10:57:38 -05:00
Altaflux
3bb7e4a5c8 Network of brokers on duplex mode reports InstanceAlreadyExistsException on already existing destinations 
https://issues.apache.org/jira/browse/AMQ-6052
closes #164
 2016-01-11 12:59:33 +00:00
Altaflux
6b1e87410d Network of brokers on duplex mode reports InstanceAlreadyExistsException on already existing destinations 2016-01-11 12:59:33 +00:00
Dejan Bosanac
5f8a3df5a4 https://issues.apache.org/jira/browse/AMQ-6116 - improve security context 2016-01-08 17:05:58 +01:00
gtully
e3df09b9db https://issues.apache.org/jira/browse/AMQ-6094 - regression via https://issues.apache.org/jira/browse/AMQ-6014 - incorrect ref count on message expiry event during cursor move for dispatch. Fix and test - thanks for the test 2016-01-05 14:09:16 +00:00
Timothy Bish
8906a53ae5 https://issues.apache.org/jira/browse/AMQ-6105 
Remove deprecated methods from JMX tree
 2015-12-22 13:33:36 -05:00
Timothy Bish
564d55023e https://issues.apache.org/jira/browse/AMQ-6102 
Call to the statistics instance of the subscription to reset the
counters.
 2015-12-21 17:03:24 -05:00
Dejan Bosanac
4e63ee7cc7 https://issues.apache.org/jira/browse/AMQ-6100 - Virtual topic message destination should be the target queue 2015-12-21 15:19:22 +01:00
Timothy Bish
46654b2dee https://issues.apache.org/jira/browse/AMQ-6093 
Remove deprecated URL accessors from BrokerViewMBean
 2015-12-17 13:55:08 -05:00
Christopher L. Shannon (cshannon)
a253ad3c71 https://issues.apache.org/jira/browse/AMQ-6091 
The JavaRuntimeConfigurationBroker can now apply a subset of policy
properties retrospectively to existing destinations versus applying
all properties of the policy update.
 2015-12-17 14:35:50 +00:00
gtully
455a628305 https://issues.apache.org/jira/browse/AMQ-6086 - avoid logging npe on attempted start of persistence adapter post stop 2015-12-14 16:32:10 +00:00
gtully
35df815fb8 https://issues.apache.org/jira/browse/AMQ-6086 - start exception can prevent stop from exiting fully, need to be more selective in creation on stop. 2015-12-14 15:40:05 +00:00
gtully
da076f4a63 https://issues.apache.org/jira/browse/AMQ-6086 - add some determinism to interleaved stop and start calls on broker service 2015-12-11 16:22:31 +00:00
gtully
93092f7ea0 https://issues.apache.org/jira/browse/AMQ-6070 - rework regression - KahaDBStoreRecoveryExpiryTest had NPE in the logs, region dest not set on recovery listener for expiry case 2015-12-11 15:27:28 +00:00
gtully
768fa17085 https://issues.apache.org/jira/browse/AMQ-6005 - have plist whack it existing state on start. Start the temp store after the primary persistence adapter which does the locking 2015-12-10 14:24:03 +00:00
gtully
d7febddb67 https://issues.apache.org/jira/browse/AMQ-6084 - add broker.adjustUsageLimits to disable the adjustment of limits to what is available. In this way, a broker will fail to start if constrained, ensuring it won't accept connections and block pending resources if it has earlier exited for that reason 2015-12-10 11:23:56 +00:00