Skip to content

Commit

Permalink
Fix Eclipse warnings
Browse files Browse the repository at this point in the history
  • Loading branch information
aduprat authored and chibenwa committed Jun 2, 2017
1 parent c74138c commit a34bc33
Show file tree
Hide file tree
Showing 21 changed files with 20 additions and 40 deletions.
Expand Up @@ -25,7 +25,6 @@
import static com.datastax.driver.core.querybuilder.QueryBuilder.insertInto;
import static com.datastax.driver.core.querybuilder.QueryBuilder.select;

import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.stream.Stream;

Expand All @@ -40,7 +39,6 @@
import com.datastax.driver.core.BoundStatement;
import com.datastax.driver.core.PreparedStatement;
import com.datastax.driver.core.Session;
import com.github.steveash.guavate.Guavate;

public class CassandraMailboxRecentsDAO {

Expand Down
Expand Up @@ -23,7 +23,6 @@
import static com.datastax.driver.core.DataType.text;
import static com.datastax.driver.core.DataType.timeuuid;

import java.util.Collections;
import java.util.List;

import org.apache.james.backends.cassandra.components.CassandraModule;
Expand Down
Expand Up @@ -22,7 +22,6 @@
import static com.datastax.driver.core.DataType.text;
import static com.datastax.driver.core.DataType.timeuuid;

import java.util.Collections;
import java.util.List;

import org.apache.james.backends.cassandra.components.CassandraModule;
Expand Down
Expand Up @@ -33,15 +33,13 @@
import org.apache.james.backends.cassandra.components.CassandraModule;
import org.apache.james.backends.cassandra.components.CassandraTable;
import org.apache.james.backends.cassandra.components.CassandraType;
import org.apache.james.backends.cassandra.utils.CassandraConstants;
import org.apache.james.mailbox.cassandra.table.CassandraMessageIdTable;
import org.apache.james.mailbox.cassandra.table.CassandraMessageIds;
import org.apache.james.mailbox.cassandra.table.CassandraMessageTable;
import org.apache.james.mailbox.cassandra.table.Flag;
import org.apache.james.mailbox.cassandra.table.MessageIdToImapUid;

import com.datastax.driver.core.schemabuilder.SchemaBuilder;
import com.datastax.driver.core.schemabuilder.TableOptions;
import com.google.common.collect.ImmutableList;

public class CassandraMessageModule implements CassandraModule {
Expand Down
Expand Up @@ -26,7 +26,6 @@
import org.apache.james.backends.cassandra.components.CassandraModule;
import org.apache.james.backends.cassandra.components.CassandraTable;
import org.apache.james.backends.cassandra.components.CassandraType;
import org.apache.james.backends.cassandra.utils.CassandraConstants;
import org.apache.james.mailbox.cassandra.table.CassandraSubscriptionTable;

import com.datastax.driver.core.schemabuilder.SchemaBuilder;
Expand Down
Expand Up @@ -37,7 +37,6 @@
import org.junit.rules.TemporaryFolder;

import com.google.common.base.Charsets;
import com.google.common.collect.ImmutableList;
import com.google.common.net.InetAddresses;
import com.jayway.restassured.RestAssured;
import com.jayway.restassured.builder.RequestSpecBuilder;
Expand Down
Expand Up @@ -19,16 +19,18 @@

package org.apache.james.utils;

import com.nurkiewicz.asyncretry.AsyncRetryExecutor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.nurkiewicz.asyncretry.AsyncRetryExecutor;

public class RetryExecutorUtil {
private static final Logger LOG = LoggerFactory.getLogger(RetryExecutorUtil.class);

private static final int INITIAL_DELAY_MILLIS = 500;
private static final int MULTIPLIER = 2;

@SafeVarargs
public static AsyncRetryExecutor retryOnExceptions(AsyncRetryExecutor executor, int maxRetries, int minDelay, Class<? extends Throwable>... clazz) {
LOG.info("The action should retry when {} and retry to {} times if needed", clazz, maxRetries);
return executor
Expand Down
Expand Up @@ -34,7 +34,6 @@
import org.apache.james.mime4j.message.BodyPartBuilder;
import org.apache.james.mime4j.message.HeaderImpl;
import org.apache.james.mime4j.message.MultipartBuilder;
import org.apache.james.mime4j.dom.Message;
import org.apache.james.mime4j.stream.Field;
import org.apache.james.mime4j.util.ByteSequence;
import org.apache.james.util.mime.MessageContentExtractor.MessageContent;
Expand Down
Expand Up @@ -21,7 +21,6 @@

import java.util.List;

import com.google.common.base.Strings;
import org.junit.Assume;
import org.junit.rules.TestRule;
import org.junit.runner.Description;
Expand All @@ -32,25 +31,27 @@
import org.testcontainers.images.builder.ImageFromDockerfile;
import org.testcontainers.shaded.com.github.dockerjava.api.command.InspectContainerResponse;

import com.google.common.base.Strings;

public class SwarmGenericContainer implements TestRule {
private static final Logger LOGGER = LoggerFactory.getLogger(SwarmGenericContainer.class);
private static final String DOCKER_CONTAINER = "DOCKER_CONTAINER";
private static final String NO_DOCKER_ENVIRONMENT = "Could not find a valid Docker environment.";
private static final String SKIPPING_TEST_CAUTION = "Skipping all docker tests as no Docker environment was found";

private GenericContainer container;
private GenericContainer<?> container;

public SwarmGenericContainer(String dockerImageName) {
try {
this.container = new GenericContainer(dockerImageName);
this.container = new GenericContainer<>(dockerImageName);
} catch (IllegalStateException e) {
logAndCheckSkipTest(e);
}
}

public SwarmGenericContainer(ImageFromDockerfile imageFromDockerfile) {
try {
this.container = new GenericContainer(imageFromDockerfile);
this.container = new GenericContainer<>(imageFromDockerfile);
} catch (IllegalStateException e) {
logAndCheckSkipTest(e);
}
Expand Down
Expand Up @@ -25,7 +25,6 @@
import java.net.UnknownHostException;
import java.util.Collection;

import com.google.common.collect.ImmutableList;
import org.apache.james.dnsservice.api.DNSService;
import org.apache.james.dnsservice.api.mock.MockDNSService;
import org.apache.james.domainlist.api.DomainList;
Expand All @@ -34,7 +33,7 @@
import org.junit.Before;
import org.junit.Test;

import javax.management.ImmutableDescriptor;
import com.google.common.collect.ImmutableList;

public abstract class AbstractDomainListTest {

Expand Down
1 change: 0 additions & 1 deletion server/dns-service/dnsservice-api/pom.xml
Expand Up @@ -42,7 +42,6 @@
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>18.0</version>
</dependency>
</dependencies>

Expand Down
Expand Up @@ -21,7 +21,6 @@

import javax.mail.MessagingException;

import org.apache.commons.logging.Log;
import org.apache.james.metrics.api.Metric;
import org.apache.james.user.api.UsersRepository;
import org.apache.james.user.api.UsersRepositoryException;
Expand Down
Expand Up @@ -33,7 +33,6 @@
import javax.mail.internet.MimeMessage;

import org.apache.commons.io.IOUtils;
import org.apache.commons.logging.Log;
import org.apache.mailet.Mail;
import org.apache.mailet.MailAddress;
import org.apache.mailet.PerRecipientHeaders.Header;
Expand Down
Expand Up @@ -27,7 +27,6 @@

import javax.mail.internet.MimeMessage;

import org.apache.commons.logging.Log;
import org.apache.james.metrics.api.Metric;
import org.apache.james.user.api.UsersRepository;
import org.apache.james.user.api.UsersRepositoryException;
Expand Down
Expand Up @@ -199,7 +199,6 @@
<groupId>org.apache.james</groupId>
<artifactId>james-server-dnsservice-api</artifactId>
<type>test-jar</type>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.james</groupId>
Expand Down
Expand Up @@ -183,7 +183,6 @@
<artifactId>james-server-dnsservice-api</artifactId>
<type>test-jar</type>
<scope>test</scope>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.james</groupId>
Expand Down
Expand Up @@ -27,8 +27,6 @@
import java.net.InetAddress;
import java.util.concurrent.TimeUnit;

import com.jayway.restassured.RestAssured;
import com.jayway.restassured.specification.RequestSpecification;
import org.apache.commons.net.smtp.SMTPClient;
import org.apache.james.GuiceJamesServer;
import org.apache.james.dnsservice.api.InMemoryDNSService;
Expand All @@ -45,14 +43,15 @@
import org.junit.Before;
import org.junit.Rule;
import org.junit.Test;
import org.testcontainers.shaded.com.google.common.net.InetAddresses;

import com.google.common.base.Charsets;
import com.jayway.awaitility.Awaitility;
import com.jayway.awaitility.Duration;
import com.jayway.awaitility.core.ConditionFactory;
import com.jayway.restassured.RestAssured;
import com.jayway.restassured.builder.RequestSpecBuilder;
import com.jayway.restassured.http.ContentType;
import org.testcontainers.shaded.com.google.common.net.InetAddresses;

public abstract class VacationRelayIntegrationTest {

Expand Down
Expand Up @@ -186,7 +186,6 @@
<groupId>org.apache.james</groupId>
<artifactId>james-server-dnsservice-api</artifactId>
<type>test-jar</type>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.james</groupId>
Expand Down
Expand Up @@ -21,7 +21,6 @@

import java.io.IOException;
import java.util.Set;
import java.util.TimeZone;

import javax.inject.Inject;

Expand Down Expand Up @@ -54,7 +53,6 @@ public class ObjectMapperFactory {
new GuavaModule());

private final Set<Module> jacksonModules;
private static final TimeZone UTC_TIMEZONE = TimeZone.getTimeZone("UTC");

@Inject
public ObjectMapperFactory(MailboxId.Factory mailboxIdFactory, MessageId.Factory messageIdFactory) {
Expand Down
Expand Up @@ -49,7 +49,6 @@
import org.apache.james.mime4j.message.BodyPart;
import org.apache.james.mime4j.message.BodyPartBuilder;
import org.apache.james.mime4j.message.DefaultMessageWriter;
import org.apache.james.mime4j.message.MessageBuilder;
import org.apache.james.mime4j.message.MultipartBuilder;
import org.apache.james.mime4j.stream.Field;
import org.apache.james.mime4j.stream.NameValuePair;
Expand All @@ -60,7 +59,6 @@
import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Splitter;
import com.google.common.base.Throwables;
import com.google.common.collect.FluentIterable;
import com.google.common.collect.ImmutableList;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.ImmutableMap.Builder;
Expand Down Expand Up @@ -103,7 +101,7 @@ public byte[] convert(ValueWithId.CreationMessageEntry creationMessageEntry, Imm
throw new IllegalArgumentException("creationMessageEntry is either null or has null message");
}

MessageBuilder messageBuilder = MessageBuilder.create();
Message.Builder messageBuilder = Message.Builder.of();
if (isMultipart(creationMessageEntry.getValue(), messageAttachments)) {
messageBuilder.setBody(createMultipart(creationMessageEntry.getValue(), messageAttachments));
} else {
Expand All @@ -114,7 +112,7 @@ public byte[] convert(ValueWithId.CreationMessageEntry creationMessageEntry, Imm
return messageBuilder.build();
}

private void buildMimeHeaders(MessageBuilder messageBuilder, CreationMessageId creationId, CreationMessage newMessage, ImmutableList<MessageAttachment> messageAttachments) {
private void buildMimeHeaders(Message.Builder messageBuilder, CreationMessageId creationId, CreationMessage newMessage, ImmutableList<MessageAttachment> messageAttachments) {
Optional<Mailbox> fromAddress = newMessage.getFrom().filter(DraftEmailer::hasValidEmail).map(this::convertEmailToMimeHeader);
fromAddress.ifPresent(messageBuilder::setFrom);
fromAddress.ifPresent(messageBuilder::setSender);
Expand Down Expand Up @@ -176,8 +174,7 @@ private Multipart createMultipart(CreationMessage newMessage, ImmutableList<Mess
addBody(newMessage, builder);

Consumer<MessageAttachment> addAttachment = addAttachment(builder);
messageAttachments.stream()
.forEach(addAttachment);
messageAttachments.forEach(addAttachment);

return builder.build();
} else {
Expand All @@ -204,8 +201,7 @@ private Multipart createMultipartAlternativeBody(CreationMessage newMessage) thr
MultipartBuilder bodyBuilder = MultipartBuilder.create(ALTERNATIVE_SUB_TYPE);
addText(bodyBuilder, newMessage.getTextBody());
addHtml(bodyBuilder, newMessage.getHtmlBody());
Multipart body = bodyBuilder.build();
return body;
return bodyBuilder.build();
}

private void addText(MultipartBuilder builder, Optional<String> textBody) throws IOException {
Expand Down Expand Up @@ -259,7 +255,7 @@ private void contentId(BodyPartBuilder builder, MessageAttachment att) {
}

private ContentTypeField contentTypeField(MessageAttachment att) {
Builder<String, String> parameters = ImmutableMap.<String, String> builder();
Builder<String, String> parameters = ImmutableMap.builder();
if (att.getName().isPresent()) {
parameters.put("name", encode(att.getName().get()));
}
Expand All @@ -275,7 +271,7 @@ private String encode(String name) {
}

private String contentTypeWithoutParameters(String type) {
return FluentIterable.from(Splitter.on(FIELD_PARAMETERS_SEPARATOR).split(type)).get(0);
return Splitter.on(FIELD_PARAMETERS_SEPARATOR).splitToList(type).get(0);
}

private ContentDispositionField contentDispositionField(boolean isInline) {
Expand Down
Expand Up @@ -56,13 +56,13 @@
import org.apache.james.queue.api.MailQueue.MailQueueItem;
import org.apache.mailet.Mail;
import org.apache.mailet.base.test.FakeMail;

import com.google.common.collect.ImmutableList;
import org.junit.Before;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.google.common.collect.ImmutableList;

public class PostDequeueDecoratorTest {
private static final Logger LOGGER = LoggerFactory.getLogger(PostDequeueDecoratorTest.class);
private static final String OUTBOX = DefaultMailboxes.OUTBOX;
Expand Down Expand Up @@ -268,6 +268,7 @@ public void doneShouldCopyMailFromOutboxToSentOnlyOneTimeWhenSuccess() throws Ex
verifyNoMoreInteractions(messageIdManager);
}

@SuppressWarnings("unchecked")
@Test(expected = MailQueue.MailQueueException.class)
public void doneShouldThrowWhenMailboxException() throws Exception {
MessageIdManager messageIdManager = mock(MessageIdManager.class);
Expand Down

0 comments on commit a34bc33

Please sign in to comment.