From f4c208885dcf089d5d03cadbba06e197fe1fd94f Mon Sep 17 00:00:00 2001 From: Dave Syer Date: Mon, 24 Jan 2011 16:23:30 +0000 Subject: [PATCH] AMQP-96: use default hostname if none provided --- .../amqp/rabbit/connection/SingleConnectionFactory.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/connection/SingleConnectionFactory.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/connection/SingleConnectionFactory.java index 2be6bc1b..c6fdb3a9 100644 --- a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/connection/SingleConnectionFactory.java +++ b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/connection/SingleConnectionFactory.java @@ -25,6 +25,7 @@ import org.apache.commons.logging.LogFactory; import org.springframework.amqp.rabbit.support.RabbitUtils; import org.springframework.beans.factory.DisposableBean; import org.springframework.util.Assert; +import org.springframework.util.StringUtils; import com.rabbitmq.client.Channel; @@ -34,6 +35,7 @@ import com.rabbitmq.client.Channel; * * @author Mark Fisher * @author Mark Pollack + * @author Dave Syer */ //TODO are there heartbeats and/or exception thrown if a connection is broken? public class SingleConnectionFactory implements ConnectionFactory, DisposableBean { @@ -69,7 +71,9 @@ public class SingleConnectionFactory implements ConnectionFactory, DisposableBea * @param hostname the host name to connect to */ public SingleConnectionFactory(String hostname) { - Assert.hasText(hostname, "hostname is required"); + if (!StringUtils.hasText(hostname)) { + hostname = getDefaultHostName(); + } this.rabbitConnectionFactory = new com.rabbitmq.client.ConnectionFactory(); this.rabbitConnectionFactory.setHost(hostname); }