ARTEMIS-3538 Removing some extra // ----
This commit is contained in:
parent
6de637259b
commit
657e4bf842
|
@ -105,8 +105,6 @@ public class ConcurrentHashSetTest extends Assert {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// TestCase overrides --------------------------------------------
|
|
||||||
|
|
||||||
@Before
|
@Before
|
||||||
public void setUp() throws Exception {
|
public void setUp() throws Exception {
|
||||||
set = new ConcurrentHashSet<>();
|
set = new ConcurrentHashSet<>();
|
||||||
|
|
|
@ -322,8 +322,6 @@ public class ActiveMQBytesMessage extends ActiveMQMessage implements BytesMessag
|
||||||
bodyLength = message.getBodySize();
|
bodyLength = message.getBodySize();
|
||||||
}
|
}
|
||||||
|
|
||||||
// ActiveMQRAMessage overrides ----------------------------------------
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void clearBody() throws JMSException {
|
public void clearBody() throws JMSException {
|
||||||
super.clearBody();
|
super.clearBody();
|
||||||
|
|
|
@ -301,8 +301,6 @@ public class ActiveMQMapMessage extends ActiveMQMessage implements MapMessage {
|
||||||
return map.containsProperty(new SimpleString(name));
|
return map.containsProperty(new SimpleString(name));
|
||||||
}
|
}
|
||||||
|
|
||||||
// ActiveMQRAMessage overrides ----------------------------------------
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void clearBody() throws JMSException {
|
public void clearBody() throws JMSException {
|
||||||
super.clearBody();
|
super.clearBody();
|
||||||
|
|
|
@ -341,8 +341,6 @@ public class ActiveMQStreamMessage extends ActiveMQMessage implements StreamMess
|
||||||
getBuffer().resetReaderIndex();
|
getBuffer().resetReaderIndex();
|
||||||
}
|
}
|
||||||
|
|
||||||
// ActiveMQRAMessage overrides ----------------------------------------
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void clearBody() throws JMSException {
|
public void clearBody() throws JMSException {
|
||||||
super.clearBody();
|
super.clearBody();
|
||||||
|
|
|
@ -327,8 +327,6 @@ public final class JMSBridgeImpl implements JMSBridge {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// ActiveMQComponent overrides --------------------------------------------------
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public JMSBridgeImpl setBridgeName(String name) {
|
public JMSBridgeImpl setBridgeName(String name) {
|
||||||
this.bridgeName = name;
|
this.bridgeName = name;
|
||||||
|
|
|
@ -305,8 +305,6 @@ public final class CoreStreamMessageWrapper extends CoreMessageWrapper {
|
||||||
getWriteBodyBuffer().resetReaderIndex();
|
getWriteBodyBuffer().resetReaderIndex();
|
||||||
}
|
}
|
||||||
|
|
||||||
// ActiveMQRAMessage overrides ----------------------------------------
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void clearBody() {
|
public void clearBody() {
|
||||||
super.clearBody();
|
super.clearBody();
|
||||||
|
|
|
@ -177,8 +177,6 @@ public class AmqpTransactionCoordinator extends AmqpAbstractResource<Sender> {
|
||||||
sendTxCommand(message);
|
sendTxCommand(message);
|
||||||
}
|
}
|
||||||
|
|
||||||
//----- Base class overrides ---------------------------------------------//
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void remotelyClosed(AmqpConnection connection) {
|
public void remotelyClosed(AmqpConnection connection) {
|
||||||
|
|
||||||
|
|
|
@ -58,8 +58,6 @@ public class XATest extends JMSTestBase {
|
||||||
protected Queue queue1;
|
protected Queue queue1;
|
||||||
|
|
||||||
|
|
||||||
// TestCase overrides -------------------------------------------
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@Before
|
@Before
|
||||||
public void setUp() throws Exception {
|
public void setUp() throws Exception {
|
||||||
|
|
|
@ -47,11 +47,6 @@ public class FloodServerTest extends ActiveMQTestBase {
|
||||||
private final String topicName = "my-topic";
|
private final String topicName = "my-topic";
|
||||||
|
|
||||||
|
|
||||||
// TestCase overrides -------------------------------------------
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@Before
|
@Before
|
||||||
public void setUp() throws Exception {
|
public void setUp() throws Exception {
|
||||||
|
|
|
@ -63,13 +63,6 @@ public class JMSClusteredTestBase extends ActiveMQTestBase {
|
||||||
|
|
||||||
protected static final int MAX_HOPS = 1;
|
protected static final int MAX_HOPS = 1;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
// TestCase overrides -------------------------------------------
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @throws Exception
|
* @throws Exception
|
||||||
*/
|
*/
|
||||||
|
@ -180,7 +173,4 @@ public class JMSClusteredTestBase extends ActiveMQTestBase {
|
||||||
|
|
||||||
return configuration;
|
return configuration;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -37,9 +37,6 @@ import org.junit.Test;
|
||||||
public class ConnectionClosedTest extends JMSTestCase {
|
public class ConnectionClosedTest extends JMSTestCase {
|
||||||
|
|
||||||
|
|
||||||
// TestCase overrides -------------------------------------------
|
|
||||||
|
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void testCloseOnce() throws Exception {
|
public void testCloseOnce() throws Exception {
|
||||||
Connection conn = createConnection();
|
Connection conn = createConnection();
|
||||||
|
|
|
@ -39,9 +39,6 @@ public class ConnectionTest extends JMSTestCase {
|
||||||
private static final JmsTestLogger log = JmsTestLogger.LOGGER;
|
private static final JmsTestLogger log = JmsTestLogger.LOGGER;
|
||||||
|
|
||||||
|
|
||||||
// TestCase overrides -------------------------------------------
|
|
||||||
|
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void testManyConnections() throws Exception {
|
public void testManyConnections() throws Exception {
|
||||||
for (int i = 0; i < 100; i++) {
|
for (int i = 0; i < 100; i++) {
|
||||||
|
|
|
@ -35,9 +35,6 @@ import org.junit.Test;
|
||||||
public class MessageWithReadResolveTest extends JMSTestCase {
|
public class MessageWithReadResolveTest extends JMSTestCase {
|
||||||
|
|
||||||
|
|
||||||
// TestCase overrides -------------------------------------------
|
|
||||||
|
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void testSendReceiveMessage() throws Exception {
|
public void testSendReceiveMessage() throws Exception {
|
||||||
Connection conn = createConnection();
|
Connection conn = createConnection();
|
||||||
|
|
|
@ -43,9 +43,4 @@ public class VersionLoaderTest extends ActiveMQTestBase {
|
||||||
Assert.assertEquals(Integer.parseInt(new StringTokenizer(props.getProperty("activemq.version.incrementingVersion"), ",").nextToken()), version.getIncrementingVersion());
|
Assert.assertEquals(Integer.parseInt(new StringTokenizer(props.getProperty("activemq.version.incrementingVersion"), ",").nextToken()), version.getIncrementingVersion());
|
||||||
}
|
}
|
||||||
|
|
||||||
// Z implementation ----------------------------------------------
|
|
||||||
|
|
||||||
// Y overrides ---------------------------------------------------
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue