org.oddjob.web

Class WebClientJob

java.lang.Object

org.oddjob.framework.extend.BaseComponent

org.oddjob.framework.extend.SimpleService

org.oddjob.web.WebClientJob

All Implemented Interfaces:

java.lang.Runnable, ArooaContextAware, ArooaSessionAware, BeanDirectoryOwner, PropertyChangeNotifier, Iconic, RemoteDirectoryOwner, ConsoleArchiver, LogArchiver, LogEnabled, Resetable, Stateful, Stoppable, Structural

public class WebClientJob
extends SimpleService
implements Structural, LogArchiver, ConsoleArchiver, RemoteDirectoryOwner

Description

An Oddjob client that works over http.

Author:

Rob Gordon

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	WebClientJob.WhyStop

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_LOG_POLLING_INTERVAL

Fields inherited from interface org.oddjob.logging.LogArchiver

MAX_HISTORY, NO_LOG_AVAILABLE

Constructor Summary

Constructors

Constructor and Description
WebClientJob()

Method Summary

Modifier and Type	Method and Description
void	addConsoleListener(LogListener l, java.lang.Object component, long last, int max) Add a listener to the archiver which will receive all missed events.
void	addLogListener(LogListener l, java.lang.Object component, LogLevel level, long last, int history) Add a listener to the archiver which will receive all missed events.
void	addStructuralListener(StructuralListener listener) Add a listener.
java.lang.String	consoleIdFor(java.lang.Object component) Get the console id for a given component.
protected void	doStart(RemoteConnection mbsc, java.util.concurrent.ScheduledExecutorService notificationProcessor)
protected void	doStop(WebClientJob.WhyStop why, java.lang.Exception cause)
HandlerFactoryProvider	getHandlerFactories()
long	getHeartbeat()
java.lang.String	getHost()
long	getLogPollingInterval()
int	getMaxConsoleLines()
int	getMaxLoggerLines()
int	getPort()
void	onInitialised() Subclasses override this method to perform post creation initialisation.
protected void	onStart()
protected void	onStop() Allow sub classes to do something on stop.
protected void	onStop(WebClientJob.WhyStop why)
RemoteDirectory	provideBeanDirectory() Provide a remote directory.
void	removeConsoleListener(LogListener l, java.lang.Object component) Remove the LogListener.
void	removeLogListener(LogListener l, java.lang.Object component) Remove the LogListener.
void	removeStructuralListener(StructuralListener listener) Remove a listener.
void	setHandlerFactories(HandlerFactoryProvider handlerFactories)
void	setHeartbeat(long heartbeat)
void	setHost(java.lang.String host)
void	setLogPollingInterval(long logPollingInterval)
void	setMaxConsoleLines(int maxConsoleLines)
void	setMaxLoggerLines(int maxLoggerLines)
void	setPort(int port)

Methods inherited from class org.oddjob.framework.extend.SimpleService

fireDestroyedState, getName, getStateChanger, hardReset, iconHelper, logger, loggerName, onDestroy, run, setName, softReset, stateHandler, stop, toString

Methods inherited from class org.oddjob.framework.extend.BaseComponent

addIconListener, addPropertyChangeListener, addStateListener, configure, destroy, firePropertyChange, getArooaSession, iconForId, initialise, lastStateEvent, onConfigured, removeIconListener, removePropertyChangeListener, removeStateListener, save, save, setArooaContext, setArooaSession

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.oddjob.Stateful

addStateListener, lastStateEvent, removeStateListener

Field Detail

DEFAULT_LOG_POLLING_INTERVAL

public static final long DEFAULT_LOG_POLLING_INTERVAL

See Also:

Constant Field Values

Constructor Detail

WebClientJob

public WebClientJob()

Method Detail

addLogListener

public void addLogListener(LogListener l,
                           java.lang.Object component,
                           LogLevel level,
                           long last,
                           int history)

Description copied from interface: LogArchiver

Add a listener to the archiver which will receive all missed events. The idea of receiving only missed events is to minimise network traffic when used remotely.

Event numbers begin at 0. To receive all events, last must be -1.

