package de.jeha.kame.crawler.service.config;

import com.fasterxml.jackson.annotation.JsonProperty;
import com.rabbitmq.client.ConnectionFactory;
import org.hibernate.validator.constraints.NotEmpty;

import javax.validation.constraints.Max;
import javax.validation.constraints.Min;

/**
 * @author jenshadlich@googlemail.com
 */
public class AmqpFactory {

    @NotEmpty
    @JsonProperty
    private String host;

    @Min(1)
    @Max(65535)
    @JsonProperty
    private int port = ConnectionFactory.DEFAULT_AMQP_PORT;

    private transient ConnectionFactory connectionFactory;

    public AmqpConfiguration build() {
        return new AmqpConfiguration(host, port);
    }

    public ConnectionFactory getConnectionFactory() {
        if (connectionFactory == null) {
            ConnectionFactory connectionFactory = new ConnectionFactory();
            connectionFactory.setConnectionTimeout(1000);
            connectionFactory.setHost(host);
            connectionFactory.setPort(port);
        }
        return connectionFactory;
    }

}

@@ -778,34 +778,16 @@
         
-ConnectionFactory 
 connecti

fix bug