This closes #708
This commit is contained in:
commit
6b0c089017
|
@ -217,7 +217,6 @@ public class URISupport {
|
||||||
return uri;
|
return uri;
|
||||||
}
|
}
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
private static Map<String, String> emptyMap() {
|
private static Map<String, String> emptyMap() {
|
||||||
return Collections.EMPTY_MAP;
|
return Collections.EMPTY_MAP;
|
||||||
}
|
}
|
||||||
|
|
|
@ -97,7 +97,7 @@ e.g.<br><br>
|
||||||
|
|
||||||
$ ./artemis run --config xml:/home/artemis/bootstrap.xml<br><br>
|
$ ./artemis run --config xml:/home/artemis/bootstrap.xml<br><br>
|
||||||
|
|
||||||
It is possible to configure run time paramters in the artemis.conf (artemis.conf.bat for windows) file under the "bin" directory of the broker directory.
|
It is possible to configure run time parameters in the artemis.conf (artemis.conf.bat for windows) file under the "bin" directory of the broker directory.
|
||||||
|
|
||||||
<h2>Stopping the Broker</h2>
|
<h2>Stopping the Broker</h2>
|
||||||
|
|
||||||
|
|
|
@ -48,6 +48,7 @@ public final class LibaioFile<Callback extends SubmitInfo> implements AutoClosea
|
||||||
return LibaioContext.lock(fd);
|
return LibaioContext.lock(fd);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
public void close() throws IOException {
|
public void close() throws IOException {
|
||||||
open = false;
|
open = false;
|
||||||
LibaioContext.close(fd);
|
LibaioContext.close(fd);
|
||||||
|
|
|
@ -108,7 +108,6 @@ public abstract class InboundTransformer {
|
||||||
this.vendor = vendor;
|
this.vendor = vendor;
|
||||||
}
|
}
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
protected void populateMessage(Message jms, org.apache.qpid.proton.message.Message amqp) throws Exception {
|
protected void populateMessage(Message jms, org.apache.qpid.proton.message.Message amqp) throws Exception {
|
||||||
Header header = amqp.getHeader();
|
Header header = amqp.getHeader();
|
||||||
if (header == null) {
|
if (header == null) {
|
||||||
|
|
|
@ -2367,6 +2367,7 @@ public class ActiveMQServerImpl implements ActiveMQServer {
|
||||||
this.server = server;
|
this.server = server;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
public void run() {
|
public void run() {
|
||||||
try {
|
try {
|
||||||
URL url = server.getConfiguration().getConfigurationUrl();
|
URL url = server.getConfiguration().getConfigurationUrl();
|
||||||
|
|
|
@ -36,7 +36,7 @@ under the License.
|
||||||
This listener will then be called by ActiveMQ Artemis in the event that connection failure is detected.</p>
|
This listener will then be called by ActiveMQ Artemis in the event that connection failure is detected.</p>
|
||||||
<p>User code in the ExceptionListener can then recreate any JMS Connection, Session, etc on another node and the application
|
<p>User code in the ExceptionListener can then recreate any JMS Connection, Session, etc on another node and the application
|
||||||
can continue.</p>
|
can continue.</p>
|
||||||
<p>Application-Layer failover is an alternative approach to High Availabilty (HA).</p>
|
<p>Application-Layer failover is an alternative approach to High Availability (HA).</p>
|
||||||
<p>Application-Layer failover differs from automatic failover in that some client side coding is required in order
|
<p>Application-Layer failover differs from automatic failover in that some client side coding is required in order
|
||||||
to implement this. Also, with Application-Layer failover, since the old Session object dies and a new is created, any uncommitted
|
to implement this. Also, with Application-Layer failover, since the old Session object dies and a new is created, any uncommitted
|
||||||
work in the old Session will be lost, and any unacknowledged messages might be redelivered.</p>
|
work in the old Session will be lost, and any unacknowledged messages might be redelivered.</p>
|
||||||
|
|
|
@ -48,7 +48,7 @@ under the License.
|
||||||
</ol>
|
</ol>
|
||||||
<h3>JMS Bridge Configuration</h3>
|
<h3>JMS Bridge Configuration</h3>
|
||||||
<p>The JMS Bridge is a <abbr title="Plain Old Java Object">POJO</abbr> that we configure with both source and target
|
<p>The JMS Bridge is a <abbr title="Plain Old Java Object">POJO</abbr> that we configure with both source and target
|
||||||
JNDI configurations. In the actual example we are programatically creating the Bridge, however the following section
|
JNDI configurations. In the actual example we are programmatically creating the Bridge, however the following section
|
||||||
describes how you would do this if you wanted to deploy with an actual ActiveMQ Artemis server via the activemq-beans.xml.
|
describes how you would do this if you wanted to deploy with an actual ActiveMQ Artemis server via the activemq-beans.xml.
|
||||||
|
|
||||||
<h4>Configuring the Bridge with the JBoss Microcontainer</h4>
|
<h4>Configuring the Bridge with the JBoss Microcontainer</h4>
|
||||||
|
|
|
@ -91,7 +91,6 @@ public class FailoverConsumerOutstandingCommitTest extends OpenwireArtemisBaseTe
|
||||||
doTestFailoverConsumerDups(true);
|
doTestFailoverConsumerDups(true);
|
||||||
}
|
}
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
public void doTestFailoverConsumerDups(final boolean watchTopicAdvisories) throws Exception {
|
public void doTestFailoverConsumerDups(final boolean watchTopicAdvisories) throws Exception {
|
||||||
|
|
||||||
server = createBroker();
|
server = createBroker();
|
||||||
|
@ -204,7 +203,6 @@ public class FailoverConsumerOutstandingCommitTest extends OpenwireArtemisBaseTe
|
||||||
doTestFailoverConsumerOutstandingSendTx(true);
|
doTestFailoverConsumerOutstandingSendTx(true);
|
||||||
}
|
}
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
public void doTestFailoverConsumerOutstandingSendTx(final boolean doActualBrokerCommit) throws Exception {
|
public void doTestFailoverConsumerOutstandingSendTx(final boolean doActualBrokerCommit) throws Exception {
|
||||||
final boolean watchTopicAdvisories = true;
|
final boolean watchTopicAdvisories = true;
|
||||||
server = createBroker();
|
server = createBroker();
|
||||||
|
|
|
@ -118,7 +118,6 @@ public class FailoverConsumerUnconsumedTest extends OpenwireArtemisBaseTest {
|
||||||
doTestFailoverConsumerDups(false);
|
doTestFailoverConsumerDups(false);
|
||||||
}
|
}
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
@Test
|
@Test
|
||||||
@BMRules(
|
@BMRules(
|
||||||
rules = {
|
rules = {
|
||||||
|
@ -231,7 +230,6 @@ public class FailoverConsumerUnconsumedTest extends OpenwireArtemisBaseTest {
|
||||||
connection.close();
|
connection.close();
|
||||||
}
|
}
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
public void doTestFailoverConsumerDups(final boolean watchTopicAdvisories) throws Exception {
|
public void doTestFailoverConsumerDups(final boolean watchTopicAdvisories) throws Exception {
|
||||||
|
|
||||||
maxConsumers = 4;
|
maxConsumers = 4;
|
||||||
|
|
|
@ -86,7 +86,6 @@ public class FailoverDuplicateTest extends OpenwireArtemisBaseTest {
|
||||||
factory.setOptimizeAcknowledge(true);
|
factory.setOptimizeAcknowledge(true);
|
||||||
}
|
}
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
@Test
|
@Test
|
||||||
@BMRules(
|
@BMRules(
|
||||||
rules = {
|
rules = {
|
||||||
|
|
|
@ -71,7 +71,6 @@ public class FailoverPrefetchZeroTest extends OpenwireArtemisBaseTest {
|
||||||
broker.start();
|
broker.start();
|
||||||
}
|
}
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
@Test
|
@Test
|
||||||
@BMRules(
|
@BMRules(
|
||||||
rules = {@BMRule(
|
rules = {@BMRule(
|
||||||
|
|
|
@ -220,7 +220,6 @@ public class FailoverTransactionTest extends OpenwireArtemisBaseTest {
|
||||||
connection.close();
|
connection.close();
|
||||||
}
|
}
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
@Test
|
@Test
|
||||||
public void testFailoverCommitReplyLostWithDestinationPathSeparator() throws Exception {
|
public void testFailoverCommitReplyLostWithDestinationPathSeparator() throws Exception {
|
||||||
//the original test validates destinations using forward slash (/) as
|
//the original test validates destinations using forward slash (/) as
|
||||||
|
@ -230,7 +229,6 @@ public class FailoverTransactionTest extends OpenwireArtemisBaseTest {
|
||||||
//Artemis doesn't support "/" so far and this test doesn't make sense therefore.
|
//Artemis doesn't support "/" so far and this test doesn't make sense therefore.
|
||||||
}
|
}
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
@Test
|
@Test
|
||||||
@BMRules(
|
@BMRules(
|
||||||
rules = {
|
rules = {
|
||||||
|
@ -316,7 +314,6 @@ public class FailoverTransactionTest extends OpenwireArtemisBaseTest {
|
||||||
connection.close();
|
connection.close();
|
||||||
}
|
}
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
@Test
|
@Test
|
||||||
@BMRules(
|
@BMRules(
|
||||||
rules = {
|
rules = {
|
||||||
|
@ -550,7 +547,6 @@ public class FailoverTransactionTest extends OpenwireArtemisBaseTest {
|
||||||
// }
|
// }
|
||||||
// }
|
// }
|
||||||
//
|
//
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
public void doTestFailoverConsumerAckLost(final int pauseSeconds) throws Exception {
|
public void doTestFailoverConsumerAckLost(final int pauseSeconds) throws Exception {
|
||||||
broker = createBroker();
|
broker = createBroker();
|
||||||
broker.start();
|
broker.start();
|
||||||
|
|
|
@ -85,7 +85,6 @@ public class BrokerQueueNetworkWithDisconnectTest extends JmsMultipleBrokersTest
|
||||||
" must be received, duplicates are expected, count=" + msgs.getMessageCount(), MESSAGE_COUNT <= msgs.getMessageCount());
|
" must be received, duplicates are expected, count=" + msgs.getMessageCount(), MESSAGE_COUNT <= msgs.getMessageCount());
|
||||||
}
|
}
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
public void testNoStuckConnectionsWithTransportDisconnect() throws Exception {
|
public void testNoStuckConnectionsWithTransportDisconnect() throws Exception {
|
||||||
inactiveDuration = 60000L;
|
inactiveDuration = 60000L;
|
||||||
useDuplexNetworkBridge = true;
|
useDuplexNetworkBridge = true;
|
||||||
|
|
|
@ -366,7 +366,6 @@ public class TwoBrokerQueueClientsReconnectTest extends JmsMultipleBrokersTestSu
|
||||||
assertEquals("Client for " + broker2 + " should have received 50% of the messages.", (int) (MESSAGE_COUNT * 0.50), msgsClient2);
|
assertEquals("Client for " + broker2 + " should have received 50% of the messages.", (int) (MESSAGE_COUNT * 0.50), msgsClient2);
|
||||||
}
|
}
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
public void testDuplicateSend() throws Exception {
|
public void testDuplicateSend() throws Exception {
|
||||||
broker1 = "BrokerA";
|
broker1 = "BrokerA";
|
||||||
broker2 = "BrokerB";
|
broker2 = "BrokerB";
|
||||||
|
@ -441,7 +440,6 @@ public class TwoBrokerQueueClientsReconnectTest extends JmsMultipleBrokersTestSu
|
||||||
}));
|
}));
|
||||||
}
|
}
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
public void testDuplicateSendWithNoAuditEnqueueCountStat() throws Exception {
|
public void testDuplicateSendWithNoAuditEnqueueCountStat() throws Exception {
|
||||||
broker1 = "BrokerA";
|
broker1 = "BrokerA";
|
||||||
broker2 = "BrokerB";
|
broker2 = "BrokerB";
|
||||||
|
|
Loading…
Reference in New Issue