Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove redundant type arguments

This commit is contained in:
Ville Skyttä 2015-12-21 17:32:24 +02:00 committed by Clebert Suconic
parent 826da3b095
commit 2cb74839f9
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/extra-tests/src/test/java/org/apache/activemq/artemis/tests/extras/byteman/ClusteredBridgeReconnectTest.java
View File

@ -44,7 +44,7 @@ import org.junit.runner.RunWith;
@RunWith(BMUnitRunner.class)
public class ClusteredBridgeReconnectTest extends ClusterTestBase {
static ThreadLocal<Boolean> inConnect = new ThreadLocal<Boolean>();
static ThreadLocal<Boolean> inConnect = new ThreadLocal<>();
public static void enterConnect() {
inConnect.set(Boolean.TRUE);

2
tests/extra-tests/src/test/java/org/apache/activemq/artemis/tests/extras/jms/ra/MDBMultipleHandlersServerDisconnectTest.java
View File

@ -366,7 +366,7 @@ public class MDBMultipleHandlersServerDisconnectTest extends ActiveMQRATestBase
private List<ServerSession> lookupServerSessions(String parameter, int numberOfSessions) {
long timeout = System.currentTimeMillis() + 50000;
List<ServerSession> serverSessions = new LinkedList<ServerSession>();
List<ServerSession> serverSessions = new LinkedList<>();
do {
if (!serverSessions.isEmpty()) {
System.err.println("Retry on serverSessions!!! currently with " + serverSessions.size());

2
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java
View File

@ -1305,7 +1305,7 @@ public class QueueControlTest extends ManagementTestBase {
ClientConsumer cons = session.createConsumer(queue);
session.start();
LinkedList<ClientMessage> msgs = new LinkedList<ClientMessage>();
LinkedList<ClientMessage> msgs = new LinkedList<>();
for (int i = 0; i < 50; i++) {
ClientMessage msg = cons.receive(1000);
msgs.add(msg);