Skip to content

Commit

Permalink
Rename IndexRangeServiceImpl to MongoIndexRangeService
Browse files Browse the repository at this point in the history
  • Loading branch information
Jochen Schalanda committed Jun 30, 2015
1 parent fe0111e commit 4b48c31
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 8 deletions.
Expand Up @@ -30,7 +30,7 @@
import org.graylog2.indexer.PersistedDeadLetterService;
import org.graylog2.indexer.PersistedDeadLetterServiceImpl;
import org.graylog2.indexer.ranges.IndexRangeService;
import org.graylog2.indexer.ranges.IndexRangeServiceImpl;
import org.graylog2.indexer.ranges.MongoIndexRangeService;
import org.graylog2.inputs.InputService;
import org.graylog2.inputs.InputServiceImpl;
import org.graylog2.notifications.NotificationService;
Expand Down Expand Up @@ -65,7 +65,7 @@ protected void configure() {
bind(PersistedDeadLetterService.class).to(PersistedDeadLetterServiceImpl.class);
bind(IndexFailureService.class).to(IndexFailureServiceImpl.class);
bind(NodeService.class).to(NodeServiceImpl.class);
bind(IndexRangeService.class).to(IndexRangeServiceImpl.class);
bind(IndexRangeService.class).to(MongoIndexRangeService.class);
bind(InputService.class).to(InputServiceImpl.class);
bind(StreamRuleService.class).to(StreamRuleServiceImpl.class);
bind(UserService.class).to(UserServiceImpl.class);
Expand Down
Expand Up @@ -34,14 +34,14 @@
import java.util.List;
import java.util.Map;

public class IndexRangeServiceImpl extends PersistedServiceImpl implements IndexRangeService {
private static final Logger LOG = LoggerFactory.getLogger(IndexRangeServiceImpl.class);
public class MongoIndexRangeService extends PersistedServiceImpl implements IndexRangeService {
private static final Logger LOG = LoggerFactory.getLogger(MongoIndexRangeService.class);
private static final Comparator<IndexRange> COMPARATOR = new IndexRangeComparator();

private final ActivityWriter activityWriter;

@Inject
public IndexRangeServiceImpl(MongoConnection mongoConnection, ActivityWriter activityWriter) {
public MongoIndexRangeService(MongoConnection mongoConnection, ActivityWriter activityWriter) {
super(mongoConnection);
this.activityWriter = activityWriter;
}
Expand Down
Expand Up @@ -36,18 +36,18 @@
import static com.lordofthejars.nosqlunit.mongodb.InMemoryMongoDb.InMemoryMongoRuleBuilder.newInMemoryMongoDbRule;
import static org.assertj.core.api.Assertions.assertThat;

public class IndexRangeServiceImplTest {
public class MongoIndexRangeServiceTest {
@ClassRule
public static final InMemoryMongoDb IN_MEMORY_MONGO_DB = newInMemoryMongoDbRule().build();

@Rule
public MongoConnectionRule mongoRule = MongoConnectionRule.build("test");

private IndexRangeServiceImpl indexRangeService;
private MongoIndexRangeService indexRangeService;

@Before
public void setUp() throws Exception {
indexRangeService = new IndexRangeServiceImpl(mongoRule.getMongoConnection(), new NullActivityWriter());
indexRangeService = new MongoIndexRangeService(mongoRule.getMongoConnection(), new NullActivityWriter());
}

@Test
Expand Down

0 comments on commit 4b48c31

Please sign in to comment.