Specified by:

addLogListener in interface LogArchiver

Parameters:

l - The logListener which will receive the events.

level - The level of events required.

last - The last event number received. The LogArchive will not send messages from before this number.

history - The maximum messages to send up to the most recent.

removeLogListener

public void removeLogListener(LogListener l,
                              java.lang.Object component)

Description copied from interface: LogArchiver

Remove the LogListener.

Specified by:

removeLogListener in interface LogArchiver

Parameters:

l - The LogListener.

addConsoleListener

public void addConsoleListener(LogListener l,
                               java.lang.Object component,
                               long last,
                               int max)

Description copied from interface: ConsoleArchiver

Add a listener to the archiver which will receive all missed events. The idea of receiving only missed event is to minimise network traffic when used remotely.

Specified by:

addConsoleListener in interface ConsoleArchiver

Parameters:

l - The logListener which will receive the events.

component - The component whose console to receive events for.

last - The last event number received. The LogArchive will not send messages from before this number.

max - The maximum messages to send up to the most recent.

removeConsoleListener

public void removeConsoleListener(LogListener l,
                                  java.lang.Object component)

Description copied from interface: ConsoleArchiver

Remove the LogListener.

Specified by:

removeConsoleListener in interface ConsoleArchiver

Parameters:

l - The LogListener.

consoleIdFor

public java.lang.String consoleIdFor(java.lang.Object component)

Description copied from interface: ConsoleArchiver

Get the console id for a given component.

Specified by:

consoleIdFor in interface ConsoleArchiver

Parameters:

component - The component.

Returns:

The console id.

onInitialised

public void onInitialised()

Description copied from class: BaseComponent

Subclasses override this method to perform post creation initialisation.

Overrides:

onInitialised in class BaseComponent

onStart

protected void onStart()
                throws java.lang.Throwable

Specified by:

onStart in class SimpleService

Throws:

java.lang.Exception

java.lang.Throwable

doStart

protected void doStart(RemoteConnection mbsc,
                       java.util.concurrent.ScheduledExecutorService notificationProcessor)

onStop

protected void onStop()

Description copied from class: SimpleService

Allow sub classes to do something on stop.

Overrides:

onStop in class SimpleService

doStop

protected void doStop(WebClientJob.WhyStop why,
                      java.lang.Exception cause)

onStop

protected void onStop(WebClientJob.WhyStop why)

provideBeanDirectory

public RemoteDirectory provideBeanDirectory()

Description copied from interface: RemoteDirectoryOwner

Provide a remote directory.

Specified by:

provideBeanDirectory in interface BeanDirectoryOwner

Specified by:

provideBeanDirectory in interface RemoteDirectoryOwner

Returns:

The BeanDirectory or null.

addStructuralListener

public void addStructuralListener(StructuralListener listener)

Description copied from interface: Structural

Add a listener. The listener will immediately receive add notifications for all existing children.

Specified by:

addStructuralListener in interface Structural

Parameters:

listener - The listener.

removeStructuralListener

public void removeStructuralListener(StructuralListener listener)

Description copied from interface: Structural

Remove a listener.

Specified by:

removeStructuralListener in interface Structural

Parameters:

listener - The listener.

getHeartbeat

public long getHeartbeat()

setHeartbeat

public void setHeartbeat(long heartbeat)

getHost

public java.lang.String getHost()

setHost

public void setHost(java.lang.String host)

getPort

public int getPort()

setPort

public void setPort(int port)

getMaxConsoleLines

public int getMaxConsoleLines()

setMaxConsoleLines

public void setMaxConsoleLines(int maxConsoleLines)

getMaxLoggerLines

public int getMaxLoggerLines()

setMaxLoggerLines

public void setMaxLoggerLines(int maxLoggerLines)

getLogPollingInterval

public long getLogPollingInterval()

setLogPollingInterval

public void setLogPollingInterval(long logPollingInterval)

getHandlerFactories

public HandlerFactoryProvider getHandlerFactories()

setHandlerFactories

public void setHandlerFactories(HandlerFactoryProvider handlerFactories)