org.ikasan.topology.service

Class TopologyServiceImpl

java.lang.Object

org.ikasan.topology.service.TopologyServiceImpl

All Implemented Interfaces:

TopologyService

public class TopologyServiceImpl
extends java.lang.Object
implements TopologyService

Author:

Ikasan Development Team

Constructor Summary

Constructors

Constructor and Description
TopologyServiceImpl(TopologyDao topologyDao) Constructor

Method Summary

Modifier and Type	Method and Description
protected void	cleanup()
protected void	cleanUpComponents()
protected void	cleanUpComponents(java.lang.Long serverId, java.lang.Long moduleId, java.lang.String flowName, java.util.List<java.lang.String> discoveredComponentNames)
protected void	cleanUpFlows()
protected void	cleanUpFlows(Module module, java.lang.Long serverId, java.lang.Long moduleId, java.util.List<java.lang.String> discoveredFlowNames)
protected void	cleanUpModules()
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.
protected java.util.Set<Flow>	discoverFlows(java.lang.Long serverId, Module module, java.util.List<Flow> flowList)
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.
protected Component	getComponent(java.util.Set<Component> components, Component component)
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 server, 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)

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 java.util.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 java.util.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 java.util.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 java.util.List<BusinessStream> getAllBusinessStreams()

Description copied from interface: TopologyService

Get all BusinessStreams

Specified by:

getAllBusinessStreams in interface TopologyService

Returns:

save

public void save(Component component)

Description copied from interface: TopologyService

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

Specified by:

save in interface TopologyService

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 java.util.List<BusinessStream> getBusinessStreamsByUserId(java.lang.Long userId)

Description copied from interface: TopologyService

Get all BusinessStreams associated with a given user.

Specified by:

getBusinessStreamsByUserId in interface TopologyService

Returns:

getFlowsByServerIdAndModuleId

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

Description copied from interface: TopologyService

Method to get a Module by its name.

Specified by:

getModuleByName in interface TopologyService

Returns:

getBusinessStreamsByUserId

public java.util.List<BusinessStream> getBusinessStreamsByUserId(java.util.List<java.lang.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(java.util.List<Server> servers,
                     IkasanAuthentication authentication)
              throws DiscoveryException

Description copied from interface: TopologyService

Method to discovery and populate Ikasan topology

Specified by:

discover in interface TopologyService

Throws:

DiscoveryException

initialiseModuleMetaData

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

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

Specified by:

initialiseModuleMetaData in interface TopologyService

Parameters:

server -

applicationName -

module -

discover

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

Description copied from interface: TopologyService

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

Specified by:

discover in interface TopologyService

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

discoverFlows

protected java.util.Set<Flow> discoverFlows(java.lang.Long serverId,
                                            Module module,
                                            java.util.List<Flow> flowList)

cleanup

protected void cleanup()

cleanUpModules

protected void cleanUpModules()

cleanUpFlows

protected void cleanUpFlows()

cleanUpComponents

protected void cleanUpComponents()

cleanUpFlows

protected void cleanUpFlows(Module module,
                            java.lang.Long serverId,
                            java.lang.Long moduleId,
                            java.util.List<java.lang.String> discoveredFlowNames)

cleanUpComponents

protected void cleanUpComponents(java.lang.Long serverId,
                                 java.lang.Long moduleId,
                                 java.lang.String flowName,
                                 java.util.List<java.lang.String> discoveredComponentNames)

getComponent

protected Component getComponent(java.util.Set<Component> components,
                                 Component component)

deleteBusinessStream

public void deleteBusinessStream(BusinessStream businessStream)

Description copied from interface: TopologyService

Delete a business stream

Specified by:

deleteBusinessStream in interface TopologyService

createFilter

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

Description copied from interface: TopologyService

Create a filter.

Specified by:

createFilter in interface TopologyService

Returns:

getAllFilters

public java.util.List<Filter> getAllFilters()

Specified by:

getAllFilters in interface TopologyService

Returns:

saveFilter

public void saveFilter(Filter filter)

Specified by:

saveFilter in interface TopologyService

deleteFilter

public void deleteFilter(Filter filter)

Specified by:

deleteFilter in interface TopologyService

saveRoleFilter

public void saveRoleFilter(RoleFilter roleFilter)

Specified by:

saveRoleFilter in interface TopologyService

getRoleFilters

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

Specified by:

getRoleFilters in interface TopologyService

Returns:

deleteRoleFilter

public void deleteRoleFilter(RoleFilter roleFilter)

Specified by:

deleteRoleFilter in interface TopologyService

getRoleFilterByFilterId

public RoleFilter getRoleFilterByFilterId(java.lang.Long filterId)

Specified by:

getRoleFilterByFilterId in interface TopologyService

Returns:

deleteFilterComponents

public void deleteFilterComponents(java.lang.Long filterId)

Specified by:

deleteFilterComponents in interface TopologyService

getFilterByName

public Filter getFilterByName(java.lang.String name)

Specified by:

getFilterByName in interface TopologyService

Returns:

save

public void save(Notification notification)

Specified by:

save in interface TopologyService

delete

public void delete(Notification notification)

Specified by:

delete in interface TopologyService

getNotificationByName

public Notification getNotificationByName(java.lang.String name)

Specified by:

getNotificationByName in interface TopologyService

Returns:

getAllNotifications

public java.util.List<Notification> getAllNotifications()

Specified by:

getAllNotifications in interface TopologyService

Returns: