org.ikasan.topology.service

Interface TopologyService

All Known Implementing Classes:

TopologyServiceImpl

public interface TopologyService

Author:

Ikasan Development Team

Method Summary

Modifier and Type	Method and Description
Filter	createFilter(java.lang.String name, java.lang.String description, java.lang.String createdBy, java.util.Set<Component> components) Create a filter.
void	delete(Notification notification)
void	deleteBusinessStream(BusinessStream businessStream) Delete a business stream
void	deleteBusinessStreamFlow(BusinessStreamFlow businessStreamFlow) Delete a business stream flow
void	deleteFilter(Filter filter)
void	deleteFilterComponents(java.lang.Long filterId)
void	deleteRoleFilter(RoleFilter roleFilter)
void	discover(java.util.List<Server> servers, IkasanAuthentication authentication) Method to discovery and populate Ikasan topology
void	discover(Server server, Module module, java.util.List<Flow> flows) Performs module discovery aka updates given module topology view with new latest flows and its components.
java.util.List<BusinessStream>	getAllBusinessStreams() Get all BusinessStreams
java.util.List<Filter>	getAllFilters()
java.util.List<Flow>	getAllFlows() Get all flows.
java.util.List<Module>	getAllModules() Get all modules
java.util.List<Notification>	getAllNotifications()
java.util.List<Server>	getAllServers() Get all servers
java.util.List<BusinessStream>	getBusinessStreamsByUserId(java.util.List<java.lang.Long> ids) Get all BusinessStreams by a list of ids.
java.util.List<BusinessStream>	getBusinessStreamsByUserId(java.lang.Long userId) Get all BusinessStreams associated with a given user.
Filter	getFilterByName(java.lang.String name)
java.util.List<Flow>	getFlowsByServerIdAndModuleId(java.lang.Long serverId, java.lang.Long moduleId) Get all flows by server id and module id.
Module	getModuleByName(java.lang.String name) Method to get a Module by its name.
Notification	getNotificationByName(java.lang.String name)
RoleFilter	getRoleFilterByFilterId(java.lang.Long filterId)
java.util.List<RoleFilter>	getRoleFilters(java.util.List<java.lang.Long> roleIds)
void	initialiseModuleMetaData(Server existingServer, java.lang.String applicationName, Module module) Creates the Module metadata in IkasanModule DB table for the module or updates existing metadata
void	save(Component component) Save a component.
void	save(Flow flow) Save a flow.
void	save(Module module) Save a module.
void	save(Notification notification)
void	save(Server server) Save a server.
void	saveBusinessStream(BusinessStream businessStream) Save a BusinessStream.
void	saveFilter(Filter filter)
void	saveRoleFilter(RoleFilter roleFilter)

Method Detail

initialiseModuleMetaData

void initialiseModuleMetaData(Server existingServer,
                              java.lang.String applicationName,
                              Module module)

Creates the Module metadata in IkasanModule DB table for the module or updates existing metadata

Parameters:

existingServer -

applicationName -

module -

getAllServers

java.util.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

java.util.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

java.util.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 -

save

void save(Component component)

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

Parameters:

component -

getAllBusinessStreams

java.util.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

java.util.List<BusinessStream> getBusinessStreamsByUserId(java.lang.Long userId)

Get all BusinessStreams associated with a given user.

Parameters:

userId -

Returns:

getFlowsByServerIdAndModuleId

java.util.List<Flow> getFlowsByServerIdAndModuleId(java.lang.Long serverId,
                                                   java.lang.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(java.lang.String name)

Method to get a Module by its name.

Parameters:

name -

Returns:

getBusinessStreamsByUserId

java.util.List<BusinessStream> getBusinessStreamsByUserId(java.util.List<java.lang.Long> ids)

Get all BusinessStreams by a list of ids.

Parameters:

ids -

Returns:

discover

void discover(Server server,
              Module module,
              java.util.List<Flow> flows)
       throws DiscoveryException

Performs module discovery aka updates given module topology view with new latest flows and its components.

Parameters:

server - server wher given module resides

module - module to be updated

flows - list of flows dto containing high level information about flow

Throws:

DiscoveryException - exce

deleteBusinessStream

void deleteBusinessStream(BusinessStream businessStream)

Delete a business stream

Parameters:

businessStream -

discover

void discover(java.util.List<Server> servers,
              IkasanAuthentication authentication)
       throws DiscoveryException

Method to discovery and populate Ikasan topology

Parameters:

authentication -

Throws:

DiscoveryException

createFilter

Filter createFilter(java.lang.String name,
                    java.lang.String description,
                    java.lang.String createdBy,
                    java.util.Set<Component> components)

Create a filter.

Parameters:

name -

description -

createdBy -

components -

Returns:

getAllFilters

java.util.List<Filter> getAllFilters()

Returns:

saveFilter

void saveFilter(Filter filter)

Parameters:

filter -

deleteFilter

void deleteFilter(Filter filter)

Parameters:

filter -

saveRoleFilter

void saveRoleFilter(RoleFilter roleFilter)

Parameters:

roleFilter -

getRoleFilters

java.util.List<RoleFilter> getRoleFilters(java.util.List<java.lang.Long> roleIds)

Parameters:

roleId -

Returns:

getRoleFilterByFilterId

RoleFilter getRoleFilterByFilterId(java.lang.Long filterId)

Parameters:

roleId -

Returns:

deleteRoleFilter

void deleteRoleFilter(RoleFilter roleFilter)

Parameters:

roleFilter -

deleteFilterComponents

void deleteFilterComponents(java.lang.Long filterId)

Parameters:

filterId -

getFilterByName

Filter getFilterByName(java.lang.String name)

Parameters:

name -

Returns:

save

void save(Notification notification)

Parameters:

notification -

delete

void delete(Notification notification)

Parameters:

notification -

getNotificationByName

Notification getNotificationByName(java.lang.String name)

Parameters:

name -

Returns:

getAllNotifications

java.util.List<Notification> getAllNotifications()

Parameters:

name -

Returns: