Default Broker connection added

Author: sergitoda

pom.xml

@@ -68,7 +68,7 @@
 	</dependencies>
 	<build>
 		<sourceDirectory>src</sourceDirectory>
-		<testSourceDirectory>test</testSourceDirectory>
+		<!-- <testSourceDirectory>test</testSourceDirectory> -->
 		<resources>
 			<resource>
 				<directory>src/main/resources</directory>
@@ -108,7 +108,7 @@
 						<manifest>
 							<addClasspath>true</addClasspath>
 						</manifest>
-					</archive>					
+					</archive>
 				</configuration>
 			</plugin>
 			<plugin>
@@ -117,6 +117,9 @@
 				<version>2.14.1</version>
 				<configuration>
 					<skipTests>true</skipTests>
+					<excludes>
+						<exclude>omq/test/*</exclude>
+					</excludes>
 				</configuration>
 			</plugin>
 		</plugins>

src/main/java/omq/common/broker/Broker.java

@@ -51,6 +51,23 @@ public class Broker {
 	private Map<String, Object> proxies = new Hashtable<String, Object>();
 	private Map<String, Object> multiProxies = new Hashtable<String, Object>();
 
+	public Broker() throws Exception {
+		Properties env = new Properties();
+
+		remoteObjs = new HashMap<String, RemoteObject>();
+		serializer = new Serializer(env);
+		environment = env;
+		connection = OmqConnectionFactory.getNewConnection(env);
+		channel = connection.createChannel();
+		addFaultTolerance();
+		if (!connection.isOpen() || !channel.isOpen()) {
+			if (connection.isOpen()) {
+				connection.close();
+			}
+			throw new InitBrokerException("The connection didn't work");
+		}
+	}
+
 	public Broker(Properties env) throws Exception {
 		// Load log4j configuration
 		// URL log4jResource = Broker.class.getResource("/log4j.xml");

src/main/java/omq/common/util/OmqConnectionFactory.java

@@ -82,12 +82,12 @@ public static Connection getNewWorkingConnection(Properties env) throws Exceptio
 	 */
 	public static Connection getNewConnection(Properties env) throws IOException, KeyManagementException, NoSuchAlgorithmException {
 		// Get login info of rabbitmq
-		String username = env.getProperty(ParameterQueue.USER_NAME);
-		String password = env.getProperty(ParameterQueue.USER_PASS);
+		String username = env.getProperty(ParameterQueue.USER_NAME, ParameterQueue.DEFAULT_USER);
+		String password = env.getProperty(ParameterQueue.USER_PASS, ParameterQueue.DEFAULT_PASS);
 
 		// Get host info of rabbimq (where it is)
-		String host = env.getProperty(ParameterQueue.RABBIT_HOST);
-		int port = Integer.parseInt(env.getProperty(ParameterQueue.RABBIT_PORT));
+		String host = env.getProperty(ParameterQueue.RABBIT_HOST, ParameterQueue.DEFAULT_RABBIT_HOST);
+		int port = Integer.parseInt(env.getProperty(ParameterQueue.RABBIT_PORT, ParameterQueue.DEFAULT_PORT));
 
 		boolean ssl = Boolean.parseBoolean(env.getProperty(ParameterQueue.ENABLE_SSL, "false"));
 

src/main/java/omq/common/util/ParameterQueue.java

@@ -141,4 +141,9 @@ public class ParameterQueue {
 	 */
 	public static long DEFAULT_TIMEOUT = 1 * 1000 * 60;
 
+	public static String DEFAULT_USER = "guest";
+	public static String DEFAULT_PASS = "guest";
+	public static String DEFAULT_RABBIT_HOST = "localhost";
+	public static String DEFAULT_PORT = "5672";
+
 }