From 6b6db1b59a75f1fc0aca0df3b14ecffc0bc00849 Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Mon, 13 Oct 2008 14:00:27 +0000 Subject: [PATCH] Formatting. --- .../integration/bus/DefaultMessageBus.java | 26 +++++++++---------- .../integration/bus/MessageBusAware.java | 4 +-- 2 files changed, 15 insertions(+), 15 deletions(-) diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/bus/DefaultMessageBus.java b/org.springframework.integration/src/main/java/org/springframework/integration/bus/DefaultMessageBus.java index f399f74859..c642c3a049 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/bus/DefaultMessageBus.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/bus/DefaultMessageBus.java @@ -131,19 +131,6 @@ public class DefaultMessageBus implements MessageBus, ApplicationContextAware, A return null; } - public void registerEndpoint(MessageEndpoint endpoint) { - Assert.notNull(endpoint, "'endpoint' must not be null"); - if (!this.endpoints.contains(endpoint)) { - this.endpoints.add(endpoint); - } - if (this.isRunning()) { - this.activateEndpoint(endpoint); - } - if (logger.isInfoEnabled()) { - logger.info("registered endpoint '" + endpoint + "'"); - } - } - public MessageEndpoint lookupEndpoint(String endpointName) { if (this.applicationContext.containsBean(endpointName)) { Object bean = this.applicationContext.getBean(endpointName); @@ -160,6 +147,19 @@ public class DefaultMessageBus implements MessageBus, ApplicationContextAware, A return this.endpoints; } + public void registerEndpoint(MessageEndpoint endpoint) { + Assert.notNull(endpoint, "'endpoint' must not be null"); + if (!this.endpoints.contains(endpoint)) { + this.endpoints.add(endpoint); + } + if (this.isRunning()) { + this.activateEndpoint(endpoint); + } + if (logger.isInfoEnabled()) { + logger.info("registered endpoint '" + endpoint + "'"); + } + } + private void activateEndpoints() { for (MessageEndpoint endpoint : this.getEndpoints()) { if (endpoint != null) { diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/bus/MessageBusAware.java b/org.springframework.integration/src/main/java/org/springframework/integration/bus/MessageBusAware.java index 0846a76d60..645a6aebec 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/bus/MessageBusAware.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/bus/MessageBusAware.java @@ -18,11 +18,11 @@ package org.springframework.integration.bus; /** * Interface to be implemented by classes which need access to the {@link MessageBus}. + * * @author Marius Bogoevici - * */ public interface MessageBusAware { public void setMessageBus(MessageBus messageBus); - + }