Jenkins build became unstable: ActiveMQ-Java7 » ActiveMQ :: STOMP Protocol #301
See https://builds.apache.org/job/ActiveMQ-Java7/org.apache.activemq$activemq-stomp/301/
Jenkins build is back to stable : ActiveMQ-Java7 » ActiveMQ :: LevelDB Store #301
See https://builds.apache.org/job/ActiveMQ-Java7/org.apache.activemq$activemq-leveldb-store/301/
Build failed in Jenkins: ActiveMQ-Java7 #301
See https://builds.apache.org/job/ActiveMQ-Java7/301/ -- [...truncated 3507 lines...] [INFO] [INFO] [INFO] [INFO] Skipping ActiveMQ :: Web Console [INFO] This project has been banned from the build due to previous failures. [INFO] [INFO] [INFO] [INFO] Skipping ActiveMQ :: Karaf Integration Tests [INFO] This project has been banned from the build due to previous failures. [INFO] [INFO] [INFO] [INFO] Skipping ActiveMQ :: Integration Test :: Spring 3.1 [INFO] This project has been banned from the build due to previous failures. [INFO] [INFO] [INFO] [INFO] Skipping ActiveMQ :: Assembly [INFO] This project has been banned from the build due to previous failures. [INFO] [INFO] [INFO] Reactor Summary: [INFO] [INFO] ActiveMQ .. SUCCESS [5.866s] [INFO] ActiveMQ :: Openwire Generator SUCCESS [5.064s] [INFO] ActiveMQ :: Client SUCCESS [2:15.704s] [INFO] ActiveMQ :: Openwire Legacy Support ... SUCCESS [4.098s] [INFO] ActiveMQ :: JAAS .. SUCCESS [48.833s] [INFO] ActiveMQ :: Broker SUCCESS [1:24.215s] [INFO] ActiveMQ :: KahaDB Store .. SUCCESS [7:30.203s] [INFO] ActiveMQ :: STOMP Protocol SUCCESS [36:58.959s] [INFO] ActiveMQ :: MQTT Protocol . SUCCESS [9:58.420s] [INFO] ActiveMQ :: JDBC Store SUCCESS [2.668s] [INFO] ActiveMQ :: LevelDB Store . SUCCESS [11:19.832s] [INFO] ActiveMQ :: Generic JMS Pool .. SUCCESS [1:28.117s] [INFO] ActiveMQ :: Pool .. SUCCESS [3.533s] [INFO] ActiveMQ :: RA SUCCESS [2:24.450s] [INFO] ActiveMQ :: Spring SUCCESS [1:37.861s] [INFO] ActiveMQ :: AMQP .. SUCCESS [26:06.657s] [INFO] ActiveMQ :: Console ... SUCCESS [4.487s] [INFO] ActiveMQ :: Partition Management .. SUCCESS [19.967s] [INFO] ActiveMQ :: Unit Tests FAILURE [1:44:23.007s] [INFO] ActiveMQ :: Camel . SKIPPED [INFO] ActiveMQ :: HTTP Protocol Support . SKIPPED [INFO] ActiveMQ :: All JAR bundle SKIPPED [INFO] ActiveMQ :: File Server ... SKIPPED [INFO] ActiveMQ :: Log4j Appender SUCCESS [7.218s] [INFO] ActiveMQ :: Apache Karaf .. SKIPPED [INFO] ActiveMQ :: RAR ... SKIPPED [INFO] ActiveMQ :: Run Jar ... SUCCESS [3.787s] [INFO] ActiveMQ :: Shiro . SKIPPED [INFO] ActiveMQ :: Runtime Configuration . SUCCESS [4:38.179s] [INFO] ActiveMQ :: Tooling ... SUCCESS [1.549s] [INFO] ActiveMQ :: Memory Usage Test Plugin .. SUCCESS [5.587s] [INFO] ActiveMQ :: Performance Test Plugin ... SUCCESS [4.086s] [INFO] ActiveMQ :: StartUp/Stop Plugin ... SKIPPED [INFO] ActiveMQ :: Web ... SKIPPED [INFO] ActiveMQ :: OSGi bundle ... SKIPPED [INFO] ActiveMQ :: Blueprint . SUCCESS [7.448s] [INFO] ActiveMQ :: Web Demo .. SKIPPED [INFO] ActiveMQ :: Web Console ... SKIPPED [INFO] ActiveMQ :: Karaf Integration Tests ... SKIPPED [INFO] ActiveMQ :: Integration Test :: Spring 3.1 SKIPPED [INFO] ActiveMQ :: Assembly .. SKIPPED [INFO] [INFO] BUILD FAILURE [INFO] [INFO] Total
Jenkins build became unstable: ActiveMQ-Java7 » ActiveMQ :: RA #301
See https://builds.apache.org/job/ActiveMQ-Java7/org.apache.activemq$activemq-ra/301/
Build failed in Jenkins: ActiveMQ-Java7 » ActiveMQ :: Unit Tests #301
See https://builds.apache.org/job/ActiveMQ-Java7/org.apache.activemq$activemq-unit-tests/301/ -- [...truncated 516 lines...] Tests run: 50, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.342 sec - in org.apache.activemq.command.ActiveMQMessageTest Running org.apache.activemq.command.ActiveMQObjectMessageTest Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.202 sec - in org.apache.activemq.command.ActiveMQObjectMessageTest Running org.apache.activemq.command.ActiveMQStreamMessageTest Tests run: 18, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.415 sec - in org.apache.activemq.command.ActiveMQStreamMessageTest Running org.apache.activemq.command.ActiveMQTextMessageTest Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.248 sec - in org.apache.activemq.command.ActiveMQTextMessageTest Running org.apache.activemq.command.MessageSendTest Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.287 sec - in org.apache.activemq.command.MessageSendTest Running org.apache.activemq.command.MessageTest Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.336 sec - in org.apache.activemq.command.MessageTest Running org.apache.activemq.config.BrokerPropertiesTest Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.974 sec - in org.apache.activemq.config.BrokerPropertiesTest Running org.apache.activemq.config.BrokerXmlConfigTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.949 sec - in org.apache.activemq.config.BrokerXmlConfigTest Running org.apache.activemq.config.JDBCConfigTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 8.604 sec - in org.apache.activemq.config.JDBCConfigTest Running org.apache.activemq.console.command.AMQ3410Test Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 19.343 sec - in org.apache.activemq.console.command.AMQ3410Test Running org.apache.activemq.console.command.AMQ3411Test Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 11.699 sec - in org.apache.activemq.console.command.AMQ3411Test Running org.apache.activemq.console.command.PurgeCommandTest Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 12.174 sec - in org.apache.activemq.console.command.PurgeCommandTest Running org.apache.activemq.conversions.AmqpAndMqttTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.62 sec - in org.apache.activemq.conversions.AmqpAndMqttTest Running org.apache.activemq.filter.DestinationFilterTest Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.082 sec - in org.apache.activemq.filter.DestinationFilterTest Running org.apache.activemq.filter.DestinationMapMemoryTest Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.102 sec - in org.apache.activemq.filter.DestinationMapMemoryTest Running org.apache.activemq.filter.DestinationMapTempDestinationTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.345 sec - in org.apache.activemq.filter.DestinationMapTempDestinationTest Running org.apache.activemq.filter.DestinationMapTest Tests run: 16, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.105 sec - in org.apache.activemq.filter.DestinationMapTest Running org.apache.activemq.filter.DestinationPathTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.208 sec - in org.apache.activemq.filter.DestinationPathTest Running org.apache.activemq.filter.DummyPolicyTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.63 sec - in org.apache.activemq.filter.DummyPolicyTest Running org.apache.activemq.jmx.JmxCreateNCTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.467 sec - in org.apache.activemq.jmx.JmxCreateNCTest Running org.apache.activemq.jmx.OpenTypeSupportTest Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.437 sec - in org.apache.activemq.jmx.OpenTypeSupportTest Running org.apache.activemq.jndi.ActiveMQInitialContextFactoryTest Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.336 sec - in org.apache.activemq.jndi.ActiveMQInitialContextFactoryTest Running org.apache.activemq.jndi.ActiveMQWASInitialContextFactoryTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.284 sec - in org.apache.activemq.jndi.ActiveMQWASInitialContextFactoryTest Running org.apache.activemq.jndi.CustomConnectionFactoryNameTest Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.284 sec - in org.apache.activemq.jndi.CustomConnectionFactoryNameTest Running org.apache.activemq.jndi.DestinationNameWithSlashTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.257 sec - in org.apache.activemq.jndi.DestinationNameWithSlashTest Running org.apache.activemq.jndi.InitialContextTest Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.304 sec - in org.apache.activemq.jndi.InitialContextTest Running
git commit: Upgrade Spring to 3.2.8
Repository: activemq Updated Branches: refs/heads/trunk 17458134a - 751fc2363 Upgrade Spring to 3.2.8 Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/751fc236 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/751fc236 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/751fc236 Branch: refs/heads/trunk Commit: 751fc2363cf911cfe8a073869c967b8f2adf5868 Parents: 1745813 Author: Claus Ibsen claus.ib...@gmail.com Authored: Wed Mar 26 09:23:32 2014 +0100 Committer: Claus Ibsen claus.ib...@gmail.com Committed: Wed Mar 26 09:23:32 2014 +0100 -- pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/activemq/blob/751fc236/pom.xml -- diff --git a/pom.xml b/pom.xml index a4308e8..fc8f8a9 100755 --- a/pom.xml +++ b/pom.xml @@ -113,7 +113,7 @@ scalatest-version1.8/scalatest-version slf4j-version1.7.5/slf4j-version snappy-version1.1.0.1/snappy-version -spring-version3.2.5.RELEASE/spring-version +spring-version3.2.8.RELEASE/spring-version spring-osgi-version1.2.1/spring-osgi-version stax2-api-version3.0.2/stax2-api-version velocity-version1.7/velocity-version
git commit: Upgraded to Camel 2.13.0
Repository: activemq Updated Branches: refs/heads/trunk 45c0dfb2b - 17458134a Upgraded to Camel 2.13.0 Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/17458134 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/17458134 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/17458134 Branch: refs/heads/trunk Commit: 17458134a453660c54ae0488bfc1d9651595be1c Parents: 45c0dfb Author: Claus Ibsen claus.ib...@gmail.com Authored: Wed Mar 26 09:19:52 2014 +0100 Committer: Claus Ibsen claus.ib...@gmail.com Committed: Wed Mar 26 09:22:53 2014 +0100 -- pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/activemq/blob/17458134/pom.xml -- diff --git a/pom.xml b/pom.xml index 019dcc9..a4308e8 100755 --- a/pom.xml +++ b/pom.xml @@ -46,7 +46,7 @@ aopalliance-version1.0/aopalliance-version aries-version1.0.0/aries-version axion-version1.0-M3-dev/axion-version -camel-version2.12.3/camel-version +camel-version2.13.0/camel-version camel-version-range[2.12,3)/camel-version-range cglib-version2.2/cglib-version commons-beanutils-version1.8.3/commons-beanutils-version
git commit: revisit https://issues.apache.org/jira/browse/AMQ-3519 with more durable solution https://issues.apache.org/jira/browse/AMQ-5068 - JMSRedelivered header now persisted before dispatch so th
Repository: activemq
Updated Branches:
refs/heads/trunk 751fc2363 - 266d23ef7
revisit https://issues.apache.org/jira/browse/AMQ-3519 with more durable
solution https://issues.apache.org/jira/browse/AMQ-5068 - JMSRedelivered header
now persisted before dispatch so that it is a reliable indication of a possible
duplicate delivery. The option is enabled via destination policy
persistJMSRedelivered
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/266d23ef
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/266d23ef
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/266d23ef
Branch: refs/heads/trunk
Commit: 266d23ef794e79bb48f81314295640421772808c
Parents: 751fc23
Author: gtully gary.tu...@gmail.com
Authored: Wed Mar 26 11:14:35 2014 +
Committer: gtully gary.tu...@gmail.com
Committed: Wed Mar 26 11:16:42 2014 +
--
.../activemq/broker/region/BaseDestination.java | 8 +
.../activemq/broker/region/QueueRegion.java | 1 +
.../activemq/broker/region/RegionBroker.java| 11 ++
.../broker/region/policy/PolicyEntry.java | 9 ++
.../activemq/store/AbstractMessageStore.java| 4 +
.../org/apache/activemq/store/MessageStore.java | 1 +
.../activemq/store/ProxyMessageStore.java | 5 +
.../activemq/store/ProxyTopicMessageStore.java | 4 +
.../store/memory/MemoryMessageStore.java| 6 +
.../apache/activemq/store/jdbc/JDBCAdapter.java | 3 +
.../activemq/store/jdbc/JDBCMessageStore.java | 15 +-
.../apache/activemq/store/jdbc/Statements.java | 2 +-
.../store/jdbc/adapter/DefaultJDBCAdapter.java | 18 +++
.../store/kahadb/KahaDBPersistenceAdapter.java | 12 --
.../activemq/store/kahadb/KahaDBStore.java | 68 -
.../activemq/store/kahadb/MessageDatabase.java | 73 +
.../apache/activemq/store/kahadb/Visitor.java | 4 +
.../src/main/proto/journal-data.proto | 8 +
.../apache/activemq/leveldb/LevelDBStore.scala | 7 +-
.../java/org/apache/activemq/TestSupport.java | 16 ++
.../broker/BrokerRestartTestSupport.java| 1 +
.../broker/LevelDBRedeliveryRestartTest.java| 49 --
.../activemq/broker/RedeliveryRestartTest.java | 151 ++-
.../FailoverRedeliveryTransactionTest.java | 23 +--
.../activemq/usecases/MemoryLimitTest.java | 2 +-
25 files changed, 313 insertions(+), 188 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/activemq/blob/266d23ef/activemq-broker/src/main/java/org/apache/activemq/broker/region/BaseDestination.java
--
diff --git
a/activemq-broker/src/main/java/org/apache/activemq/broker/region/BaseDestination.java
b/activemq-broker/src/main/java/org/apache/activemq/broker/region/BaseDestination.java
index 3f925b4..c3841c8 100755
---
a/activemq-broker/src/main/java/org/apache/activemq/broker/region/BaseDestination.java
+++
b/activemq-broker/src/main/java/org/apache/activemq/broker/region/BaseDestination.java
@@ -106,6 +106,7 @@ public abstract class BaseDestination implements
Destination {
* percentage of in-flight messages above which optimize message store is
disabled
*/
private int optimizeMessageStoreInFlightLimit = 10;
+private boolean persistJMSRedelivered;
/**
* @param brokerService
@@ -807,4 +808,11 @@ public abstract class BaseDestination implements
Destination {
}
}
+public void setPersistJMSRedelivered(boolean persistJMSRedelivered) {
+this.persistJMSRedelivered = persistJMSRedelivered;
+}
+
+public boolean isPersistJMSRedelivered() {
+return persistJMSRedelivered;
+}
}
http://git-wip-us.apache.org/repos/asf/activemq/blob/266d23ef/activemq-broker/src/main/java/org/apache/activemq/broker/region/QueueRegion.java
--
diff --git
a/activemq-broker/src/main/java/org/apache/activemq/broker/region/QueueRegion.java
b/activemq-broker/src/main/java/org/apache/activemq/broker/region/QueueRegion.java
index 05aa633..f300a13 100755
---
a/activemq-broker/src/main/java/org/apache/activemq/broker/region/QueueRegion.java
+++
b/activemq-broker/src/main/java/org/apache/activemq/broker/region/QueueRegion.java
@@ -25,6 +25,7 @@ import org.apache.activemq.broker.ConnectionContext;
import org.apache.activemq.broker.region.policy.PolicyEntry;
import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.command.Message;
import org.apache.activemq.command.MessageDispatchNotification;
import org.apache.activemq.thread.TaskRunnerFactory;
import org.apache.activemq.usage.SystemUsage;
[CONF] Apache ActiveMQ ActiveMQ Message Properties
Gary Tully edited the page: ActiveMQ Message Properties ... Property Name type default value description JMSDestination javax.jms.Destination set by the producer Destination used by the producer JMSReplyTo javax.jms.Destination null user defined JMSType String empty user defined JMSDeliveryMode int DeliveryMode.PERSISTENT indicator if messages should be persisted JMSPriority int 4 value from 0-9 JMSMessageID String unique unique identifier for the message JMSTimestamp long time the message was sent time in
svn commit: r903726 - in /websites/production/activemq/content: activemq-message-properties.html cache/main.pageCache per-destination-policies.html
Author: buildbot Date: Wed Mar 26 12:23:00 2014 New Revision: 903726 Log: Production update by buildbot for activemq Modified: websites/production/activemq/content/activemq-message-properties.html websites/production/activemq/content/cache/main.pageCache websites/production/activemq/content/per-destination-policies.html Modified: websites/production/activemq/content/activemq-message-properties.html == --- websites/production/activemq/content/activemq-message-properties.html (original) +++ websites/production/activemq/content/activemq-message-properties.html Wed Mar 26 12:23:00 2014 @@ -72,26 +72,7 @@ tbody tr td valign=top width=100% -div class=wiki-content maincontentpstrongActiveMQ Messages support the following default message properties:/strong/p - -h2 id=ActiveMQMessageProperties-Messageattributesaccessedasproperties:Message attributes accessed as properties:/h2 - - -div class=table-wraptable class=confluenceTabletbodytrth colspan=1 rowspan=1 class=confluenceThpProperty Name /p/thth colspan=1 rowspan=1 class=confluenceThp type /p/thth colspan=1 rowspan=1 class=confluenceThp default value /p/thth colspan=1 rowspan=1 class=confluenceThp description /p/th/trtrtd colspan=1 rowspan=1 class=confluenceTdp JMSDestination /p/tdtd colspan=1 rowspan=1 class=confluenceTdp javax.jms.Destination /p/tdtd colspan=1 rowspan=1 class=confluenceTdp set by the producer /p/tdtd colspan=1 rowspan=1 class=confluenceTdp Destination used by the producer/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdp JMSReplyTo /p/tdtd colspan=1 rowspan=1 class=confluenceTdp javax.jms.Destination /p/tdtd colspan=1 rowspan=1 class=confluenceTdp null /p/tdtd colspan=1 rowspan=1 class=confluenceTdp user de fined /p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdp JMSType /p/tdtd colspan=1 rowspan=1 class=confluenceTdp String /p/tdtd colspan=1 rowspan=1 class=confluenceTdp empty /p/tdtd colspan=1 rowspan=1 class=confluenceTdp user defined /p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdp JMSDeliveryMode /p/tdtd colspan=1 rowspan=1 class=confluenceTdp int /p/tdtd colspan=1 rowspan=1 class=confluenceTdp DeliveryMode.PERSISTENT /p/tdtd colspan=1 rowspan=1 class=confluenceTdp indicator if messages should be persisted/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdp JMSPriority /p/tdtd colspan=1 rowspan=1 class=confluenceTdp int /p/tdtd colspan=1 rowspan=1 class=confluenceTdp 4 /p/tdtd colspan=1 rowspan=1 class=confluenceTdp value from 0-9 /p/td/trtrtd colspan=1 rowspan=1 class=confluenceTd p JMSMessageID /p/tdtd colspan=1 rowspan=1 class=confluenceTdp String /p/tdtd colspan=1 rowspan=1 class=confluenceTdp unique /p/tdtd colspan=1 rowspan=1 class=confluenceTdp unique identifier for the message /p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdp JMSTimestamp /p/tdtd colspan=1 rowspan=1 class=confluenceTdp long /p/tdtd colspan=1 rowspan=1 class=confluenceTdp time the message was sent /p/tdtd colspan=1 rowspan=1 class=confluenceTdp time in milliseconds /p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdp JMSCorrelationID /p/tdtd colspan=1 rowspan=1 class=confluenceTdp String /p/tdtd colspan=1 rowspan=1 class=confluenceTdp null /p/tdtd colspan=1 rowspan=1 class=confluenceTdp user defined /p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdp JMSExpiration /p/tdtd colspan=1 rowspan=1 clas s=confluenceTdp long /p/tdtd colspan=1 rowspan=1 class=confluenceTdp 0 /p/tdtd colspan=1 rowspan=1 class=confluenceTdp time in milliseconds to expire the message - 0 means never expire /p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdp JMSRedelivered /p/tdtd colspan=1 rowspan=1 class=confluenceTdp boolean /p/tdtd colspan=1 rowspan=1 class=confluenceTdp false /p/tdtd colspan=1 rowspan=1 class=confluenceTdp true if the message is being resent to the consumer /p/td/tr/tbody/table/div - - - -h2 id=ActiveMQMessageProperties-JMSDefined:JMS Defined:/h2 - - -div class=table-wraptable class=confluenceTabletbodytrth colspan=1 rowspan=1 class=confluenceThpProperty Name /p/thth colspan=1 rowspan=1 class=confluenceThp type /p/thth colspan=1 rowspan=1 class=confluenceThp default value /p/thth colspan=1 rowspan=1 class=confluenceThp description /p/th/trtrtd colspan=1 rowspan=1 class=confluenceTdp JMSXDeliveryCount /p/tdtd colspan=1 rowspan=1 class=confluenceTdp int /p/tdtd colspan=1 rowspan=1 class=confluenceTdp 0 /p/tdtd colspan=1 rowspan=1 class=confluenceTdp number of attempts to send the message/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdp JMSXGroupID /p/tdtd colspan=1 rowspan=1 class=confluenceTdp String /p/tdtd colspan=1 rowspan=1 class=confluenceTdp null /p/tdtd colspan=1 rowspan=1 class=confluenceTdp identity of the message group /p/td/trtr td colspan=1 rowspan=1 class=confluenceTdp JMSXGroupSeq /p/tdtd colspan=1 rowspan=1 class=confluenceTdp int /p/tdtd colspan=1 rowspan=1
git commit: have kahadb journal transaction commands respect enableJournalDiskSyncs - so consistent with leveldbstore - syncs off breaks the jms durability guarantee across the board - no good reason
Repository: activemq
Updated Branches:
refs/heads/trunk 7a0168a4f - 79ba2a79c
have kahadb journal transaction commands respect enableJournalDiskSyncs - so
consistent with leveldbstore - syncs off breaks the jms durability guarantee
across the board - no good reason to distinguish transactional from non
transaction ops; the server qos can override the client
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/79ba2a79
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/79ba2a79
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/79ba2a79
Branch: refs/heads/trunk
Commit: 79ba2a79c18d80bb251b3110e6db39efd8427b6e
Parents: 7a0168a
Author: gtully gary.tu...@gmail.com
Authored: Wed Mar 26 16:37:23 2014 +
Committer: gtully gary.tu...@gmail.com
Committed: Wed Mar 26 16:37:23 2014 +
--
.../apache/activemq/store/kahadb/KahaDBTransactionStore.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/activemq/blob/79ba2a79/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBTransactionStore.java
--
diff --git
a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBTransactionStore.java
b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBTransactionStore.java
index 1ca1def..12e5f00 100755
---
a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBTransactionStore.java
+++
b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBTransactionStore.java
@@ -283,7 +283,7 @@ public class KahaDBTransactionStore implements
TransactionStore {
}
if (doneSomething) {
KahaTransactionInfo info = getTransactionInfo(txid);
-theStore.store(new
KahaCommitCommand().setTransactionInfo(info), true, null, null);
+theStore.store(new
KahaCommitCommand().setTransactionInfo(info),
theStore.isEnableJournalDiskSyncs(), null, null);
}
}else {
//The Tx will be null for failed over clients - lets run
their post commits
@@ -294,7 +294,7 @@ public class KahaDBTransactionStore implements
TransactionStore {
} else {
KahaTransactionInfo info = getTransactionInfo(txid);
-theStore.store(new
KahaCommitCommand().setTransactionInfo(info), true, preCommit, postCommit);
+theStore.store(new
KahaCommitCommand().setTransactionInfo(info),
theStore.isEnableJournalDiskSyncs(), preCommit, postCommit);
forgetRecoveredAcks(txid, false);
}
}else {
@@ -309,7 +309,7 @@ public class KahaDBTransactionStore implements
TransactionStore {
public void rollback(TransactionId txid) throws IOException {
if (txid.isXATransaction() ||
theStore.isConcurrentStoreAndDispatchTransactions() == false) {
KahaTransactionInfo info = getTransactionInfo(txid);
-theStore.store(new KahaRollbackCommand().setTransactionInfo(info),
false, null, null);
+theStore.store(new KahaRollbackCommand().setTransactionInfo(info),
theStore.isEnableJournalDiskSyncs(), null, null);
forgetRecoveredAcks(txid, true);
} else {
inflightTransactions.remove(txid);
svn commit: r903784 - in /websites/production/activemq/content: cache/main.pageCache kahadb.html
Author: buildbot Date: Wed Mar 26 17:23:15 2014 New Revision: 903784 Log: Production update by buildbot for activemq Modified: websites/production/activemq/content/cache/main.pageCache websites/production/activemq/content/kahadb.html Modified: websites/production/activemq/content/cache/main.pageCache == Binary files - no diff available. Modified: websites/production/activemq/content/kahadb.html == --- websites/production/activemq/content/kahadb.html (original) +++ websites/production/activemq/content/kahadb.html Wed Mar 26 17:23:15 2014 @@ -97,7 +97,7 @@ Available as of ActiveMQ 5.10 /div /div -/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpindexWriteBatchSize/p/tdtd colspan=1 rowspan=1 class=confluenceTdp1000/p/tdtd colspan=1 rowspan=1 class=confluenceTdpnumber of indexes written in a batch/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpindexCacheSize/p/tdtd colspan=1 rowspan=1 class=confluenceTdp1/p/tdtd colspan=1 rowspan=1 class=confluenceTdpnumber of index pages cached in memory/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpenableIndexWriteAsync/p/tdtd colspan=1 rowspan=1 class=confluenceTdpfalse/p/tdtd colspan=1 rowspan=1 class=confluenceTdpif set, will asynchronously write indexes/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpjournalMaxFileLength/p/tdtd colspan=1 rowspan=1 class=confluenceTdp32mb/p/tdtd colspan=1 rowspan=1 class=confluenceTdpa hint to set the maximum size of the message data logs/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpenableJournalDiskSyncs/p/tdtd colspan=1 rowspan=1 class=confluenceTdptrue/p/tdtd colspan=1 rowspan=1 class=confluenceTdpensure every non transactional journal write is followed by a disk sync (JMS durability requirement). Disk syncs are always enforced when using transacted clients, so enableJournalDiskSyncs=false has no effect on transacted clients./p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpcleanupInterval/p/tdtd colspan=1 rowspan=1 class=confluenceTdp3/p/tdtd colspan=1 rowspan=1 class=confluenceTdptime (ms) before checking for a discarding/moving message data logs that are no longer used/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpcheckpointInterval/p/tdtd colspan=1 rowspan=1 class=confluenceTdp5000/p/tdtd colspan=1 rowspan=1 class=confluenceTdpt ime (ms) before checkpointing the journal/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpignoreMissingJournalfiles/p/tdtd colspan=1 rowspan=1 class=confluenceTdpfalse/p/tdtd colspan=1 rowspan=1 class=confluenceTdpIf enabled, will ignore a missing message log file/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpcheckForCorruptJournalFiles/p/tdtd colspan=1 rowspan=1 class=confluenceTdpfalse/p/tdtd colspan=1 rowspan=1 class=confluenceTdpIf enabled, will check for corrupted Journal files on startup and try and recover them/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpchecksumJournalFiles/p/tdtd colspan=1 rowspan=1 class=confluenceTdpspan style=text-decoration: line-through;false/span true subv5.9/sub/p/tdtd colspan=1 rowspan=1 class=confluenceTdpcreate a checksum for a journal file - to enable checking for corrupted journals/p /td/trtrtd colspan=1 rowspan=1 class=confluenceTdparchiveDataLogs/p/tdtd colspan=1 rowspan=1 class=confluenceTdpfalse/p/tdtd colspan=1 rowspan=1 class=confluenceTdpIf enabled, will move a message data log to the archive directory instead of deleting it./p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpdirectoryArchive/p/tdtd colspan=1 rowspan=1 class=confluenceTdpnull/p/tdtd colspan=1 rowspan=1 class=confluenceTdpDefine the directory to move data logs to when they all the messages they contain have been consumed./p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpmaxAsyncJobs/p/tdtd colspan=1 rowspan=1 class=confluenceTdp1/p/tdtd colspan=1 rowspan=1 class=confluenceTdpthe maximum number of asynchronous messages that will be queued awaiting storage (should be the same as the number of concurrent MessageProducers)/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpconcurrentStoreAndDispatchTopics/p/tdtd colspan=1 rowspan=1 class=confluenceTdpfalse/p/tdtd colspan=1 rowspan=1 class=confluenceTdpenable the dispatching of Topic messages to interested clients to happen concurrently with message storage/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpconcurrentStoreAndDispatchQueues/p/tdtd colspan=1 rowspan=1 class=confluenceTdptrue/p/tdtd colspan=1 rowspan=1 class=confluenceTdpenable the dispatching of Queue messages to interested clients to happen concurrently with message storage/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdparchiveCorruptedIndex/p/tdtd colspan=1 rowspan=1 class=confluenceTdpfalse/p/tdtd colspan=1 rowspan=1 class=confluenceTdpIf
