diff --git a/gazelle-proxy-ejb/src/main/java/net/ihe/gazelle/proxy/action/ChannelManagerBean.java b/gazelle-proxy-ejb/src/main/java/net/ihe/gazelle/proxy/action/ChannelManagerBean.java index b22cb519d4e8906c0a922229cf4c975d03502aa3..96c8c1fcf3f097f5649d94155c55af93633f20f0 100644 --- a/gazelle-proxy-ejb/src/main/java/net/ihe/gazelle/proxy/action/ChannelManagerBean.java +++ b/gazelle-proxy-ejb/src/main/java/net/ihe/gazelle/proxy/action/ChannelManagerBean.java @@ -22,6 +22,7 @@ import java.util.List; import net.ihe.gazelle.proxy.netty.ChannelType; import net.ihe.gazelle.proxy.netty.ConnectionConfig; import net.ihe.gazelle.proxy.netty.ConnectionConfigSimple; +import net.ihe.gazelle.proxy.netty.Proxy; import org.apache.commons.lang.exception.ExceptionUtils; import org.jboss.seam.ScopeType; @@ -139,4 +140,20 @@ public class ChannelManagerBean implements Serializable { stopChannel(channelToStop); } + public void stopAllChannels() { + List<Proxy<?, ?>> lp = proxyBean.getListOfProxies(); + int size = lp.size(); + if (size > 0) { + for (int i = 0; i < size; i++) { + int port = lp.get(0).getProxyProviderPort(); + stopChannel(port); + } + FacesMessages.instance().add(StatusMessage.Severity.INFO, "All channels are now closed !"); + } else { + FacesMessages.instance().add(StatusMessage.Severity.ERROR, + "Failed to stop channel : none proxy channel open !"); + } + + } + }