org.ikasan.topology.service

Class TopologyServiceImpl

java.lang.Object

org.ikasan.topology.service.TopologyServiceImpl

All Implemented Interfaces:

TopologyService

public class TopologyServiceImpl
extends Object
implements TopologyService

Author:

Ikasan Development Team

Constructor Summary

Constructors

Constructor and Description
TopologyServiceImpl(TopologyDao topologyDao) Constructor

Method Summary

Methods

Modifier and Type	Method and Description
void	deleteBusinessStreamFlow(BusinessStreamFlow businessStreamFlow) Delete a business stream flow
void	discover(IkasanAuthentication authentication) Method to discovery and populate Ikasan topology
List<BusinessStream>	getAllBusinessStreams() Get all BusinessStreams
List<Flow>	getAllFlows() Get all flows.
List<Module>	getAllModules() Get all modules
List<Server>	getAllServers() Get all servers
List<BusinessStream>	getBusinessStreamsByUserId(List<Long> ids) Get all BusinessStreams by a list of ids.
List<BusinessStream>	getBusinessStreamsByUserId(Long userId) Get all BusinessStreams associated with a given user.
List<Flow>	getFlowsByServerIdAndModuleId(Long serverId, Long moduleId) Get all flows by server id and module id.
Module	getModuleByName(String name) Method to get a Module by its name.
void	save(Flow flow) Save a flow.
void	save(Module module) Save a module.
void	save(Server server) Save a server.
void	saveBusinessStream(BusinessStream businessStream) Save a BusinessStream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TopologyServiceImpl

public TopologyServiceImpl(TopologyDao topologyDao)

Constructor

Parameters:

topologyDao -

Method Detail

getAllServers

public List<Server> getAllServers()

Description copied from interface: TopologyService

Get all servers

Specified by:

getAllServers in interface TopologyService

Returns:

save

public void save(Server server)

Description copied from interface: TopologyService

Save a server. Will create a new record or update an existing.

Specified by:

save in interface TopologyService

getAllModules

public List<Module> getAllModules()

Description copied from interface: TopologyService

Get all modules

Specified by:

getAllModules in interface TopologyService

Returns:

save

public void save(Module module)

Description copied from interface: TopologyService

Save a module. Will create a new record or update an existing.

Specified by:

save in interface TopologyService

getAllFlows

public List<Flow> getAllFlows()

Description copied from interface: TopologyService

Get all flows.

Specified by:

getAllFlows in interface TopologyService

Returns:

save

public void save(Flow flow)

Description copied from interface: TopologyService

Save a flow. Will create a new record or update an existing.

Specified by:

save in interface TopologyService

getAllBusinessStreams

public List<BusinessStream> getAllBusinessStreams()

Description copied from interface: TopologyService

Get all BusinessStreams

Specified by:

getAllBusinessStreams in interface TopologyService

Returns:

saveBusinessStream

public void saveBusinessStream(BusinessStream businessStream)

Description copied from interface: TopologyService

Save a BusinessStream. Will create a new record or update an existing.

Specified by:

saveBusinessStream in interface TopologyService

getBusinessStreamsByUserId

public List<BusinessStream> getBusinessStreamsByUserId(Long userId)

Description copied from interface: TopologyService

Get all BusinessStreams associated with a given user.

Specified by:

getBusinessStreamsByUserId in interface TopologyService

Returns:

getFlowsByServerIdAndModuleId

public List<Flow> getFlowsByServerIdAndModuleId(Long serverId,
                                       Long moduleId)

Description copied from interface: TopologyService

Get all flows by server id and module id.

Specified by:

getFlowsByServerIdAndModuleId in interface TopologyService

Returns:

deleteBusinessStreamFlow

public void deleteBusinessStreamFlow(BusinessStreamFlow businessStreamFlow)

Description copied from interface: TopologyService

Delete a business stream flow

Specified by:

deleteBusinessStreamFlow in interface TopologyService

getModuleByName

public Module getModuleByName(String name)

Description copied from interface: TopologyService

Method to get a Module by its name.

Specified by:

getModuleByName in interface TopologyService

Returns:

getBusinessStreamsByUserId

public List<BusinessStream> getBusinessStreamsByUserId(List<Long> ids)

Description copied from interface: TopologyService

Get all BusinessStreams by a list of ids.

Specified by:

getBusinessStreamsByUserId in interface TopologyService

Returns:

discover

public void discover(IkasanAuthentication authentication)
              throws DiscoveryException

Description copied from interface: TopologyService

Method to discovery and populate Ikasan topology

Specified by:

discover in interface TopologyService

Throws:

DiscoveryException