org.ikasan.topology.service

Interface TopologyService

All Known Implementing Classes:

TopologyServiceImpl

public interface TopologyService

Author:

Ikasan Development Team

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.

Method Detail

getAllServers

List<Server> getAllServers()

Get all servers

Returns:

save

void save(Server server)

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

Parameters:

server -

getAllModules

List<Module> getAllModules()

Get all modules

Returns:

save

void save(Module module)

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

Parameters:

module -

getAllFlows

List<Flow> getAllFlows()

Get all flows.

Returns:

save

void save(Flow flow)

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

Parameters:

flow -

getAllBusinessStreams

List<BusinessStream> getAllBusinessStreams()

Get all BusinessStreams

Returns:

saveBusinessStream

void saveBusinessStream(BusinessStream businessStream)

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

Parameters:

businessStream -

getBusinessStreamsByUserId

List<BusinessStream> getBusinessStreamsByUserId(Long userId)

Get all BusinessStreams associated with a given user.

Parameters:

userId -

Returns:

getFlowsByServerIdAndModuleId

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

Get all flows by server id and module id.

Returns:

deleteBusinessStreamFlow

void deleteBusinessStreamFlow(BusinessStreamFlow businessStreamFlow)

Delete a business stream flow

Parameters:

businessStreamFlow -

getModuleByName

Module getModuleByName(String name)

Method to get a Module by its name.

Parameters:

name -

Returns:

getBusinessStreamsByUserId

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

Get all BusinessStreams by a list of ids.

Parameters:

ids -

Returns:

discover

void discover(IkasanAuthentication authentication)
              throws DiscoveryException

Method to discovery and populate Ikasan topology

Throws:

DiscoveryException