DATAREDIS-700 - Polishing.

Fix line endings.
This commit is contained in:
Mark Paluch
2017-09-18 15:29:50 +02:00
parent 15535cb48a
commit ddb5ca7c28

View File

@@ -1,108 +1,108 @@
/*
* Copyright 2016-2017 the original author or authors.
*
* Licensed 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 org.springframework.data.redis.repository.cdi;
import static org.hamcrest.Matchers.*;
import static org.junit.Assert.*;
import java.util.List;
import java.util.Set;
import javax.enterprise.context.ApplicationScoped;
import javax.enterprise.inject.se.SeContainer;
import javax.enterprise.inject.se.SeContainerInitializer;
import javax.enterprise.inject.spi.Bean;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* Integration tests for Spring Data Redis CDI extension.
*
* @author Mark Paluch
*/
public class CdiExtensionIntegrationTests {
private static Logger LOGGER = LoggerFactory.getLogger(CdiExtensionIntegrationTests.class);
static SeContainer container;
@BeforeClass
public static void setUp() {
container = SeContainerInitializer.newInstance() //
.disableDiscovery() //
.addPackages(RepositoryConsumer.class) //
.initialize();
LOGGER.debug("CDI container bootstrapped!");
}
@AfterClass
public static void cleanUp() {
container.close();
}
@Test // DATAREDIS-425, DATAREDIS-700
@SuppressWarnings("rawtypes")
public void beanShouldBeRegistered() {
Set<Bean<?>> beans = container.getBeanManager().getBeans(PersonRepository.class);
assertThat(beans, hasSize(1));
assertThat(beans.iterator().next().getScope(), is(equalTo((Class) ApplicationScoped.class)));
}
@Test // DATAREDIS-425, DATAREDIS-700
public void saveAndFindUnqualified() {
RepositoryConsumer repositoryConsumer = container.select(RepositoryConsumer.class).get();
repositoryConsumer.deleteAll();
Person person = new Person();
person.setName("foo");
repositoryConsumer.getUnqualifiedRepo().save(person);
List<Person> result = repositoryConsumer.getUnqualifiedRepo().findByName("foo");
assertThat(result, contains(person));
}
@Test // DATAREDIS-425, DATAREDIS-700
public void saveAndFindQualified() {
RepositoryConsumer repositoryConsumer = container.select(RepositoryConsumer.class).get();
repositoryConsumer.deleteAll();
Person person = new Person();
person.setName("foo");
repositoryConsumer.getUnqualifiedRepo().save(person);
List<Person> result = repositoryConsumer.getQualifiedRepo().findByName("foo");
assertThat(result, contains(person));
}
@Test // DATAREDIS-425, DATAREDIS-700
public void callMethodOnCustomRepositoryShouldSuceed() {
RepositoryConsumer repositoryConsumer = container.select(RepositoryConsumer.class).get();
int result = repositoryConsumer.getUnqualifiedRepo().returnOne();
assertThat(result, is(1));
}
}
/*
* Copyright 2016-2017 the original author or authors.
*
* Licensed 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 org.springframework.data.redis.repository.cdi;
import static org.hamcrest.Matchers.*;
import static org.junit.Assert.*;
import java.util.List;
import java.util.Set;
import javax.enterprise.context.ApplicationScoped;
import javax.enterprise.inject.se.SeContainer;
import javax.enterprise.inject.se.SeContainerInitializer;
import javax.enterprise.inject.spi.Bean;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* Integration tests for Spring Data Redis CDI extension.
*
* @author Mark Paluch
*/
public class CdiExtensionIntegrationTests {
private static Logger LOGGER = LoggerFactory.getLogger(CdiExtensionIntegrationTests.class);
static SeContainer container;
@BeforeClass
public static void setUp() {
container = SeContainerInitializer.newInstance() //
.disableDiscovery() //
.addPackages(RepositoryConsumer.class) //
.initialize();
LOGGER.debug("CDI container bootstrapped!");
}
@AfterClass
public static void cleanUp() {
container.close();
}
@Test // DATAREDIS-425, DATAREDIS-700
@SuppressWarnings("rawtypes")
public void beanShouldBeRegistered() {
Set<Bean<?>> beans = container.getBeanManager().getBeans(PersonRepository.class);
assertThat(beans, hasSize(1));
assertThat(beans.iterator().next().getScope(), is(equalTo((Class) ApplicationScoped.class)));
}
@Test // DATAREDIS-425, DATAREDIS-700
public void saveAndFindUnqualified() {
RepositoryConsumer repositoryConsumer = container.select(RepositoryConsumer.class).get();
repositoryConsumer.deleteAll();
Person person = new Person();
person.setName("foo");
repositoryConsumer.getUnqualifiedRepo().save(person);
List<Person> result = repositoryConsumer.getUnqualifiedRepo().findByName("foo");
assertThat(result, contains(person));
}
@Test // DATAREDIS-425, DATAREDIS-700
public void saveAndFindQualified() {
RepositoryConsumer repositoryConsumer = container.select(RepositoryConsumer.class).get();
repositoryConsumer.deleteAll();
Person person = new Person();
person.setName("foo");
repositoryConsumer.getUnqualifiedRepo().save(person);
List<Person> result = repositoryConsumer.getQualifiedRepo().findByName("foo");
assertThat(result, contains(person));
}
@Test // DATAREDIS-425, DATAREDIS-700
public void callMethodOnCustomRepositoryShouldSuceed() {
RepositoryConsumer repositoryConsumer = container.select(RepositoryConsumer.class).get();
int result = repositoryConsumer.getUnqualifiedRepo().returnOne();
assertThat(result, is(1));
}
}