org.ow2.proactive.scheduler.common.util.logforwarder.providers

Class ProActiveBasedForwardingProvider

java.lang.Object

org.ow2.proactive.scheduler.common.util.logforwarder.providers.ProActiveBasedForwardingProvider

All Implemented Interfaces:

LogForwardingProvider

public class ProActiveBasedForwardingProvider
extends Object
implements LogForwardingProvider

ProActive communication based log forwarding service.

See Also:

ProActiveAppender

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ProActiveBasedForwardingProvider.LogCollector
static class	ProActiveBasedForwardingProvider.LogCollectorDeployer
static class	ProActiveBasedForwardingProvider.ProActiveAppenderProvider

Field Summary

Fields

Modifier and Type	Field and Description
static String	COLLECTOR_BIND_NAME

Constructor Summary

Constructors

Constructor and Description
ProActiveBasedForwardingProvider()

Method Summary

Modifier and Type	Method and Description
AppenderProvider	createAppenderProvider(URI serverURI) Create an appender provider (i.e.
URI	createServer(LoggingEventProcessor eventProcessor) Create locally a server that is able to receive logging events from the appender created by createAppenderProvider.
void	terminateServer() Terminate the server created by createServer().

Methods inherited from class java.lang.Object

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

Field Detail

COLLECTOR_BIND_NAME

public static final String COLLECTOR_BIND_NAME

See Also:

Constant Field Values

Constructor Detail

ProActiveBasedForwardingProvider

public ProActiveBasedForwardingProvider()

Method Detail

createAppenderProvider

public AppenderProvider createAppenderProvider(URI serverURI)
                                        throws LogForwardingException

Description copied from interface: LogForwardingProvider

Create an appender provider (i.e. a container for appender). This provider is serializable and can be remotely sent. Note that a specific AppenderProvider implementation must be provided with a specific LogForwardingProvider implementation.

Specified by:

createAppenderProvider in interface LogForwardingProvider

Parameters:

serverURI - the URI of the server that receives logging events appended in the contained appender.

Returns:

a container for an appender.

Throws:

LogForwardingException - if the provider cannot be created.

createServer

public URI createServer(LoggingEventProcessor eventProcessor)
                 throws LogForwardingException

Description copied from interface: LogForwardingProvider

Create locally a server that is able to receive logging events from the appender created by createAppenderProvider.

Specified by:

createServer in interface LogForwardingProvider

Returns:

the URI to reach this server.

Throws:

LogForwardingException - if the server cannot be created.

terminateServer

public void terminateServer()
                     throws LogForwardingException

Description copied from interface: LogForwardingProvider

Terminate the server created by createServer().

Specified by:

terminateServer in interface LogForwardingProvider

Throws:

LogForwardingException - if the server cannot be terminated.