public ChainData createOutboundChain ( CFEndPoint endpoint ) throws ChannelFrameworkException { List < OutboundChannelDefinition > defs = endpoint . getOutboundChannelDefs ( ) ; String namelist [ ] = new String [ defs . size ( ) ] ; int i = 0 ; for ( OutboundChannelDefinition def : defs ) { namelist [ i ] = "channel_" + channelNameCounter . getAndIncrement ( ) ; addChannel ( namelist [ i ] , def . getOutboundFactory ( ) , def . getOutboundChannelProperties ( ) ) ; i ++ ; } return addChain ( "chain_" + chainNameCounter . getAndIncrement ( ) , FlowType . OUTBOUND , namelist ) ; }
Create a new outbound chain based on the provided endpoint definition .