Some unit test work

server/test/com/cloud/async/AsyncJobTestConfiguration.java

@@ -0,0 +1,94 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+package com.cloud.async;
+
+import org.mockito.Mockito;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import com.cloud.api.ApiDispatcher;
+import com.cloud.async.dao.AsyncJobDao;
+import com.cloud.async.dao.AsyncJobDaoImpl;
+import com.cloud.async.dao.SyncQueueDao;
+import com.cloud.async.dao.SyncQueueDaoImpl;
+import com.cloud.async.dao.SyncQueueItemDao;
+import com.cloud.async.dao.SyncQueueItemDaoImpl;
+import com.cloud.cluster.ClusterManager;
+import com.cloud.configuration.ConfigurationManager;
+import com.cloud.configuration.dao.ConfigurationDao;
+import com.cloud.dao.EntityManager;
+import com.cloud.user.AccountManager;
+import com.cloud.user.dao.AccountDao;
+
+@Configuration
+public class AsyncJobTestConfiguration {
+
+	@Bean
+	public ClusterManager clusterManager() {
+		return Mockito.mock(ClusterManager.class);
+	}
+	
+	@Bean
+	public AsyncJobDao asyncJobDao() {
+		return new AsyncJobDaoImpl();
+	}
+	
+	@Bean
+	public AccountManager accountManager() {
+		return Mockito.mock(AccountManager.class);
+	}
+	
+	@Bean
+	public ApiDispatcher apiDispatcher() {
+		return Mockito.mock(ApiDispatcher.class);
+	}
+	
+	@Bean
+	public EntityManager entityManager() {
+		return Mockito.mock(EntityManager.class);
+	}
+	
+	@Bean
+	public SyncQueueManager syncQueueManager() {
+		return new SyncQueueManagerImpl();
+	}
+	
+	@Bean
+	public AccountDao accountDao() {
+		return Mockito.mock(AccountDao.class);
+	}
+	
+	@Bean
+	public SyncQueueDao syncQueueDao() {
+		return new SyncQueueDaoImpl();
+	}
+	
+	@Bean
+	public SyncQueueItemDao syncQueueItemDao() {
+		return new SyncQueueItemDaoImpl();
+	}
+	
+	@Bean 
+	public ConfigurationDao configurationDao() {
+		return Mockito.mock(ConfigurationDao.class);
+	}
+	
+	@Bean
+	public ConfigurationManager configurationManager() {
+		return Mockito.mock(ConfigurationManager.class);
+	}
+}

server/test/com/cloud/async/SyncQueueTestConfiguration.java

@@ -0,0 +1,58 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+package com.cloud.async;
+
+import org.mockito.Mockito;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import com.cloud.async.dao.SyncQueueDao;
+import com.cloud.async.dao.SyncQueueDaoImpl;
+import com.cloud.async.dao.SyncQueueItemDao;
+import com.cloud.async.dao.SyncQueueItemDaoImpl;
+import com.cloud.configuration.ConfigurationManager;
+import com.cloud.configuration.dao.ConfigurationDao;
+
+@Configuration
+public class SyncQueueTestConfiguration {
+
+	@Bean
+	public SyncQueueManager syncQueueManager() {
+		return new SyncQueueManagerImpl();
+	}
+	
+	@Bean
+	public SyncQueueDao syncQueueDao() {
+		return new SyncQueueDaoImpl();
+	}
+	
+	@Bean
+	public SyncQueueItemDao syncQueueItemDao() {
+		return new SyncQueueItemDaoImpl();
+	}
+	
+	@Bean 
+	public ConfigurationDao configurationDao() {
+		return Mockito.mock(ConfigurationDao.class);
+	}
+	
+	@Bean
+	public ConfigurationManager configurationManager() {
+		return Mockito.mock(ConfigurationManager.class);
+	}
+}
+

server/test/resources/AsyncJobTestContext.xml

