Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-2984 changed some LocalChannelRegistry methods to protected

Browse Source
This commit is contained in:
David Turanski
2013-05-19 10:19:36 -04:00
parent 68aa23710c
commit 9721eac28b
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-integration-core/src/main/java/org/springframework/integration/channel/registry/LocalChannelRegistry.java
View File

@@ -106,7 +106,7 @@ public class LocalChannelRegistry implements ChannelRegistry, ApplicationContext
bridge(tapChannel, channel); bridge(tapChannel, channel);
} }
private synchronized <T extends AbstractMessageChannel> T lookupOrCreateSharedChannel(String name, Class<T> requiredType) { protected synchronized <T extends AbstractMessageChannel> T lookupOrCreateSharedChannel(String name, Class<T> requiredType) {
T channel = null; T channel = null;
if (applicationContext.containsBean(name)) { if (applicationContext.containsBean(name)) {
try { try {
@@ -123,7 +123,7 @@ public class LocalChannelRegistry implements ChannelRegistry, ApplicationContext
return channel; return channel;
} }
private <T extends AbstractMessageChannel> T createSharedChannel(String name, Class<T> requiredType) { protected <T extends AbstractMessageChannel> T createSharedChannel(String name, Class<T> requiredType) {
try { try {
T channel = requiredType.newInstance(); T channel = requiredType.newInstance();
channel.setComponentName(name); channel.setComponentName(name);
@@ -157,7 +157,7 @@ public class LocalChannelRegistry implements ChannelRegistry, ApplicationContext
} }
} }
private BridgeHandler bridge(SubscribableChannel from, MessageChannel to) { protected BridgeHandler bridge(SubscribableChannel from, MessageChannel to) {
BridgeHandler handler = new BridgeHandler(); BridgeHandler handler = new BridgeHandler();
handler.setOutputChannel(to); handler.setOutputChannel(to);
handler.afterPropertiesSet(); handler.afterPropertiesSet();