@@ -0,0 +1,1906 @@
+/***************************** BEGIN LICENSE BLOCK ***************************%0D%0A%0D%0AThe contents of this file are subject to the Mozilla Public License, v. 2.0.%0D%0AIf a copy of the MPL was not distributed with this file, You can obtain one%0D%0Aat http://mozilla.org/MPL/2.0/.%0D%0A%0D%0ASoftware distributed under the License is distributed on an %22AS IS%22 basis,%0D%0AWITHOUT WARRANTY OF ANY KIND, either express or implied. See the License%0D%0Afor the specific language governing rights and limitations under the License.%0D%0A %0D%0ACopyright (C) 2012-2015 Sensia Software LLC. All Rights Reserved.%0D%0A %0D%0A******************************* END LICENSE BLOCK ***************************/%0D%0A%0D%0Apackage org.sensorhub.impl.persistence.es;%0A%0Aimport java.util.ArrayList;%0D%0Aimport java.util.List;%0D%0Aimport java.util.UUID;%0D%0A%0D%0Aimport org.junit.After;%0D%0Aimport org.junit.Before;%0D%0Aimport org.sensorhub.api.persistence.IObsStorageModule;%0D%0Aimport org.sensorhub.test.persistence.AbstractTestBasicStorage;%0D%0Aimport org.sensorhub.test.persistence.AbstractTestMultiObsStorage;%0D%0A%0A%0Apublic class TestEsMultiSourceStorage extends AbstractTestMultiObsStorage%3CIObsStorageModule%3CESBasicStorageConfig%3E%3E%0D%0A%7B%0D%0A    %0D%0A    @Before%0D%0A    public void init() throws Exception%0D%0A    %7B%0D%0A        ESBasicStorageConfig config = new ESBasicStorageConfig();%0D%0A        config.autoStart = true;%0D%0A        config.storagePath = %22elastic-cluster%22;%0D%0A        List%3CString%3E nodes = new ArrayList%3CString%3E();%0D%0A        nodes.add(%22localhost:9300%22);%0D%0A        %0D%0A        config.nodeUrls = nodes;%0D%0A        config.scrollFetchSize = 2;%0D%0A        config.id = %22junit_%22+UUID.randomUUID().toString();%0D%0A        storage = new ESMultiSourceStorageImpl();%0D%0A        storage.init(config);%0D%0A        storage.start();%0D%0A    %7D%0D%0A    %0D%0A%0D%0A    @Override%0D%0A    protected void forceReadBackFromStorage() throws Exception%0D%0A    %7B%0D%0A    %09storage.commit();%0D%0A    %7D%0D%0A    %0D%0A    %0D%0A    @After%0D%0A    public void cleanup()%0D%0A    %7B%0D%0A    %7D%0D%0A    %0D%0A%7D%0D%0A

Add empty junit class for ES multiSource storage