Remove unnecessary @SuppressWarnings("unchecked")
This commit is contained in:
parent
b863219959
commit
330c65ba35
|
@ -217,7 +217,6 @@ public class URISupport {
|
|||
return uri;
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
private static Map<String, String> emptyMap() {
|
||||
return Collections.EMPTY_MAP;
|
||||
}
|
||||
|
|
|
@ -108,7 +108,6 @@ public abstract class InboundTransformer {
|
|||
this.vendor = vendor;
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
protected void populateMessage(Message jms, org.apache.qpid.proton.message.Message amqp) throws Exception {
|
||||
Header header = amqp.getHeader();
|
||||
if (header == null) {
|
||||
|
|
|
@ -91,7 +91,6 @@ public class FailoverConsumerOutstandingCommitTest extends OpenwireArtemisBaseTe
|
|||
doTestFailoverConsumerDups(true);
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
public void doTestFailoverConsumerDups(final boolean watchTopicAdvisories) throws Exception {
|
||||
|
||||
server = createBroker();
|
||||
|
@ -204,7 +203,6 @@ public class FailoverConsumerOutstandingCommitTest extends OpenwireArtemisBaseTe
|
|||
doTestFailoverConsumerOutstandingSendTx(true);
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
public void doTestFailoverConsumerOutstandingSendTx(final boolean doActualBrokerCommit) throws Exception {
|
||||
final boolean watchTopicAdvisories = true;
|
||||
server = createBroker();
|
||||
|
|
|
@ -118,7 +118,6 @@ public class FailoverConsumerUnconsumedTest extends OpenwireArtemisBaseTest {
|
|||
doTestFailoverConsumerDups(false);
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
@Test
|
||||
@BMRules(
|
||||
rules = {
|
||||
|
@ -231,7 +230,6 @@ public class FailoverConsumerUnconsumedTest extends OpenwireArtemisBaseTest {
|
|||
connection.close();
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
public void doTestFailoverConsumerDups(final boolean watchTopicAdvisories) throws Exception {
|
||||
|
||||
maxConsumers = 4;
|
||||
|
|
|
@ -86,7 +86,6 @@ public class FailoverDuplicateTest extends OpenwireArtemisBaseTest {
|
|||
factory.setOptimizeAcknowledge(true);
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
@Test
|
||||
@BMRules(
|
||||
rules = {
|
||||
|
|
|
@ -71,7 +71,6 @@ public class FailoverPrefetchZeroTest extends OpenwireArtemisBaseTest {
|
|||
broker.start();
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
@Test
|
||||
@BMRules(
|
||||
rules = {@BMRule(
|
||||
|
|
|
@ -220,7 +220,6 @@ public class FailoverTransactionTest extends OpenwireArtemisBaseTest {
|
|||
connection.close();
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
@Test
|
||||
public void testFailoverCommitReplyLostWithDestinationPathSeparator() throws Exception {
|
||||
//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.
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
@Test
|
||||
@BMRules(
|
||||
rules = {
|
||||
|
@ -316,7 +314,6 @@ public class FailoverTransactionTest extends OpenwireArtemisBaseTest {
|
|||
connection.close();
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
@Test
|
||||
@BMRules(
|
||||
rules = {
|
||||
|
@ -550,7 +547,6 @@ public class FailoverTransactionTest extends OpenwireArtemisBaseTest {
|
|||
// }
|
||||
// }
|
||||
//
|
||||
@SuppressWarnings("unchecked")
|
||||
public void doTestFailoverConsumerAckLost(final int pauseSeconds) throws Exception {
|
||||
broker = createBroker();
|
||||
broker.start();
|
||||
|
|
|
@ -85,7 +85,6 @@ public class BrokerQueueNetworkWithDisconnectTest extends JmsMultipleBrokersTest
|
|||
" must be received, duplicates are expected, count=" + msgs.getMessageCount(), MESSAGE_COUNT <= msgs.getMessageCount());
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
public void testNoStuckConnectionsWithTransportDisconnect() throws Exception {
|
||||
inactiveDuration = 60000L;
|
||||
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);
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
public void testDuplicateSend() throws Exception {
|
||||
broker1 = "BrokerA";
|
||||
broker2 = "BrokerB";
|
||||
|
@ -441,7 +440,6 @@ public class TwoBrokerQueueClientsReconnectTest extends JmsMultipleBrokersTestSu
|
|||
}));
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
public void testDuplicateSendWithNoAuditEnqueueCountStat() throws Exception {
|
||||
broker1 = "BrokerA";
|
||||
broker2 = "BrokerB";
|
||||
|
|
Loading…
Reference in New Issue