Jenkins build is still unstable: ActiveMQ-Java7 » ActiveMQ :: RA #725
See https://builds.apache.org/job/ActiveMQ-Java7/org.apache.activemq$activemq-ra/725/
Jenkins build is still unstable: ActiveMQ-Java7 #725
See https://builds.apache.org/job/ActiveMQ-Java7/changes
Jenkins build became unstable: ActiveMQ-Java7 » ActiveMQ :: LevelDB Store #725
See https://builds.apache.org/job/ActiveMQ-Java7/org.apache.activemq$activemq-leveldb-store/725/
Jenkins build is still unstable: ActiveMQ-Java7 » ActiveMQ :: Unit Tests #725
See https://builds.apache.org/job/ActiveMQ-Java7/org.apache.activemq$activemq-unit-tests/changes
[CONF] Apache ActiveMQ Connection Configuration URI
Christopher L. Shannon edited the page: Connection Configuration URI ... You set the property called jms.$PROPERTY on a regular connection URI. For example you can set the brokerURL on your ActiveMQConnectionFactory to the following value to enable Async Sends Code Block tcp://localhost:61616?jms.useAsyncSend=true ... Option Name Default Value Description alwaysSessionAsync true If this flag is set then a separate thread is used for dispatching messages for each Session in the Connection. However, a separate thread is always used if there is more than one session, or the session isn't in auto acknowledge or dups ok mode clientID null Sets the JMS clientID to use for the connection closeTimeout 15000ms Sets the timeout before a close is considered complete. Normally a close() on a connection waits for confirmation from the broker; this allows that operation to timeout to save the client hanging if there is no broker. copyMessageOnSend true Should a JMS message be copied to a new JMS Message object as part of the send() method in JMS. This is enabled by default to be compliant with the JMS specification. You can disable it if you do not mutate JMS messages after they are sent for a performance boost.
Build failed in Jenkins: ActiveMQ-Java7-All-UnitTests #142
See https://builds.apache.org/job/ActiveMQ-Java7-All-UnitTests/142/ -- [...truncated 3572 lines...] [INFO] ActiveMQ :: JAAS .. SUCCESS [33.322s] [INFO] ActiveMQ :: Broker SUCCESS [1:21.099s] [INFO] ActiveMQ :: KahaDB Store .. SUCCESS [2:05.443s] [INFO] ActiveMQ :: STOMP Protocol SUCCESS [8:36.280s] [INFO] ActiveMQ :: MQTT Protocol . SUCCESS [12:25.672s] [INFO] ActiveMQ :: JDBC Store SUCCESS [1.380s] [INFO] ActiveMQ :: LevelDB Store . SUCCESS [5:21.725s] [INFO] ActiveMQ :: Generic JMS Pool .. SUCCESS [39.753s] [INFO] ActiveMQ :: Pool .. SUCCESS [2.778s] [INFO] ActiveMQ :: RA SUCCESS [2:38.487s] [INFO] ActiveMQ :: Spring SUCCESS [1:16.312s] [INFO] ActiveMQ :: AMQP .. SUCCESS [7:37.032s] [INFO] ActiveMQ :: Console ... SUCCESS [2.127s] [INFO] ActiveMQ :: Partition Management .. SUCCESS [18.068s] [INFO] ActiveMQ :: Unit Tests FAILURE [3:42:06.461s] [INFO] [INFO] BUILD FAILURE [INFO] [INFO] Total time: 4:27:39.468s [INFO] Finished at: Fri Jun 12 12:54:51 UTC 2015 [INFO] Final Memory: 110M/1023M [INFO] Waiting for Jenkins to finish collecting data [ERROR] Failed to execute goal org.apache.maven.plugins:maven-surefire-plugin:2.16:test (default-test) on project activemq-unit-tests: ExecutionException; nested exception is java.util.concurrent.ExecutionException: java.lang.RuntimeException: The forked VM terminated without saying properly goodbye. VM crash or System.exit called ? [ERROR] Command was/bin/sh -c cd https://builds.apache.org/job/ActiveMQ-Java7-All-UnitTests/ws/activemq-unit-tests /home/jenkins/tools/java/jdk1.7.0_25-32/jre/bin/java -Xmx512m -jar https://builds.apache.org/job/ActiveMQ-Java7-All-UnitTests/ws/activemq-unit-tests/target/surefire/surefirebooter6036784485824017760.jar https://builds.apache.org/job/ActiveMQ-Java7-All-UnitTests/ws/activemq-unit-tests/target/surefire/surefire6775773055333034067tmp https://builds.apache.org/job/ActiveMQ-Java7-All-UnitTests/ws/activemq-unit-tests/target/surefire/surefire_4721165598611231539597tmp [ERROR] - [Help 1] org.apache.maven.lifecycle.LifecycleExecutionException: Failed to execute goal org.apache.maven.plugins:maven-surefire-plugin:2.16:test (default-test) on project activemq-unit-tests: ExecutionException; nested exception is java.util.concurrent.ExecutionException: java.lang.RuntimeException: The forked VM terminated without saying properly goodbye. VM crash or System.exit called ? Command was/bin/sh -c cd https://builds.apache.org/job/ActiveMQ-Java7-All-UnitTests/ws/activemq-unit-tests /home/jenkins/tools/java/jdk1.7.0_25-32/jre/bin/java -Xmx512m -jar https://builds.apache.org/job/ActiveMQ-Java7-All-UnitTests/ws/activemq-unit-tests/target/surefire/surefirebooter6036784485824017760.jar https://builds.apache.org/job/ActiveMQ-Java7-All-UnitTests/ws/activemq-unit-tests/target/surefire/surefire6775773055333034067tmp https://builds.apache.org/job/ActiveMQ-Java7-All-UnitTests/ws/activemq-unit-tests/target/surefire/surefire_4721165598611231539597tmp at org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:213) at org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:153) at org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:145) at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject(LifecycleModuleBuilder.java:84) at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject(LifecycleModuleBuilder.java:59) at org.apache.maven.lifecycle.internal.LifecycleStarter.singleThreadedBuild(LifecycleStarter.java:183) at org.apache.maven.lifecycle.internal.LifecycleStarter.execute(LifecycleStarter.java:161) at org.apache.maven.DefaultMaven.doExecute(DefaultMaven.java:320) at org.apache.maven.DefaultMaven.execute(DefaultMaven.java:156) at org.jvnet.hudson.maven3.launcher.Maven3Launcher.main(Maven3Launcher.java:117) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:606) at
activemq git commit: fix incorrect warn message about lease duration and keep alive
Repository: activemq
Updated Branches:
refs/heads/master ce16735bb - f45ce0965
fix incorrect warn message about lease duration and keep alive
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/f45ce096
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/f45ce096
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/f45ce096
Branch: refs/heads/master
Commit: f45ce09655932be7207feb87101b3f87794462ae
Parents: ce16735
Author: gtully gary.tu...@gmail.com
Authored: Fri Jun 12 12:25:35 2015 +0100
Committer: gtully gary.tu...@gmail.com
Committed: Fri Jun 12 12:26:06 2015 +0100
--
.../java/org/apache/activemq/store/jdbc/LeaseDatabaseLocker.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/activemq/blob/f45ce096/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/LeaseDatabaseLocker.java
--
diff --git
a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/LeaseDatabaseLocker.java
b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/LeaseDatabaseLocker.java
index 9dce47e..e03fbc4 100644
---
a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/LeaseDatabaseLocker.java
+++
b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/LeaseDatabaseLocker.java
@@ -48,7 +48,7 @@ public class LeaseDatabaseLocker extends AbstractJDBCLocker {
if (lockAcquireSleepInterval lockable.getLockKeepAlivePeriod()) {
LOG.warn(LockableService keep alive period: +
lockable.getLockKeepAlivePeriod()
-+ , which renews the lease, is less than
lockAcquireSleepInterval: + lockAcquireSleepInterval
++ , which renews the lease, is greater than
lockAcquireSleepInterval: + lockAcquireSleepInterval
+ , the lease duration. These values will allow the lease
to expire.);
}
svn commit: r954617 - in /websites/production/activemq/content: cache/main.pageCache mqtt.html
Author: buildbot Date: Fri Jun 12 19:21:04 2015 New Revision: 954617 Log: Production update by buildbot for activemq Modified: websites/production/activemq/content/cache/main.pageCache websites/production/activemq/content/mqtt.html Modified: websites/production/activemq/content/cache/main.pageCache == Binary files - no diff available. Modified: websites/production/activemq/content/mqtt.html == --- websites/production/activemq/content/mqtt.html (original) +++ websites/production/activemq/content/mqtt.html Fri Jun 12 19:21:04 2015 @@ -87,6 +87,8 @@ lt;transportConnector name=quot;mqttquot; uri=quot;mqtt://localhost:1883quot;/gt; lt;/transportConnectorsgt; ]]/script +/div/divh3 id=MQTT-TheMQTTWireFormatThe MQTT Wire Format/h3pMQTT uses a compact binary format that can be configured with the following options. #160;All options can be configured on a Brokers transport bind URI./pdiv class=table-wraptable class=confluenceTabletbodytrth colspan=1 rowspan=1 class=confluenceThpParameter Name/p/thth colspan=1 rowspan=1 class=confluenceThpDefault Value/p/thth colspan=1 rowspan=1 class=confluenceThpDescription/p/th/trtrtd colspan=1 rowspan=1 class=confluenceTdpmaxFrameSize/p/tdtd colspan=1 rowspan=1 class=confluenceTdp268435456/p/tdtd colspan=1 rowspan=1 class=confluenceTdp(v5.12.0) Maximum frame size that can be sent. The protocol limit is 256 megabytes and his value cannot be set higher. Can help help prevent OOM DOS attacks/p/td/tr/tbody/table/divpAll options must be prepended with#160;codewireFormat/code#160;in order to t ake effect. Without this proper formatting, the option will have zero effect./ph4 id=MQTT-ExampleWireFormatConfigurationExample Wire Format Configurationbr clear=none#160;/h4div class=code panel pdl style=border-width: 1px;div class=codeContent panelContent pdl +script class=theme: Default; brush: xml; gutter: false type=syntaxhighlighter![CDATA[ lt;transportConnector name=quot;mqttquot; uri=quot;mqtt://localhost:61612?wireFormat.maxFrameSize=10quot;/gt;]]/script /div/divh3 id=MQTT-SecuritySecurity/h3pThe ActiveMQ MQTT Transport implementation fully supports an a shape=rect href=security.htmlActiveMQ security/a mechanism. Also, the authorization policies will be applied when you try to access (read/write) certain destinations./ph3 id=MQTT-EnablingMQTToverNIOEnabling MQTT over NIO/h3pFor better scalability (and performance) you might want to run the MQTT protocol over NIO transport. To do that just use codemqtt+nio/code transport prefix instead of codematt/code. For example, add the following transport configuration in your XML file/pdiv class=code panel pdl style=border-width: 1px;div class=codeContent panelContent pdl script class=theme: Default; brush: xml; gutter: false type=syntaxhighlighter![CDATA[ lt;transportConnector name=quot;mqtt+nioquot; uri=quot;mqtt+nio://localhost:1883quot;/gt; ]]/script
activemq git commit: https://issues.apache.org/jira/browse/AMQ-5839
Repository: activemq
Updated Branches:
refs/heads/master 4945c83d7 - 732fd5684
https://issues.apache.org/jira/browse/AMQ-5839
Disable failing test, broker doesn't currently recover the noLocal state
for a durable subscription.
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/732fd568
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/732fd568
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/732fd568
Branch: refs/heads/master
Commit: 732fd5684017cd585bfb418950a03ec9a6f44e49
Parents: 4945c83
Author: Timothy Bish tabish...@gmail.com
Authored: Fri Jun 12 16:43:34 2015 -0400
Committer: Timothy Bish tabish...@gmail.com
Committed: Fri Jun 12 16:43:34 2015 -0400
--
.../activemq/transport/amqp/interop/AmqpDurableReceiverTest.java | 2 ++
1 file changed, 2 insertions(+)
--
http://git-wip-us.apache.org/repos/asf/activemq/blob/732fd568/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpDurableReceiverTest.java
--
diff --git
a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpDurableReceiverTest.java
b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpDurableReceiverTest.java
index e2d2495..1b944a9 100644
---
a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpDurableReceiverTest.java
+++
b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpDurableReceiverTest.java
@@ -35,6 +35,7 @@ import org.apache.qpid.proton.amqp.messaging.Source;
import org.apache.qpid.proton.amqp.messaging.TerminusDurability;
import org.apache.qpid.proton.amqp.messaging.TerminusExpiryPolicy;
import org.apache.qpid.proton.engine.Receiver;
+import org.junit.Ignore;
import org.junit.Test;
/**
@@ -292,6 +293,7 @@ public class AmqpDurableReceiverTest extends
AmqpClientTestSupport {
connection.close();
}
+@Ignore(Broker doesn't currently recover noLocal state)
@Test(timeout = 6)
public void
testLookupExistingSubscriptionAfterRestartWithSelectorAndNoLocal() throws
Exception {
activemq git commit: https://issues.apache.org/jira/browse/AMQ-5839
Repository: activemq
Updated Branches:
refs/heads/master d74c08713 - 4945c83d7
https://issues.apache.org/jira/browse/AMQ-5839
Use correct name for the no-local filter
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/4945c83d
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/4945c83d
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/4945c83d
Branch: refs/heads/master
Commit: 4945c83d708eb5fe6c6a44cb0e73e96f495da9a5
Parents: d74c087
Author: Timothy Bish tabish...@gmail.com
Authored: Fri Jun 12 16:11:55 2015 -0400
Committer: Timothy Bish tabish...@gmail.com
Committed: Fri Jun 12 16:11:55 2015 -0400
--
.../main/java/org/apache/activemq/transport/amqp/AmqpSupport.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/activemq/blob/4945c83d/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpSupport.java
--
diff --git
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpSupport.java
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpSupport.java
index 0579fcf..0d3f733 100644
---
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpSupport.java
+++
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpSupport.java
@@ -38,7 +38,7 @@ public class AmqpSupport {
public static final Symbol JMS_SELECTOR_NAME =
Symbol.valueOf(apache.org:selector-filter:string);
public static final Object[] JMS_SELECTOR_FILTER_IDS = new Object[] {
JMS_SELECTOR_CODE, JMS_SELECTOR_NAME };
public static final UnsignedLong NO_LOCAL_CODE =
UnsignedLong.valueOf(0x468C0003L);
-public static final Symbol NO_LOCAL_NAME =
Symbol.valueOf(apache.org:selector-filter:string);
+public static final Symbol NO_LOCAL_NAME =
Symbol.valueOf(apache.org:no-local-filter:list);
public static final Object[] NO_LOCAL_FILTER_IDS = new Object[] {
NO_LOCAL_CODE, NO_LOCAL_NAME };
// Capabilities used to identify destination type in some requests.
activemq git commit: Add a negative validation test.
Repository: activemq
Updated Branches:
refs/heads/master d723d14ac - d74c08713
Add a negative validation test.
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/d74c0871
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/d74c0871
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/d74c0871
Branch: refs/heads/master
Commit: d74c0871347b509a610d585188f61142e3d06b50
Parents: d723d14
Author: Timothy Bish tabish...@gmail.com
Authored: Fri Jun 12 15:39:17 2015 -0400
Committer: Timothy Bish tabish...@gmail.com
Committed: Fri Jun 12 15:39:17 2015 -0400
--
.../amqp/interop/AmqpSendReceiveTest.java | 17 -
1 file changed, 12 insertions(+), 5 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/activemq/blob/d74c0871/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpSendReceiveTest.java
--
diff --git
a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpSendReceiveTest.java
b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpSendReceiveTest.java
index 29ff954..906febf 100644
---
a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpSendReceiveTest.java
+++
b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpSendReceiveTest.java
@@ -19,6 +19,7 @@ package org.apache.activemq.transport.amqp.interop;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
import static org.junit.Assert.assertTrue;
import java.util.concurrent.TimeUnit;
@@ -86,23 +87,29 @@ public class AmqpSendReceiveTest extends
AmqpClientTestSupport {
AmqpConnection connection = client.connect();
AmqpSession session = connection.createSession();
-AmqpMessage message = new AmqpMessage();
+AmqpMessage message1 = new AmqpMessage();
+message1.setGroupId(abcdefg);
+message1.setApplicationProperty(sn, 100);
-message.setGroupId(abcdefg);
-message.setApplicationProperty(sn, 100);
+AmqpMessage message2 = new AmqpMessage();
+message2.setGroupId(hijklm);
+message2.setApplicationProperty(sn, 200);
AmqpSender sender = session.createSender(queue:// + getTestName());
-sender.send(message);
+sender.send(message1);
+sender.send(message2);
sender.close();
AmqpReceiver receiver = session.createReceiver(queue:// +
getTestName(), sn = 100);
-receiver.flow(1);
+receiver.flow(2);
AmqpMessage received = receiver.receive(5, TimeUnit.SECONDS);
assertNotNull(received);
assertEquals(100, received.getApplicationProperty(sn));
assertEquals(abcdefg, received.getGroupId());
received.accept();
+assertNull(receiver.receive(1, TimeUnit.SECONDS));
+
receiver.close();
}
[CONF] Apache ActiveMQ How do I embed a Broker inside a Connection
Timothy Bish edited the page: How do I embed a Broker inside a Connection ... The following Java code will create an embedded broker Code Block BrokerService broker = new BrokerService(); // configure the broker broker.addConnector(tcp://localhost:61616); broker.start(); If you want to lazily bind the transport connector as part of start(), useful when start() will block pending a store lock (as in a slave start), you can use the following code Code Block BrokerService broker = new BrokerService(); TransportConnector connector = new TransportConnector(); connector.setUri(new URI(tcp://localhost:61616)); broker.addConnector(connector); broker.start(); ... If you have more than one embedded broker, ensure that you give them a unique name and - e.g. Code Block BrokerService broker = new BrokerService(); // configure the broker broker.setBrokerName(fred); broker.addConnector(tcp://localhost:61616); broker.start(); ... It is possible to fully configure a broker through application code e.g. Code Block
svn commit: r954603 - in /websites/production/activemq/content: cache/main.pageCache how-do-i-embed-a-broker-inside-a-connection.html
Author: buildbot Date: Fri Jun 12 16:20:58 2015 New Revision: 954603 Log: Production update by buildbot for activemq Modified: websites/production/activemq/content/cache/main.pageCache websites/production/activemq/content/how-do-i-embed-a-broker-inside-a-connection.html Modified: websites/production/activemq/content/cache/main.pageCache == Binary files - no diff available. Modified: websites/production/activemq/content/how-do-i-embed-a-broker-inside-a-connection.html == --- websites/production/activemq/content/how-do-i-embed-a-broker-inside-a-connection.html (original) +++ websites/production/activemq/content/how-do-i-embed-a-broker-inside-a-connection.html Fri Jun 12 16:20:58 2015 @@ -81,56 +81,31 @@ tbody tr td valign=top width=100% -div class=wiki-content maincontentpIn many messaging topologies there are JMS Brokers (server side) and a JMS client side. Often it makes sense to deploy a broker within your JVM. This allows you to optimise away a network hop; making the networking of JMS as efficient as pure RMI, but with all the usual JMS features of location independence, reliability, load balancing etc./p - -pThere are various ways to embed a broker in ActiveMQ depending on if you are using Java, Spring, XBean or using the ActiveMQConnectionFactory ./p - -h3 id=HowdoIembedaBrokerinsideaConnection-UsingexplicitJavacodeUsing explicit Java code/h3 - -pThe following Java code will create an embedded broker/p -div class=code panel pdl style=border-width: 1px;div class=codeContent panelContent pdl -script class=theme: Default; brush: java; gutter: false type=syntaxhighlighter![CDATA[ -BrokerService broker = new BrokerService(); +div class=wiki-content maincontentpIn many messaging topologies there are JMS Brokers (server side) and a JMS client side. Often it makes sense to deploy a broker within your JVM. This allows you to optimise away a network hop; making the networking of JMS as efficient as pure RMI, but with all the usual JMS features of location independence, reliability, load balancing etc./ppThere are various ways to embed a broker in ActiveMQ depending on if you are using Java, Spring, XBean or using the ActiveMQConnectionFactory ./ph3 id=HowdoIembedaBrokerinsideaConnection-UsingexplicitJavacodeUsing explicit Java code/h3pThe following Java code will create an embedded broker/pdiv class=code panel pdl style=border-width: 1px;div class=codeContent panelContent pdl +script class=theme: Default; brush: java; gutter: false type=syntaxhighlighter![CDATA[BrokerService broker = new BrokerService(); // configure the broker broker.addConnector(quot;tcp://localhost:61616quot;); broker.start(); ]]/script -/div/div - -pIf you want to lazily bind the transport connector as part of start(), useful when start() will block pending a store lock (as in a slave start), you can use the following code/p -div class=code panel pdl style=border-width: 1px;div class=codeContent panelContent pdl -script class=theme: Default; brush: java; gutter: false type=syntaxhighlighter![CDATA[ -BrokerService broker = new BrokerService(); +/div/divpIf you want to lazily bind the transport connector as part of start(), useful when start() will block pending a store lock (as in a slave start), you can use the following code/pdiv class=code panel pdl style=border-width: 1px;div class=codeContent panelContent pdl +script class=theme: Default; brush: java; gutter: false type=syntaxhighlighter![CDATA[BrokerService broker = new BrokerService(); TransportConnector connector = new TransportConnector(); connector.setUri(new URI(quot;tcp://localhost:61616quot;)); broker.addConnector(connector); broker.start(); ]]/script -/div/div - -pIn the same JVM clients can then use the a shape=rect href=vm-transport-reference.htmlvm:// transport/a to connect to the embedded broker - whilst external clients can use the a shape=rect href=tcp-transport-reference.htmltcp:// protocol/a/p - -pIf you have more than one embedded broker, ensure that you give them a unique name and - e.g./p -div class=code panel pdl style=border-width: 1px;div class=codeContent panelContent pdl -script class=theme: Default; brush: java; gutter: false type=syntaxhighlighter![CDATA[ -BrokerService broker = new BrokerService(); +/div/divpIn the same JVM clients can then use the a shape=rect href=vm-transport-reference.htmlvm:// transport/a to connect to the embedded broker - whilst external clients can use the a shape=rect href=tcp-transport-reference.htmltcp:// protocol/a/ppIf you have more than one embedded broker, ensure that you give them a unique name and - e.g./pdiv class=code panel pdl style=border-width: 1px;div class=codeContent panelContent pdl +script class=theme: Default; brush: java; gutter: false
[1/2] activemq git commit: https://issues.apache.org/jira/browse/AMQ-5393
Repository: activemq
Updated Branches:
refs/heads/master f45ce0965 - f74e3c114
https://issues.apache.org/jira/browse/AMQ-5393
Adding a property called schedulePeriodForDiskUsageCheck which can be set
to a time period to periodically check disk usage limits and adjust if
the amount of disk space has been reduced.
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/61fd811a
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/61fd811a
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/61fd811a
Branch: refs/heads/master
Commit: 61fd811adcb416ca1810dac81ef33e39e8722537
Parents: f45ce09
Author: Christopher L. Shannon (cshannon) christopher.l.shan...@gmail.com
Authored: Tue Jun 9 19:40:16 2015 +
Committer: Timothy Bish tabish...@gmail.com
Committed: Fri Jun 12 10:35:20 2015 -0400
--
.../apache/activemq/broker/BrokerService.java | 79 ++--
.../usage/PeriodicDiskUsageLimitTest.java | 185 +++
2 files changed, 253 insertions(+), 11 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/activemq/blob/61fd811a/activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java
--
diff --git
a/activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java
b/activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java
index d285c74..6148d38 100644
---
a/activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java
+++
b/activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java
@@ -229,6 +229,7 @@ public class BrokerService implements Service {
private ThreadPoolExecutor executor;
private int schedulePeriodForDestinationPurge= 0;
private int maxPurgedDestinationsPerSweep = 0;
+private int schedulePeriodForDiskUsageCheck = 0;
private BrokerContext brokerContext;
private boolean networkConnectorStartAsync = false;
private boolean allowTempAutoCreationOnSend;
@@ -1953,17 +1954,12 @@ public class BrokerService implements Service {
}
}
-protected void checkSystemUsageLimits() throws IOException {
-SystemUsage usage = getSystemUsage();
-long memLimit = usage.getMemoryUsage().getLimit();
-long jvmLimit = Runtime.getRuntime().maxMemory();
-
-if (memLimit jvmLimit) {
-usage.getMemoryUsage().setPercentOfJvmHeap(70);
-LOG.warn(Memory Usage for the Broker ( + memLimit / (1024 *
1024) +
- mb) is more than the maximum available for the JVM: +
-jvmLimit / (1024 * 1024) + mb - resetting to 70% of
maximum available: + (usage.getMemoryUsage().getLimit() / (1024 * 1024)) +
mb);
-}
+/**
+ * Check that the store usage limit is not greater than max usable
+ * space and adjust if it is
+ */
+protected void checkStoreUsageLimits() throws IOException {
+final SystemUsage usage = getSystemUsage();
if (getPersistenceAdapter() != null) {
PersistenceAdapter adapter = getPersistenceAdapter();
@@ -2007,6 +2003,14 @@ public class BrokerService implements Service {
}
}
+}
+
+/**
+ * Check that temporary usage limit is not greater than max usable
+ * space and adjust if it is
+ */
+protected void checkTmpStoreUsageLimits() throws IOException {
+final SystemUsage usage = getSystemUsage();
File tmpDir = getTmpDataDirectory();
if (tmpDir != null) {
@@ -2047,6 +2051,54 @@ public class BrokerService implements Service {
}
}
}
+}
+
+/**
+ * Schedules a periodic task based on schedulePeriodForDiskLimitCheck to
+ * update store and temporary store limits if the amount of available space
+ * plus current store size is less than the existin configured limit
+ */
+protected void scheduleDiskUsageLimitsCheck() throws IOException {
+if (schedulePeriodForDiskUsageCheck 0
+(getPersistenceAdapter() != null || getTmpDataDirectory() !=
null)) {
+Runnable diskLimitCheckTask = new Runnable() {
+@Override
+public void run() {
+try {
+checkStoreUsageLimits();
+} catch (IOException e) {
+LOG.error(Failed to check persistent disk usage
limits, e);
+}
+
+try {
+checkTmpStoreUsageLimits();
+} catch (IOException e) {
+LOG.error(Failed to check temporary store usage
limits, e);
+}
+}
+};
+
[2/2] activemq git commit: This closes #110
This closes #110 Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/f74e3c11 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/f74e3c11 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/f74e3c11 Branch: refs/heads/master Commit: f74e3c1146dfdc0dacaa2a8de8bf9ce23d959d80 Parents: f45ce09 61fd811 Author: Timothy Bish tabish...@gmail.com Authored: Fri Jun 12 10:45:48 2015 -0400 Committer: Timothy Bish tabish...@gmail.com Committed: Fri Jun 12 10:45:48 2015 -0400 -- .../apache/activemq/broker/BrokerService.java | 79 ++-- .../usage/PeriodicDiskUsageLimitTest.java | 185 +++ 2 files changed, 253 insertions(+), 11 deletions(-) --
[1/6] activemq-artemis git commit: ARTEMIS-127 Fixing activemq-unit-tests pom version
Repository: activemq-artemis Updated Branches: refs/heads/master 145fc7f82 - 29d59e970 ARTEMIS-127 Fixing activemq-unit-tests pom version Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/61895223 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/61895223 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/61895223 Branch: refs/heads/master Commit: 61895223d07ebc58cde504bd57d3b95c0d27b677 Parents: 145fc7f Author: Thiago Kronig thiagokro...@gmail.com Authored: Wed Jun 10 13:22:08 2015 -0300 Committer: Thiago Kronig thiagokro...@gmail.com Committed: Thu Jun 11 23:58:12 2015 -0300 -- tests/activemq5-unit-tests/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/61895223/tests/activemq5-unit-tests/pom.xml -- diff --git a/tests/activemq5-unit-tests/pom.xml b/tests/activemq5-unit-tests/pom.xml index d6d87e8..da44d3e 100644 --- a/tests/activemq5-unit-tests/pom.xml +++ b/tests/activemq5-unit-tests/pom.xml @@ -20,7 +20,7 @@ parent groupIdorg.apache.activemq.tests/groupId artifactIdartemis-tests-pom/artifactId - version1.0.0-SNAPSHOT/version + version1.0.1-SNAPSHOT/version /parent artifactIdactivemq5-unit-tests/artifactId
Jenkins build is still unstable: ActiveMQ-Java8 » ActiveMQ :: Unit Tests #384
See https://builds.apache.org/job/ActiveMQ-Java8/org.apache.activemq$activemq-unit-tests/changes
Jenkins build is still unstable: ActiveMQ-Java8 #384
See https://builds.apache.org/job/ActiveMQ-Java8/changes
Jenkins build is still unstable: ActiveMQ-Java8 » ActiveMQ :: RA #384
See https://builds.apache.org/job/ActiveMQ-Java8/org.apache.activemq$activemq-ra/384/
[1/2] activemq git commit: https://issues.apache.org/jira/browse/AMQ-5836
Repository: activemq
Updated Branches:
refs/heads/master f74e3c114 - 8cc5f597d
https://issues.apache.org/jira/browse/AMQ-5836
Modifying start up scripts to consistently use the same property names
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/ab389684
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/ab389684
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/ab389684
Branch: refs/heads/master
Commit: ab389684be1f6da3a0887f1f1392f3399b1aca0d
Parents: f74e3c1
Author: Christopher L. Shannon christopher.l.shan...@gmail.com
Authored: Thu Jun 11 21:35:33 2015 -0400
Committer: Timothy Bish tabish...@gmail.com
Committed: Fri Jun 12 11:50:44 2015 -0400
--
assembly/src/release/bin/activemq-admin | 10 +-
assembly/src/release/bin/activemq-admin.bat | 6 +++---
assembly/src/release/bin/activemq.bat | 6 +++---
3 files changed, 11 insertions(+), 11 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/activemq/blob/ab389684/assembly/src/release/bin/activemq-admin
--
diff --git a/assembly/src/release/bin/activemq-admin
b/assembly/src/release/bin/activemq-admin
index cbe2aef..eff43dd 100644
--- a/assembly/src/release/bin/activemq-admin
+++ b/assembly/src/release/bin/activemq-admin
@@ -151,15 +151,15 @@ if [ $1 = start ] ; then
ACTIVEMQ_OPTS=-Xmx1G
-Dorg.apache.activemq.UseDedicatedTaskRunner=true
-Djava.util.logging.config.file=logging.properties
-Djava.security.auth.login.config=$ACTIVEMQ_CONF/login.config
fi
-if [ -z $SUNJMX ] ; then
-#SUNJMX=-Dcom.sun.management.jmxremote.port=1099
-Dcom.sun.management.jmxremote.authenticate=false
-Dcom.sun.management.jmxremote.ssl=false
-SUNJMX=-Dcom.sun.management.jmxremote
+if [ -z $ACTIVEMQ_SUNJMX_START ] ; then
+#ACTIVEMQ_SUNJMX_START=-Dcom.sun.management.jmxremote.port=1099
-Dcom.sun.management.jmxremote.authenticate=false
-Dcom.sun.management.jmxremote.ssl=false
+ACTIVEMQ_SUNJMX_START=-Dcom.sun.management.jmxremote
fi
-ACTIVEMQ_OPTS=$ACTIVEMQ_OPTS $SUNJMX -Djava.io.tmpdir=${ACTIVEMQ_TMP}
+ACTIVEMQ_OPTS=$ACTIVEMQ_OPTS $ACTIVEMQ_SUNJMX_START
-Djava.io.tmpdir=${ACTIVEMQ_TMP}
fi
-ACTIVEMQ_OPTS=$ACTIVEMQ_OPTS $SSL_OPTS
+ACTIVEMQ_OPTS=$ACTIVEMQ_OPTS $ACTIVEMQ_SSL_OPTS
# Uncomment to enable YourKit profiling
#ACTIVEMQ_DEBUG_OPTS=-agentlib:yjpagent
http://git-wip-us.apache.org/repos/asf/activemq/blob/ab389684/assembly/src/release/bin/activemq-admin.bat
--
diff --git a/assembly/src/release/bin/activemq-admin.bat
b/assembly/src/release/bin/activemq-admin.bat
index 6327826..35a5ffb 100644
--- a/assembly/src/release/bin/activemq-admin.bat
+++ b/assembly/src/release/bin/activemq-admin.bat
@@ -82,8 +82,8 @@ if /i not %1 == start goto debugOpts
if %ACTIVEMQ_OPTS% == set ACTIVEMQ_OPTS=-Xmx1G
-Dorg.apache.activemq.UseDedicatedTaskRunner=true
-Djava.util.logging.config.file=logging.properties
-Djava.security.auth.login.config=%ACTIVEMQ_CONF%\login.config
-if %SUNJMX% == set SUNJMX=-Dcom.sun.management.jmxremote
-REM set SUNJMX=-Dcom.sun.management.jmxremote.port=1099
-Dcom.sun.management.jmxremote.authenticate=false
-Dcom.sun.management.jmxremote.ssl=false
+if %ACTIVEMQ_SUNJMX_START% == set
ACTIVEMQ_SUNJMX_START=-Dcom.sun.management.jmxremote
+REM set ACTIVEMQ_SUNJMX_START=-Dcom.sun.management.jmxremote.port=1099
-Dcom.sun.management.jmxremote.authenticate=false
-Dcom.sun.management.jmxremote.ssl=false
:debugOpts
@@ -95,7 +95,7 @@ REM SET ACTIVEMQ_DEBUG_OPTS=-Xdebug -Xnoagent
-Djava.compiler=NONE -Xrunjdwp:tra
REM Setup ActiveMQ Classpath. Default is the conf directory.
set ACTIVEMQ_CLASSPATH=%ACTIVEMQ_CONF%;%ACTIVEMQ_DATA%;%ACTIVEMQ_CLASSPATH%
-%_JAVACMD% %SUNJMX% %ACTIVEMQ_DEBUG_OPTS% %ACTIVEMQ_OPTS% %SSL_OPTS%
-Dactivemq.classpath=%ACTIVEMQ_CLASSPATH% -Dactivemq.home=%ACTIVEMQ_HOME%
-Dactivemq.base=%ACTIVEMQ_BASE% -Dactivemq.data=%ACTIVEMQ_DATA%
-Djava.io.tmpdir=%ACTIVEMQ_TMP% -Dactivemq.conf=%ACTIVEMQ_CONF% -jar
%ACTIVEMQ_HOME%/bin/activemq.jar %*
+%_JAVACMD% %ACTIVEMQ_SUNJMX_START% %ACTIVEMQ_DEBUG_OPTS% %ACTIVEMQ_OPTS%
%ACTIVEMQ_SSL_OPTS% -Dactivemq.classpath=%ACTIVEMQ_CLASSPATH%
-Dactivemq.home=%ACTIVEMQ_HOME% -Dactivemq.base=%ACTIVEMQ_BASE%
-Dactivemq.data=%ACTIVEMQ_DATA% -Djava.io.tmpdir=%ACTIVEMQ_TMP%
-Dactivemq.conf=%ACTIVEMQ_CONF% -jar %ACTIVEMQ_HOME%/bin/activemq.jar %*
goto end
http://git-wip-us.apache.org/repos/asf/activemq/blob/ab389684/assembly/src/release/bin/activemq.bat
--
diff --git a/assembly/src/release/bin/activemq.bat
b/assembly/src/release/bin/activemq.bat
index 276bfab..22e1f9d
[2/2] activemq git commit: This closes #111
This closes #111 Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/8cc5f597 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/8cc5f597 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/8cc5f597 Branch: refs/heads/master Commit: 8cc5f597d94f8be7f456650daaf11e3fba883880 Parents: f74e3c1 ab38968 Author: Timothy Bish tabish...@gmail.com Authored: Fri Jun 12 11:58:22 2015 -0400 Committer: Timothy Bish tabish...@gmail.com Committed: Fri Jun 12 11:58:22 2015 -0400 -- assembly/src/release/bin/activemq-admin | 10 +- assembly/src/release/bin/activemq-admin.bat | 6 +++--- assembly/src/release/bin/activemq.bat | 6 +++--- 3 files changed, 11 insertions(+), 11 deletions(-) --
[CONF] Apache ActiveMQ JMX
Christopher L. Shannon edited the page:
JMX
...
3. Modify the activemq startup script (in bin) to enable the Java 1.5+ JMX connector
Find the ACTIVEMQ_SUNJMX_START= line and change it too the following: (note that in previous versions of ActiveMQ this property was called SUNJMX in some scripts. As of v5.12.0 all scripts use ACTIVEMQ_SUNJMX_START):
Code Block
1. Windows
ACTIVEMQ_SUNJMX_START=-Dcom.sun.management.jmxremote.port=1616 -Dcom.sun.management.jmxremote.ssl=false \
-Dcom.sun.management.jmxremote.password.file=%ACTIVEMQ_BASE%/conf/jmx.password \
-Dcom.sun.management.jmxremote.access.file=%ACTIVEMQ_BASE%/conf/jmx.access
2. Unix
ACTIVEMQ_SUNJMX_START=-Dcom.sun.management.jmxremote.port=1616 -Dcom.sun.management.jmxremote.ssl=false \
-Dcom.sun.management.jmxremote.password.file=${ACTIVEMQ_BASE}/conf/jmx.password \
-Dcom.sun.management.jmxremote.access.file=${ACTIVEMQ_BASE}/conf/jmx.access
...
Code Block
1. Windows
ACTIVEMQ_HOME=DRIVE_LETTER:/where/ActiveMQ/is/installed
ACTIVEMQ_BASE=%ACTIVEMQ_HOME%
ACTIVEMQ_SUNJMX_START=-Dcom.sun.management.jmxremote.port=1616 -Dcom.sun.management.jmxremote.ssl=false \
-Dcom.sun.management.jmxremote.password.file=%ACTIVEMQ_BASE%/conf/jmx.password \
-Dcom.sun.management.jmxremote.access.file=%ACTIVEMQ_BASE%/conf/jmx.access
2. Unix
ACTIVEMQ_HOME=DRIVE_LETTER:/where/ActiveMQ/is/installed
ACTIVEMQ_BASE=${ACTIVEMQ_HOME}
ACTIVEMQ_SUNJMX_START=-Dcom.sun.management.jmxremote.port=1616 -Dcom.sun.management.jmxremote.ssl=false \
-Dcom.sun.management.jmxremote.password.file=${ACTIVEMQ_BASE}/conf/jmx.password \
-Dcom.sun.management.jmxremote.access.file=${ACTIVEMQ_BASE}/conf/jmx.access
...
For example you can enable remote JMX connections to the Sun JMX connector, via setting the following environment variable (using set or export depending on your platform). These settings only configure the Sun JMX connector within Java 1.5+, not the JMX connector that ActiveMQ creates by default.
Code
[CONF] Apache ActiveMQ How do I use SSL
Christopher L. Shannon edited the page: How do I use SSL ... Before starting the broker's VM set the ACTIVEMQ_SSL_OPTS enviorment OPTSenvironment variable so that it knows to use the broker keystore. (note that in previous versions of ActiveMQ this property was called SSL_OPTS in some scripts. As of v5.12.0 all scripts use ACTIVEMQ_SSL_OPTS) Code Block export ACTIVEMQ_SSL_OPTS = -Djavax.net.ssl.keyStore=/path/to/broker.ks -Djavax.net.ssl.keyStorePassword=password ... Export the client's certificate so it can be shared with broker: Code Block keytool -export -alias client -keystore client.ks -file client_cert Create a truststore for the broker, and import the client's certificate. This establishes that the broker trusts the client: Code Block keytool -import -alias client -keystore broker.ts -file client_cert Add Code Block
buildbot failure in ASF Buildbot on activemq-site-production
The Buildbot has detected a new failure on builder activemq-site-production while building ASF Buildbot. Full details are available at: http://ci.apache.org/builders/activemq-site-production/builds/9904 Buildbot URL: http://ci.apache.org/ Buildslave for this Build: bb-cms-slave Build Reason: The Nightly scheduler named 'activemq-site-production' triggered this build Build Source Stamp: [branch activemq/activemq-website] HEAD Blamelist: BUILD FAILED: failed compile Sincerely, -The Buildbot
[2/6] activemq-artemis git commit: ARTEMIS-127 Fixing sync on non-final object for ArtemisBrokerWrapper
ARTEMIS-127 Fixing sync on non-final object for ArtemisBrokerWrapper
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/aab34e5b
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/aab34e5b
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/aab34e5b
Branch: refs/heads/master
Commit: aab34e5bd01757c3305691e80d7d3588e5ca0cbe
Parents: 6189522
Author: Thiago Kronig thiagokro...@gmail.com
Authored: Wed Jun 10 13:23:03 2015 -0300
Committer: Thiago Kronig thiagokro...@gmail.com
Committed: Thu Jun 11 23:58:13 2015 -0300
--
.../activemq/broker/artemiswrapper/ArtemisBrokerWrapper.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/aab34e5b/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/artemiswrapper/ArtemisBrokerWrapper.java
--
diff --git
a/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/artemiswrapper/ArtemisBrokerWrapper.java
b/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/artemiswrapper/ArtemisBrokerWrapper.java
index 86580e1..b739730 100644
---
a/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/artemiswrapper/ArtemisBrokerWrapper.java
+++
b/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/artemiswrapper/ArtemisBrokerWrapper.java
@@ -38,7 +38,7 @@ import org.apache.activemq.broker.BrokerService;
public class ArtemisBrokerWrapper extends ArtemisBrokerBase
{
- protected MapString, SimpleString testQueues = new HashMapString,
SimpleString();
+ protected final MapString, SimpleString testQueues = new HashMapString,
SimpleString();
public ArtemisBrokerWrapper(BrokerService brokerService)
{
[CONF] Apache ActiveMQ MQTT
Christopher L. Shannon edited the page: MQTT ... Code Block xml transportConnectors transportConnector name=mqtt uri=mqtt://localhost:1883/ /transportConnectors The MQTT Wire Format MQTT uses a compact binary format that can be configured with the following options. All options can be configured on a Brokers transport bind URI. Parameter Name Default Value Description maxFrameSize MAX_LONG (v5.12.0) Maximum frame size that can be sent. The protocol limit is 256 megabytes and his value cannot be set higher. Can help help prevent OOM DOS attacks All options must be prepended withwireFormatin order to take effect. Without this proper formatting, the option will have zero effect. Example Wire Format Configuration Code Block
svn commit: r954613 - in /websites/production/activemq/content: cache/main.pageCache how-do-i-use-ssl.html jmx.html
Author: buildbot Date: Fri Jun 12 18:21:03 2015 New Revision: 954613 Log: Production update by buildbot for activemq Modified: websites/production/activemq/content/cache/main.pageCache websites/production/activemq/content/how-do-i-use-ssl.html websites/production/activemq/content/jmx.html Modified: websites/production/activemq/content/cache/main.pageCache == Binary files - no diff available. Modified: websites/production/activemq/content/how-do-i-use-ssl.html == --- websites/production/activemq/content/how-do-i-use-ssl.html (original) +++ websites/production/activemq/content/how-do-i-use-ssl.html Fri Jun 12 18:21:03 2015 @@ -99,8 +99,8 @@ script class=theme: Default; brush: java; gutter: false type=syntaxhighlighter![CDATA[keytool -genkey -alias client -keyalg RSA -keystore client.ks]]/script /div/div/lilipCreate a truststore for the client, and import the broker's certificate. This establishes that the client trusts the broker:/pdiv class=code panel pdl style=border-width: 1px;div class=codeContent panelContent pdl script class=theme: Default; brush: java; gutter: false type=syntaxhighlighter![CDATA[keytool -import -alias broker -keystore client.ts -file broker_cert]]/script -/div/div/li/olh3 id=HowdoIuseSSL-StartingtheBrokerStarting the Broker/h3h4 id=HowdoIuseSSL-Usingthejavax.net.ssl.*SystemPropertiesUsing the javax.net.ssl.* System Properties/h4pBefore starting the broker's VM set the SSL_OPTS enviorment variable so that it knows to use the broker keystore./pdiv class=code panel pdl style=border-width: 1px;div class=codeContent panelContent pdl -script class=theme: Default; brush: java; gutter: false type=syntaxhighlighter![CDATA[export SSL_OPTS = -Djavax.net.ssl.keyStore=/path/to/broker.ks -Djavax.net.ssl.keyStorePassword=password +/div/div/li/olh3 id=HowdoIuseSSL-StartingtheBrokerStarting the Broker/h3h4 id=HowdoIuseSSL-Usingthejavax.net.ssl.*SystemPropertiesUsing the javax.net.ssl.* System Properties/h4pBefore starting the broker's VM set the ACTIVEMQ_SSL_OPTS#160;environment variable so that it knows to use the broker keystore. #160;(note that in previous versions of ActiveMQ this property was called SSL_OPTS in some scripts. #160;As of v5.12.0 all scripts use ACTIVEMQ_SSL_OPTS)/pdiv class=code panel pdl style=border-width: 1px;div class=codeContent panelContent pdl +script class=theme: Default; brush: java; gutter: false type=syntaxhighlighter![CDATA[export ACTIVEMQ_SSL_OPTS = -Djavax.net.ssl.keyStore=/path/to/broker.ks -Djavax.net.ssl.keyStorePassword=password ]]/script /div/divh4 id=HowdoIuseSSL-UsingSpringtoconfigureSSLforaBrokerinstanceUsing Spring to configure SSL for a Broker instance/h4pSometimes the use of javax.net.ssl.* system properties is not appropriate as they effect all SSL users in a JVM. ActiveMQ 5.2.x adds an lt;sslContextgt; element to the lt;amq:brokergt; that allows a broker specific set of SSL properties to be configured./ppThe SslContext a shape=rect class=external-link href=https://svn.apache.org/repos/asf/activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/transport/tcp/SslContextBrokerServiceTest.java;test case/a validates starting an SSL transport listener using the configuration specified in the broker Xbean. The SslContext element is added to the broker as follows:/pdiv class=code panel pdl style=border-width: 1px;div class=codeContent panelContent pdl script class=theme: Default; brush: java; gutter: false type=syntaxhighlighter![CDATA[lt;beans @@ -137,7 +137,7 @@ javax.net.ssl.trustStore=/path/to/client script class=theme: Default; brush: java; gutter: false type=syntaxhighlighter![CDATA[keytool -import -alias client -keystore broker.ts -file client_cert]]/script /div/div/lilipAdd/pdiv class=code panel pdl style=border-width: 1px;div class=codeContent panelContent pdl script class=theme: Default; brush: java; gutter: false type=syntaxhighlighter![CDATA[-Djavax.net.ssl.trustStore=/path/to/broker.ts]]/script -/div/divpto SSL_OPTS/p/lilipInstruct ActiveMQ to require client authentication by setting the following in activemq.xml:/pdiv class=code panel pdl style=border-width: 1px;div class=codeContent panelContent pdl +/div/divpto ACTIVEMQ_SSL_OPTS/p/lilipInstruct ActiveMQ to require client authentication by setting the following in activemq.xml:/pdiv class=code panel pdl style=border-width: 1px;div class=codeContent panelContent pdl script class=theme: Default; brush: java; gutter: false type=syntaxhighlighter![CDATA[ lt;transportConnectorsgt; lt;transportConnector name=quot;sslquot; uri=quot;ssl://localhost:61617?needClientAuth=truequot; /gt; lt;/transportConnectorsgt;]]/script Modified: websites/production/activemq/content/jmx.html == ---
buildbot success in ASF Buildbot on activemq-site-production
The Buildbot has detected a restored build on builder activemq-site-production while building ASF Buildbot. Full details are available at: http://ci.apache.org/builders/activemq-site-production/builds/9905 Buildbot URL: http://ci.apache.org/ Buildslave for this Build: bb-cms-slave Build Reason: The Nightly scheduler named 'activemq-site-production' triggered this build Build Source Stamp: [branch activemq/activemq-website] HEAD Blamelist: Build succeeded! Sincerely, -The Buildbot
activemq git commit: Add some additional control over what is configured on the running broker.
Repository: activemq
Updated Branches:
refs/heads/master 8cc5f597d - d723d14ac
Add some additional control over what is configured on the running
broker.
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/d723d14a
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/d723d14a
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/d723d14a
Branch: refs/heads/master
Commit: d723d14acb4f87c312804cabe61c7786e971396d
Parents: 8cc5f59
Author: Timothy Bish tabish...@gmail.com
Authored: Fri Jun 12 14:26:04 2015 -0400
Committer: Timothy Bish tabish...@gmail.com
Committed: Fri Jun 12 14:26:55 2015 -0400
--
.../activemq/transport/amqp/IDERunner.java | 20 +++-
1 file changed, 15 insertions(+), 5 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/activemq/blob/d723d14a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java
--
diff --git
a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java
b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java
index ab64f21..7067605 100644
---
a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java
+++
b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java
@@ -28,6 +28,8 @@ public class IDERunner {
private static final String AMQP_TRANSFORMER = jms;
private static final boolean TRANSPORT_TRACE = true;
+private static final boolean PERSISTENT = true;
+private static final boolean CLIENT_CONNECT = false;
public static void main(String[]args) throws Exception {
BrokerService brokerService = new BrokerService();
@@ -40,15 +42,23 @@ public class IDERunner {
KahaDBStore store = new KahaDBStore();
store.setDirectory(new File(target/activemq-data/kahadb));
-brokerService.setStoreOpenWireVersion(10);
-brokerService.setPersistenceAdapter(store);
+if (PERSISTENT) {
+brokerService.setStoreOpenWireVersion(10);
+brokerService.setPersistenceAdapter(store);
+brokerService.deleteAllMessages();
+} else {
+brokerService.setPersistent(false);
+}
+
brokerService.setUseJmx(false);
-brokerService.deleteAllMessages();
+brokerService.setAdvisorySupport(false);
brokerService.start();
-Connection connection =
JMSClientContext.INSTANCE.createConnection(connector.getPublishableConnectURI());
-connection.start();
+if (CLIENT_CONNECT) {
+Connection connection =
JMSClientContext.INSTANCE.createConnection(connector.getPublishableConnectURI());
+connection.start();
+}
brokerService.waitUntilStopped();
}
[CONF] Apache ActiveMQ MQTT
Christopher L. Shannon edited the page: MQTT ... Parameter Name Default Value Description maxFrameSize MAX_LONG268435456 (v5.12.0) Maximum frame size that can be sent. The protocol limit is 256 megabytes and his value cannot be set higher. Can help help prevent OOM DOS attacks ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
svn commit: r954592 - in /websites/production/activemq/content: cache/main.pageCache connection-configuration-uri.html
Author: buildbot Date: Fri Jun 12 13:21:01 2015 New Revision: 954592 Log: Production update by buildbot for activemq Modified: websites/production/activemq/content/cache/main.pageCache websites/production/activemq/content/connection-configuration-uri.html Modified: websites/production/activemq/content/cache/main.pageCache == Binary files - no diff available. Modified: websites/production/activemq/content/connection-configuration-uri.html == --- websites/production/activemq/content/connection-configuration-uri.html (original) +++ websites/production/activemq/content/connection-configuration-uri.html Fri Jun 12 13:21:01 2015 @@ -81,39 +81,11 @@ tbody tr td valign=top width=100% -div class=wiki-content maincontenth2 id=ConnectionConfigurationURI-ConnectionConfigurationURIConnection Configuration URI/h2 - -pAn Apache ActiveMQ connection can be configured by explicitly setting properties on the a shape=rect class=external-link href=http://activemq.apache.org/maven/apidocs/org/apache/activemq/ActiveMQConnection.html;ActiveMQConnection/a or a shape=rect class=external-link href=http://activemq.apache.org/maven/apidocs/org/apache/activemq/ActiveMQConnectionFactory.html;ActiveMQConnectionFactory/a objects themselves via the bean properties or using the following URI syntax./p - -h3 id=ConnectionConfigurationURI-ExampleExample/h3 - -pYou set the property called jms.$PROPERTY on a regular connection URI. For example you can set the brokerURL on your ActiveMQConnectionFactory to the following value to enable a shape=rect href=async-sends.htmlAsync Sends/a/p - -div class=code panel pdl style=border-width: 1px;div class=codeContent panelContent pdl -script class=theme: Default; brush: java; gutter: false type=syntaxhighlighter![CDATA[ -tcp://localhost:61616?jms.useAsyncSend=true +div class=wiki-content maincontenth2 id=ConnectionConfigurationURI-ConnectionConfigurationURIConnection Configuration URI/h2pAn Apache ActiveMQ connection can be configured by explicitly setting properties on the a shape=rect class=external-link href=http://activemq.apache.org/maven/apidocs/org/apache/activemq/ActiveMQConnection.html;ActiveMQConnection/a or a shape=rect class=external-link href=http://activemq.apache.org/maven/apidocs/org/apache/activemq/ActiveMQConnectionFactory.html;ActiveMQConnectionFactory/a objects themselves via the bean properties or using the following URI syntax./ph3 id=ConnectionConfigurationURI-ExampleExample/h3pYou set the property called jms.$PROPERTY on a regular connection URI. For example you can set the brokerURL on your ActiveMQConnectionFactory to the following value to enable a shape=rect href=async-sends.htmlAsync Sends/a/pdiv class=code panel pdl style=border-width: 1px;div class=codeCon tent panelContent pdl +script class=theme: Default; brush: java; gutter: false type=syntaxhighlighter![CDATA[tcp://localhost:61616?jms.useAsyncSend=true ]]/script -/div/div - -h3 id=ConnectionConfigurationURI-ConnectionOptionsConnection Options/h3 - -pThe following options should be prefixed with strongjms./strong when used on a URI when connecting to a broker./p -div class=table-wraptable class=confluenceTabletbodytrth colspan=1 rowspan=1 class=confluenceThp Option Name /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 alwaysSessionAsync /p/tdtd colspan=1 rowspan=1 class=confluenceTdp true /p/tdtd colspan=1 rowspan=1 class=confluenceTdp If this flag is set then a separate thread is used for dispatching messages for each Session in the Connection. However, a separate thread is always used if there is more than one session, or the session isn't in auto acknowledge or dups ok mode /p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdp clientID /p/tdtd colspan=1 rowspan=1 class=confluenceTdp null /p/tdtd colspan=1 rowspan=1 class=confluenceTdp Sets the JMS clientID to use for the conne ction /p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdp closeTimeout /p/tdtd colspan=1 rowspan=1 class=confluenceTdp 15000ms /p/tdtd colspan=1 rowspan=1 class=confluenceTdp Sets the timeout before a close is considered complete. Normally a close() on a connection waits for confirmation from the broker; this allows that operation to timeout to save the client hanging if there is no broker. /p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdp copyMessageOnSend /p/tdtd colspan=1 rowspan=1 class=confluenceTdp true /p/tdtd colspan=1 rowspan=1 class=confluenceTdp Should a JMS message be copied to a new JMS Message object as part of the send() method in JMS. This is enabled by default to be compliant with the JMS specification. You can disable it if you do not mutate JMS messages after they
[6/6] activemq-artemis git commit: This closes #26 error prone errors and fixes on activemq5-tests
This closes #26 error prone errors and fixes on activemq5-tests Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/29d59e97 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/29d59e97 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/29d59e97 Branch: refs/heads/master Commit: 29d59e970b0fbbe48533578875f5e59279351ccd Parents: 145fc7f 4dd5408 Author: Clebert Suconic clebertsuco...@apache.org Authored: Fri Jun 12 10:38:24 2015 -0400 Committer: Clebert Suconic clebertsuco...@apache.org Committed: Fri Jun 12 10:38:24 2015 -0400 -- tests/activemq5-unit-tests/pom.xml | 2 +- .../artemiswrapper/ArtemisBrokerWrapper.java| 2 +- .../JmsCreateConsumerInOnMessageTest.java | 6 +- .../activemq/JmsMultipleClientsTestSupport.java | 4 +- .../activemq/LargeMessageTestSupport.java | 8 +- .../activemq/OnePrefetchAsyncConsumerTest.java | 2 +- .../DbRestartJDBCQueueMasterSlaveLeaseTest.java | 2 +- .../broker/policy/AbortSlowConsumer1Test.java | 4 +- .../activemq/broker/region/QueuePurgeTest.java | 2 +- .../region/QueueResendDuringShutdownTest.java | 4 +- .../cursors/StoreQueueCursorOrderTest.java | 46 .../broker/scheduler/JmsSchedulerTest.java | 8 +- .../org/apache/activemq/bugs/AMQ2149Test.java | 114 ++- .../org/apache/activemq/bugs/AMQ2314Test.java | 2 +- .../org/apache/activemq/bugs/AMQ3779Test.java | 2 +- .../activemq/bugs/AMQ4485LowLimitTest.java | 8 +- ...XBrokersWithNDestsFanoutTransactionTest.java | 4 +- .../org/apache/activemq/bugs/AMQ4607Test.java | 2 +- .../org/apache/activemq/bugs/AMQ4636Test.java | 4 +- .../activemq/bugs/AMQ5266SingleDestTest.java| 2 +- .../org/apache/activemq/bugs/CraigsBugTest.java | 7 +- .../bugs/TrapMessageInJDBCStoreTest.java| 4 +- .../activemq/bugs/amq1974/TryJmsClient.java | 5 +- .../activemq/bugs/amq1974/TryJmsManager.java| 5 +- .../command/ActiveMQStreamMessageTest.java | 2 +- .../command/ActiveMQTextMessageTest.java| 2 +- .../apache/activemq/spring/ConsumerBean.java| 33 +++--- .../apache/activemq/spring/SpringConsumer.java | 8 +- .../store/jdbc/JDBCIOExceptionHandlerTest.java | 12 +- .../store/jdbc/JDBCMessagePriorityTest.java | 2 +- .../store/jdbc/LeaseDatabaseLockerTest.java | 2 +- .../store/kahadb/KahaDBFastEnqueueTest.java | 6 +- .../activemq/store/kahadb/plist/PListTest.java | 10 +- .../activemq/streams/JMSInputStreamTest.java| 2 +- .../activemq/transport/StubTransport.java | 7 +- .../activemq/transport/TopicClusterTest.java| 4 +- .../transport/failover/AMQ1925Test.java | 27 ++--- .../activemq/transport/udp/UdpTestSupport.java | 6 +- .../usecases/BacklogNetworkCrossTalkTest.java | 2 +- .../BrokerQueueNetworkWithDisconnectTest.java | 2 +- .../ConcurrentProducerDurableConsumerTest.java | 16 +-- .../ConcurrentProducerQueueConsumerTest.java| 16 +-- .../DurableSubscriptionOffline4Test.java| 3 +- .../usecases/JdbcDurableSubDupTest.java | 2 +- .../activemq/usecases/MemoryLimitTest.java | 4 +- .../MessageGroupReconnectDistributionTest.java | 4 +- .../usecases/MultiBrokersMultiClientsTest.java | 2 +- .../usecases/NoDuplicateOnTopicNetworkTest.java | 2 +- .../usecases/ReliableReconnectTest.java | 8 +- ...erTempDestDemandSubscriptionCleanupTest.java | 2 +- .../VerifyNetworkConsumersDisconnectTest.java | 2 +- .../org/apache/activemq/util/MessageIdList.java | 32 -- 52 files changed, 234 insertions(+), 235 deletions(-) --
[5/6] activemq-artemis git commit: ARTEMIS-127 Fix Array.toString(), nonatomic update on volatiles
ARTEMIS-127 Fix Array.toString(), nonatomic update on volatiles
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/4dd54080
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/4dd54080
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/4dd54080
Branch: refs/heads/master
Commit: 4dd54080a1e91463ad4b6693fb1e62ad3a81124a
Parents: ae6a2b8
Author: Thiago Kronig thiagokro...@gmail.com
Authored: Fri Jun 12 01:27:54 2015 -0300
Committer: Thiago Kronig thiagokro...@gmail.com
Committed: Fri Jun 12 01:27:54 2015 -0300
--
.../broker/policy/AbortSlowConsumer1Test.java | 4 +-
.../org/apache/activemq/bugs/AMQ2149Test.java | 112 ++-
.../org/apache/activemq/bugs/AMQ3779Test.java | 2 +-
.../command/ActiveMQTextMessageTest.java| 2 +-
.../store/kahadb/KahaDBFastEnqueueTest.java | 4 +-
.../activemq/store/kahadb/plist/PListTest.java | 8 +-
.../activemq/transport/StubTransport.java | 7 +-
.../DurableSubscriptionOffline4Test.java| 3 +-
.../activemq/usecases/MemoryLimitTest.java | 4 +-
9 files changed, 78 insertions(+), 68 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/4dd54080/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/policy/AbortSlowConsumer1Test.java
--
diff --git
a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/policy/AbortSlowConsumer1Test.java
b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/policy/AbortSlowConsumer1Test.java
index e17b362..4368f79 100644
---
a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/policy/AbortSlowConsumer1Test.java
+++
b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/policy/AbortSlowConsumer1Test.java
@@ -82,7 +82,7 @@ public class AbortSlowConsumer1Test extends
AbortSlowConsumerBase {
consumer.close();
TimeUnit.SECONDS.sleep(5);
-assertTrue(no exceptions : + exceptions.toArray(),
exceptions.isEmpty());
+assertTrue(no exceptions : + exceptions, exceptions.isEmpty());
}
@Test(timeout = 60 * 1000)
@@ -99,6 +99,6 @@ public class AbortSlowConsumer1Test extends
AbortSlowConsumerBase {
conn.close();
TimeUnit.SECONDS.sleep(5);
-assertTrue(no exceptions : + exceptions.toArray(),
exceptions.isEmpty());
+assertTrue(no exceptions : + exceptions, exceptions.isEmpty());
}
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/4dd54080/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2149Test.java
--
diff --git
a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2149Test.java
b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2149Test.java
index c28d3ad..f172a91 100644
---
a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2149Test.java
+++
b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2149Test.java
@@ -30,6 +30,7 @@ import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
+import java.util.concurrent.atomic.AtomicLong;
import javax.jms.*;
@@ -65,22 +66,22 @@ public class AMQ2149Test {
private static final String BROKER_CONNECTOR = tcp://localhost:61617;
private static final String DEFAULT_BROKER_URL = failover:(+
BROKER_CONNECTOR
+)?maxReconnectDelay=1000useExponentialBackOff=false;
-
+
private final String SEQ_NUM_PROPERTY = seqNum;
final int MESSAGE_LENGTH_BYTES = 75 * 1024;
final long SLEEP_BETWEEN_SEND_MS = 25;
final int NUM_SENDERS_AND_RECEIVERS = 10;
final Object brokerLock = new Object();
-
+
private static final long DEFAULT_BROKER_STOP_PERIOD = 10 * 1000;
private static final long DEFAULT_NUM_TO_SEND = 1400;
-
+
long brokerStopPeriod = DEFAULT_BROKER_STOP_PERIOD;
long numtoSend = DEFAULT_NUM_TO_SEND;
long sleepBetweenSend = SLEEP_BETWEEN_SEND_MS;
String brokerURL = DEFAULT_BROKER_URL;
-
+
int numBrokerRestarts = 0;
final static int MAX_BROKER_RESTARTS = 4;
BrokerService broker;
@@ -88,15 +89,15 @@ public class AMQ2149Test {
protected File dataDirFile;
final LoggingBrokerPlugin[] plugins = new LoggingBrokerPlugin[]{new
LoggingBrokerPlugin()};
-
-
+
+
public void createBroker(Configurer configurer) throws Exception {
broker = new BrokerService();
configurePersistenceAdapter(broker);
-
+
[4/6] activemq-artemis git commit: ARTEMIS-127 Fix some concurrency idioms for ActimeMQ Tests
ARTEMIS-127 Fix some concurrency idioms for ActimeMQ Tests
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/ae6a2b87
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/ae6a2b87
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/ae6a2b87
Branch: refs/heads/master
Commit: ae6a2b87eaa9325d2437db2ccd5152f6db0d2ad3
Parents: 64ecb95
Author: Thiago Kronig thiagokro...@gmail.com
Authored: Wed Jun 10 20:37:58 2015 -0300
Committer: Thiago Kronig thiagokro...@gmail.com
Committed: Fri Jun 12 00:30:23 2015 -0300
--
.../JmsCreateConsumerInOnMessageTest.java | 6 ++--
.../activemq/JmsMultipleClientsTestSupport.java | 4 +--
.../activemq/LargeMessageTestSupport.java | 8 ++---
.../activemq/OnePrefetchAsyncConsumerTest.java | 2 +-
.../region/QueueResendDuringShutdownTest.java | 4 +--
.../org/apache/activemq/bugs/AMQ2149Test.java | 2 +-
.../org/apache/activemq/bugs/AMQ4607Test.java | 2 +-
.../org/apache/activemq/bugs/CraigsBugTest.java | 7 +++--
.../activemq/bugs/amq1974/TryJmsClient.java | 5 ++-
.../activemq/bugs/amq1974/TryJmsManager.java| 5 ++-
.../apache/activemq/spring/ConsumerBean.java| 33 +++-
.../apache/activemq/spring/SpringConsumer.java | 8 ++---
.../activemq/store/kahadb/plist/PListTest.java | 2 +-
.../activemq/streams/JMSInputStreamTest.java| 2 +-
.../activemq/transport/TopicClusterTest.java| 4 +--
.../transport/failover/AMQ1925Test.java | 27 +---
.../activemq/transport/udp/UdpTestSupport.java | 6 ++--
.../ConcurrentProducerDurableConsumerTest.java | 14 +++--
.../ConcurrentProducerQueueConsumerTest.java| 14 +++--
.../usecases/MultiBrokersMultiClientsTest.java | 2 +-
.../usecases/NoDuplicateOnTopicNetworkTest.java | 2 +-
.../usecases/ReliableReconnectTest.java | 8 ++---
.../VerifyNetworkConsumersDisconnectTest.java | 2 +-
.../org/apache/activemq/util/MessageIdList.java | 32 ---
24 files changed, 95 insertions(+), 106 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/ae6a2b87/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsCreateConsumerInOnMessageTest.java
--
diff --git
a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsCreateConsumerInOnMessageTest.java
b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsCreateConsumerInOnMessageTest.java
index 7a219e2..c0a4f5f 100644
---
a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsCreateConsumerInOnMessageTest.java
+++
b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsCreateConsumerInOnMessageTest.java
@@ -36,7 +36,7 @@ public class JmsCreateConsumerInOnMessageTest extends
TestSupport implements Mes
private MessageConsumer testConsumer;
private MessageProducer producer;
private Topic topic;
-private Object lock = new Object();
+private final Object lock = new Object();
/*
* @see junit.framework.TestCase#setUp()
@@ -71,8 +71,8 @@ public class JmsCreateConsumerInOnMessageTest extends
TestSupport implements Mes
public void testCreateConsumer() throws Exception {
Message msg = super.createMessage();
producer.send(msg);
-if (testConsumer == null) {
-synchronized (lock) {
+synchronized (lock) {
+while(testConsumer == null) {
lock.wait(3000);
}
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/ae6a2b87/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsMultipleClientsTestSupport.java
--
diff --git
a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsMultipleClientsTestSupport.java
b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsMultipleClientsTestSupport.java
index 5eaab8d..5c73a6e 100644
---
a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsMultipleClientsTestSupport.java
+++
b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsMultipleClientsTestSupport.java
@@ -83,8 +83,6 @@ public class JmsMultipleClientsTestSupport {
protected ListConnection connections = Collections.synchronizedList(new
ArrayListConnection());
protected MessageIdList allMessagesList = new MessageIdList();
-private AtomicInteger producerLock;
-
protected void startProducers(Destination dest, int msgCount) throws
Exception {
startProducers(createConnectionFactory(), dest, msgCount);
}
@@ -92,7 +90,7 @@ public class JmsMultipleClientsTestSupport {
protected void startProducers(final
[3/6] activemq-artemis git commit: ARTEMIS-127 Use L as suffix for long constants
ARTEMIS-127 Use L as suffix for long constants
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/64ecb956
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/64ecb956
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/64ecb956
Branch: refs/heads/master
Commit: 64ecb9565dea42c7381e9a70a08339cafff7c960
Parents: aab34e5
Author: Thiago Kronig thiagokro...@gmail.com
Authored: Wed Jun 10 13:24:37 2015 -0300
Committer: Thiago Kronig thiagokro...@gmail.com
Committed: Thu Jun 11 23:58:14 2015 -0300
--
.../DbRestartJDBCQueueMasterSlaveLeaseTest.java | 2 +-
.../activemq/broker/region/QueuePurgeTest.java | 2 +-
.../cursors/StoreQueueCursorOrderTest.java | 46 ++--
.../broker/scheduler/JmsSchedulerTest.java | 8 ++--
.../org/apache/activemq/bugs/AMQ2314Test.java | 2 +-
.../activemq/bugs/AMQ4485LowLimitTest.java | 8 ++--
...XBrokersWithNDestsFanoutTransactionTest.java | 4 +-
.../org/apache/activemq/bugs/AMQ4636Test.java | 4 +-
.../activemq/bugs/AMQ5266SingleDestTest.java| 2 +-
.../bugs/TrapMessageInJDBCStoreTest.java| 4 +-
.../command/ActiveMQStreamMessageTest.java | 2 +-
.../store/jdbc/JDBCIOExceptionHandlerTest.java | 12 ++---
.../store/jdbc/JDBCMessagePriorityTest.java | 2 +-
.../store/jdbc/LeaseDatabaseLockerTest.java | 2 +-
.../store/kahadb/KahaDBFastEnqueueTest.java | 2 +-
.../usecases/BacklogNetworkCrossTalkTest.java | 2 +-
.../BrokerQueueNetworkWithDisconnectTest.java | 2 +-
.../ConcurrentProducerDurableConsumerTest.java | 2 +-
.../ConcurrentProducerQueueConsumerTest.java| 2 +-
.../usecases/JdbcDurableSubDupTest.java | 2 +-
.../MessageGroupReconnectDistributionTest.java | 4 +-
...erTempDestDemandSubscriptionCleanupTest.java | 2 +-
22 files changed, 59 insertions(+), 59 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/64ecb956/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/ft/DbRestartJDBCQueueMasterSlaveLeaseTest.java
--
diff --git
a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/ft/DbRestartJDBCQueueMasterSlaveLeaseTest.java
b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/ft/DbRestartJDBCQueueMasterSlaveLeaseTest.java
index cf4929a..422b5ff 100644
---
a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/ft/DbRestartJDBCQueueMasterSlaveLeaseTest.java
+++
b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/ft/DbRestartJDBCQueueMasterSlaveLeaseTest.java
@@ -43,7 +43,7 @@ public class DbRestartJDBCQueueMasterSlaveLeaseTest extends
DbRestartJDBCQueueMa
LeaseLockerIOExceptionHandler ioExceptionHandler = new
LeaseLockerIOExceptionHandler();
ioExceptionHandler.setIgnoreSQLExceptions(false);
ioExceptionHandler.setStopStartConnectors(false);
-ioExceptionHandler.setResumeCheckSleepPeriod(500l);
+ioExceptionHandler.setResumeCheckSleepPeriod(500L);
brokerService.setIoExceptionHandler(ioExceptionHandler);
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/64ecb956/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java
--
diff --git
a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java
b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java
index 9120937..d02085a 100644
---
a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java
+++
b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java
@@ -67,7 +67,7 @@ public class QueuePurgeTest extends CombinationTestSupport {
broker.setDataDirectoryFile(testDataDir);
broker.setUseJmx(true);
broker.setDeleteAllMessagesOnStartup(true);
-broker.getSystemUsage().getMemoryUsage().setLimit(1024l*1024*64);
+broker.getSystemUsage().getMemoryUsage().setLimit(1024L*1024*64);
KahaDBPersistenceAdapter persistenceAdapter = new
KahaDBPersistenceAdapter();
persistenceAdapter.setDirectory(new File(testDataDir, kahadb));
broker.setPersistenceAdapter(persistenceAdapter);
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/64ecb956/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/StoreQueueCursorOrderTest.java
--
diff --git
