anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

broker/ServerIntegrationHazelcastHandlerInterceptorTest: code formatter

Browse Source 
used
This commit is contained in:
Andreas Mager
2017-02-01 17:13:42 +01:00
parent 139db5e5b8
commit 5823bdae46
1 changed files with 14 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/test/java/io/moquette/server/ServerIntegrationHazelcastHandlerInterceptorTest.java
+14 -8
View File
@@ -1,3 +1,4 @@
package io.moquette.server; package io.moquette.server;
import io.moquette.BrokerConstants; import io.moquette.BrokerConstants;
@@ -12,16 +13,15 @@ import org.eclipse.paho.client.mqttv3.persist.MqttDefaultFilePersistence;
import org.junit.*; import org.junit.*;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import java.io.File; import java.io.File;
import java.io.IOException; import java.io.IOException;
import java.security.NoSuchAlgorithmException; import java.security.NoSuchAlgorithmException;
import java.sql.SQLException; import java.sql.SQLException;
import java.util.Properties; import java.util.Properties;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
public class ServerIntegrationHazelcastHandlerInterceptorTest{ public class ServerIntegrationHazelcastHandlerInterceptorTest {
private static final Logger LOG = LoggerFactory.getLogger(ServerIntegrationHazelcastHandlerInterceptorTest.class); private static final Logger LOG = LoggerFactory.getLogger(ServerIntegrationHazelcastHandlerInterceptorTest.class);
static MqttClientPersistence s_dataStore; static MqttClientPersistence s_dataStore;
@@ -55,7 +55,9 @@ public class ServerIntegrationHazelcastHandlerInterceptorTest{
private Properties addHazelCastConf(Properties properties, int port, String hazelcastConfigurationFile) { private Properties addHazelCastConf(Properties properties, int port, String hazelcastConfigurationFile) {
properties.put(BrokerConstants.PORT_PROPERTY_NAME, port); properties.put(BrokerConstants.PORT_PROPERTY_NAME, port);
properties.put(BrokerConstants.INTERCEPT_HANDLER_PROPERTY_NAME, HazelcastInterceptHandler.class.getCanonicalName()); properties.put(
BrokerConstants.INTERCEPT_HANDLER_PROPERTY_NAME,
HazelcastInterceptHandler.class.getCanonicalName());
properties.put(BrokerConstants.HAZELCAST_CONFIGURATION, hazelcastConfigurationFile); properties.put(BrokerConstants.HAZELCAST_CONFIGURATION, hazelcastConfigurationFile);
return properties; return properties;
} }
@@ -65,14 +67,18 @@ public class ServerIntegrationHazelcastHandlerInterceptorTest{
String dbPath = IntegrationUtils.localMapDBPath(); String dbPath = IntegrationUtils.localMapDBPath();
IntegrationUtils.cleanPersistenceFile(dbPath); IntegrationUtils.cleanPersistenceFile(dbPath);
final Properties configProps = addHazelCastConf(IntegrationUtils.prepareTestClusterProperties(1883), final Properties configProps = addHazelCastConf(
1883, "config/hazelcast.xml"); IntegrationUtils.prepareTestClusterProperties(1883),
1883,
"config/hazelcast.xml");
m_config_1883 = new MemoryConfig(configProps); m_config_1883 = new MemoryConfig(configProps);
server1883 = startServer(1883, m_config_1883); server1883 = startServer(1883, m_config_1883);
final Properties configProps1884 = addHazelCastConf(IntegrationUtils.prepareTestClusterProperties(1884), final Properties configProps1884 = addHazelCastConf(
1883, "config/hazelcast.xml"); IntegrationUtils.prepareTestClusterProperties(1884),
1883,
"config/hazelcast.xml");
m_config_1884 = new MemoryConfig(configProps1884); m_config_1884 = new MemoryConfig(configProps1884);
server1884 = startServer(1884, m_config_1884); server1884 = startServer(1884, m_config_1884);