Add missing @Overrides

This commit is contained in:
Ville Skyttä 2016-09-27 14:36:54 +03:00
parent 78d8ddffbe
commit 447d7840aa
10 changed files with 14 additions and 0 deletions

View File

@ -109,6 +109,7 @@ public class ActiveMQConsumerResource extends AbstractActiveMQClientResource {
}
}
@Override
public boolean isAutoCreateQueue() {
return autoCreateQueue;
}
@ -118,6 +119,7 @@ public class ActiveMQConsumerResource extends AbstractActiveMQClientResource {
*
* @param autoCreateQueue
*/
@Override
public void setAutoCreateQueue(boolean autoCreateQueue) {
this.autoCreateQueue = autoCreateQueue;
}

View File

@ -255,6 +255,7 @@ public class UnmodifiableLink implements Link {
return link.detached();
}
@Override
public Record attachments() {
return link.attachments();
}

View File

@ -48,6 +48,7 @@ public class AmqpClientTestSupport extends ActiveMQTestBase {
@Before
@Override
public void setUp() throws Exception {
super.setUp();
server = createServer(true, true);
@ -55,6 +56,7 @@ public class AmqpClientTestSupport extends ActiveMQTestBase {
}
@After
@Override
public void tearDown() throws Exception {
super.tearDown();

View File

@ -38,6 +38,7 @@ public class DestinationCommandTest extends JMSTestBase {
private ByteArrayOutputStream error;
@Before
@Override
public void setUp() throws Exception {
super.setUp();
this.output = new ByteArrayOutputStream(1024);

View File

@ -35,6 +35,7 @@ import org.junit.Test;
public class ExpireWhileLoadBalanceTest extends ClusterTestBase {
@Before
@Override
public void setUp() throws Exception {
super.setUp();

View File

@ -117,6 +117,7 @@ public class GlobalPagingTest extends PagingTest {
serverImpl.getMonitor().tick();
Thread t = new Thread() {
@Override
public void run() {
try {
sendFewMessages(numberOfMessages, session, producer, body);

View File

@ -34,6 +34,7 @@ public class ProtonMaxFrameSizeTest extends ProtonTestBase {
private static final int FRAME_SIZE = 512;
@Override
protected void configureAmqp(Map<String, Object> params) {
params.put("maxFrameSize", FRAME_SIZE);
}

View File

@ -54,6 +54,7 @@ public class ProtonPubSubTest extends ProtonTestBase {
private Connection connection;
private JmsConnectionFactory factory;
@Override
protected void configureAmqp(Map<String, Object> params) {
params.put("pubSubPrefix", prefix);
}

View File

@ -44,12 +44,14 @@ public class RestDeserializationTest extends RestTestBase {
private RestAMQConnection restConnection;
@Before
@Override
public void setUp() throws Exception {
super.setUp();
createJettyServer("localhost", 12345);
}
@After
@Override
public void tearDown() throws Exception {
if (restConnection != null) {
restConnection.close();

View File

@ -42,12 +42,14 @@ public class RestTestBase extends JMSTestBase {
protected HandlerList handlers;
@Before
@Override
public void setUp() throws Exception {
super.setUp();
webAppDir = testFolder.newFolder("test-apps");
}
@After
@Override
public void tearDown() throws Exception {
if (server != null) {
try {