@@ -0,0 +1,49 @@
+<!-- Licensed to the Apache Software Foundation (ASF) under one or more contributor 
+  license agreements. See the NOTICE file distributed with this work for additional 
+  information regarding copyright ownership. The ASF licenses this file to 
+  you under the Apache License, Version 2.0 (the "License"); you may not use 
+  this file except in compliance with the License. You may obtain a copy of 
+  the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required 
+  by applicable law or agreed to in writing, software distributed under the 
+  License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS 
+  OF ANY KIND, either express or implied. See the License for the specific 
+  language governing permissions and limitations under the License. -->
+<beans xmlns="http://www.springframework.org/schema/beans"
+  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
+  xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop"
+  xsi:schemaLocation="http://www.springframework.org/schema/beans
+                      http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
+                      http://www.springframework.org/schema/tx 
+                      http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
+                      http://www.springframework.org/schema/aop
+                      http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
+                      http://www.springframework.org/schema/context
+                      http://www.springframework.org/schema/context/spring-context-3.0.xsd">
+
+  <context:annotation-config />
+
+  <!-- @DB support -->
+      
+  <bean id="componentContext" class="com.cloud.utils.component.ComponentContext" />
+
+  <bean id="transactionContextBuilder" class="com.cloud.utils.db.TransactionContextBuilder" />
+  <bean id="actionEventInterceptor" class="com.cloud.event.ActionEventInterceptor" />
+  <bean id="instantiatePostProcessor" class="com.cloud.utils.component.ComponentInstantiationPostProcessor">
+    <property name="Interceptors">
+        <list>
+            <ref bean="transactionContextBuilder" />
+            <ref bean="actionEventInterceptor" />
+        </list>
+    </property>
+  </bean>
+
+  <bean id="asyncJobManagerImpl" class="com.cloud.async.AsyncJobManagerImpl">
+    <property name="defaultDispatcher" value="ApiAsyncJobDispatcher" />
+  </bean>
+  <bean id="ApiAsyncJobDispatcher" class="com.cloud.api.ApiAsyncJobDispatcher">
+    <property name="name" value="ApiAsyncJobDispatcher" />
+  </bean>
+
+  <bean class="com.cloud.async.AsyncJobTestConfiguration" />
+
+</beans>

server/test/resources/SyncQueueTestContext.xml

@@ -0,0 +1,41 @@
+<!-- Licensed to the Apache Software Foundation (ASF) under one or more contributor 
+  license agreements. See the NOTICE file distributed with this work for additional 
+  information regarding copyright ownership. The ASF licenses this file to 
+  you under the Apache License, Version 2.0 (the "License"); you may not use 
+  this file except in compliance with the License. You may obtain a copy of 
+  the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required 
+  by applicable law or agreed to in writing, software distributed under the 
+  License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS 
+  OF ANY KIND, either express or implied. See the License for the specific 
+  language governing permissions and limitations under the License. -->
+<beans xmlns="http://www.springframework.org/schema/beans"
+  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
+  xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop"
+  xsi:schemaLocation="http://www.springframework.org/schema/beans
+                      http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
+                      http://www.springframework.org/schema/tx 
+                      http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
+                      http://www.springframework.org/schema/aop
+                      http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
+                      http://www.springframework.org/schema/context
+                      http://www.springframework.org/schema/context/spring-context-3.0.xsd">
+
+  <context:annotation-config />
+
+  <!-- @DB support -->
+      
+  <bean id="componentContext" class="com.cloud.utils.component.ComponentContext" />
+
+  <bean id="transactionContextBuilder" class="com.cloud.utils.db.TransactionContextBuilder" />
+  <bean id="actionEventInterceptor" class="com.cloud.event.ActionEventInterceptor" />
+  <bean id="instantiatePostProcessor" class="com.cloud.utils.component.ComponentInstantiationPostProcessor">
+    <property name="Interceptors">
+        <list>
+            <ref bean="transactionContextBuilder" />
+            <ref bean="actionEventInterceptor" />
+        </list>
+    </property>
+  </bean>
+  <bean class="com.cloud.async.SyncQueueTestConfiguration" />
+
+</beans>