Index

A B C D E F G H I M P R S T W
All Classes|All Packages|Constant Field Values|Serialized Form

A

addRawOptions(String) - Method in class com.zfabrik.impl.workers.home.CommandLineBuilder

addSysProperty(String, String, boolean) - Method in class com.zfabrik.impl.workers.home.CommandLineBuilder

addWatch(Thread, long, String) - Method in class com.zfabrik.impl.workers.TimeOutWatchDog

allWorkers() - Static method in class com.zfabrik.impl.workers.home.WorkerProcess

as(Class<T>) - Method in class com.zfabrik.impl.workers.home.HomeLayoutResource

as(Class<T>) - Method in class com.zfabrik.impl.workers.home.WorkerProcessResource

as(Class<T>) - Method in class com.zfabrik.impl.workers.MessageHandlerResource

as(Class<T>) - Method in class com.zfabrik.impl.workers.worker.WorkerSoul

B

Base64 - Class in com.zfabrik.impl.workers

A very fast and memory efficient class to encode and decode to and from BASE64 in full accordance with RFC 2045.

On Windows XP sp1 with 1.4.2_04 and later ;), this encoder and decoder is about 10 times faster on small arrays (10 - 1000 bytes) and 2-3 times as fast on larger arrays (10000 - 1000000 bytes) compared to sun.misc.Encoder()/Decoder().

On byte arrays the encoder is about 20% faster than Jakarta Commons Base64 Codec for encode and about 50% faster for decoding large arrays.

Base64() - Constructor for class com.zfabrik.impl.workers.Base64

BOUNDARY - Static variable in class com.zfabrik.impl.workers.MessageExchange

BOUNDARY_LENGTH - Static variable in class com.zfabrik.impl.workers.MessageExchange

C

close() - Method in class com.zfabrik.impl.workers.home.io.StdErrHandler

close() - Method in class com.zfabrik.impl.workers.home.io.StdOutHandler

close() - Method in interface com.zfabrik.impl.workers.IStreamEventHandler

close() - Method in class com.zfabrik.impl.workers.MessageExchange

close() - Method in class com.zfabrik.impl.workers.worker.WorkerEndPoint

close(boolean) - Method in class com.zfabrik.impl.workers.home.io.WorkerIO

close(boolean) - Method in class com.zfabrik.impl.workers.StreamReader

CMD_GETLOG - Static variable in class com.zfabrik.impl.workers.home.HomeMessageHandler

CMD_INVALIDATION - Static variable in class com.zfabrik.impl.workers.home.HomeMessageHandler

CMD_SYNC - Static variable in class com.zfabrik.impl.workers.home.HomeMessageHandler

CMD_VERIFY - Static variable in class com.zfabrik.impl.workers.home.HomeMessageHandler

CMDGROUP - Static variable in class com.zfabrik.impl.workers.home.HomeMessageHandler

com.zfabrik.impl.workers - package com.zfabrik.impl.workers

com.zfabrik.impl.workers.home - package com.zfabrik.impl.workers.home

com.zfabrik.impl.workers.home.io - package com.zfabrik.impl.workers.home.io

com.zfabrik.impl.workers.worker - package com.zfabrik.impl.workers.worker

COMMAND_ATTAINOP - Static variable in interface com.zfabrik.impl.workers.WorkerConstants

COMMAND_DETACH - Static variable in interface com.zfabrik.impl.workers.WorkerConstants

COMMAND_GETLEASE - Static variable in interface com.zfabrik.impl.workers.WorkerConstants

COMMAND_INVALIDATE - Static variable in interface com.zfabrik.impl.workers.WorkerConstants

COMMAND_PING - Static variable in interface com.zfabrik.impl.workers.WorkerConstants

COMMAND_TERM - Static variable in interface com.zfabrik.impl.workers.WorkerConstants

CommandLineBuilder - Class in com.zfabrik.impl.workers.home

A utility to build a worker process command line from various sources.

CommandLineBuilder(String, int) - Constructor for class com.zfabrik.impl.workers.home.CommandLineBuilder

CommandLineParser - Class in com.zfabrik.impl.workers.home

A simple utility to split a blank separated list of command line arguments while supporting quotes and escaping \.

CommandLineParser() - Constructor for class com.zfabrik.impl.workers.home.CommandLineParser

complete(ISynchronization) - Method in class com.zfabrik.impl.workers.home.WorkerSynchronizer

createComponentResource(String) - Method in class com.zfabrik.impl.workers.home.WorkerProcessFactory

createComponentResource(String) - Method in class com.zfabrik.impl.workers.MessageHandlerFactory

D

decode(byte[]) - Static method in class com.zfabrik.impl.workers.Base64

Decodes a BASE64 encoded byte array.

decode(char[]) - Static method in class com.zfabrik.impl.workers.Base64

Decodes a BASE64 encoded char array.

decode(String) - Static method in class com.zfabrik.impl.workers.Base64

Decodes a BASE64 encoded String.

decodeFast(byte[]) - Static method in class com.zfabrik.impl.workers.Base64

Decodes a BASE64 encoded byte array that is known to be resonably well formatted.

decodeFast(char[]) - Static method in class com.zfabrik.impl.workers.Base64

Decodes a BASE64 encoded char array that is known to be resonably well formatted.

decodeFast(String) - Static method in class com.zfabrik.impl.workers.Base64

Decodes a BASE64 encoded string that is known to be resonably well formatted.

decodeMessage(byte[]) - Static method in class com.zfabrik.impl.workers.MessageExchange

decouple() - Method in class com.zfabrik.impl.workers.home.io.StdErrHandler

decouple() - Method in class com.zfabrik.impl.workers.home.io.StdOutHandler

decouple() - Method in class com.zfabrik.impl.workers.home.io.WorkerIO

decouple() - Method in class com.zfabrik.impl.workers.StreamReader

decreaseLease() - Method in class com.zfabrik.impl.workers.worker.WorkerSoul

detach() - Method in class com.zfabrik.impl.workers.home.WorkerProcess

detach() - Method in interface com.zfabrik.impl.workers.home.WorkerProcessMBean

E

encodeMessage(OutputStream, Map<String, Serializable>) - Static method in class com.zfabrik.impl.workers.MessageExchange

encodeToByte(byte[], boolean) - Static method in class com.zfabrik.impl.workers.Base64

Encodes a raw byte array into a BASE64 byte[] representation i accordance with RFC 2045.

encodeToChar(byte[], boolean) - Static method in class com.zfabrik.impl.workers.Base64

Encodes a raw byte array into a BASE64 char[] representation i accordance with RFC 2045.

encodeToString(byte[], boolean) - Static method in class com.zfabrik.impl.workers.Base64

Encodes a raw byte array into a BASE64 String representation i accordance with RFC 2045.

ERROR - Static variable in class com.zfabrik.impl.workers.MessageExchange

F

forwardMessageToHandler(Logger, Map<String, Serializable>) - Static method in class com.zfabrik.impl.workers.MessageHandlerResource

fromConfig(String, int, Properties) - Static method in class com.zfabrik.impl.workers.home.CommandLineBuilder

Factory using the worker process configuration

G

getActiveWorkerProcess() - Method in class com.zfabrik.impl.workers.home.WorkerProcessResource

getCausesByNode() - Method in exception com.zfabrik.impl.workers.MessageDistributionException

getComponentName() - Method in class com.zfabrik.impl.workers.home.WorkerProcess

getComponentName() - Method in interface com.zfabrik.impl.workers.home.WorkerProcessMBean

getComponentName() - Method in class com.zfabrik.impl.workers.home.WorkerProcessResource

getCreated() - Method in class com.zfabrik.impl.workers.home.WorkerProcess

getDetachTime() - Method in class com.zfabrik.impl.workers.home.WorkerProcess

getDetachTime() - Method in interface com.zfabrik.impl.workers.home.WorkerProcessMBean

getError() - Method in class com.zfabrik.impl.workers.home.io.WorkerNotifier

getId() - Method in class com.zfabrik.impl.workers.home.io.WorkerNotifier

getLastAttemptedStart() - Method in interface com.zfabrik.impl.workers.home.WorkerProcessMBean

getLastError() - Method in interface com.zfabrik.impl.workers.home.WorkerProcessMBean

getLastSuccessfulStart() - Method in interface com.zfabrik.impl.workers.home.WorkerProcessMBean

getMaxQueueSize() - Method in class com.zfabrik.impl.workers.MessageExchange

getName() - Method in class com.zfabrik.impl.workers.home.WorkerProcess

getName() - Method in interface com.zfabrik.impl.workers.home.WorkerProcessMBean

getNumberAttemptedStarts() - Method in interface com.zfabrik.impl.workers.home.WorkerProcessMBean

getNumberSuccesfulStarts() - Method in interface com.zfabrik.impl.workers.home.WorkerProcessMBean

getPID() - Method in interface com.zfabrik.impl.workers.home.WorkerProcessMBean

getResult() - Method in class com.zfabrik.impl.workers.home.io.WorkerNotifier

getState() - Method in class com.zfabrik.impl.workers.home.WorkerProcess

getState() - Method in interface com.zfabrik.impl.workers.home.WorkerProcessMBean

getWorkerProcesses() - Method in class com.zfabrik.impl.workers.home.WorkerProcessResource

H

HomeLayoutMBean - Interface in com.zfabrik.impl.workers.home

JMX MBean interface of the home layout

HomeLayoutResource - Class in com.zfabrik.impl.workers.home

The home layout knows all currently running workers.

HomeLayoutResource() - Constructor for class com.zfabrik.impl.workers.home.HomeLayoutResource

HomeMessageHandler - Class in com.zfabrik.impl.workers.home

Receives messages from worker processes and (if so needed) forwards.

HomeMessageHandler() - Constructor for class com.zfabrik.impl.workers.home.HomeMessageHandler

I

increaseLease() - Method in class com.zfabrik.impl.workers.worker.WorkerSoul

init() - Method in class com.zfabrik.impl.workers.home.HomeLayoutResource

init() - Method in class com.zfabrik.impl.workers.worker.WorkerSoul

invalidate() - Method in class com.zfabrik.impl.workers.home.HomeLayoutResource

invalidate() - Method in class com.zfabrik.impl.workers.home.WorkerProcessResource

invalidate() - Method in class com.zfabrik.impl.workers.MessageHandlerResource

invalidate() - Method in class com.zfabrik.impl.workers.worker.WorkerSoul

INVALIDATIONSET - Static variable in interface com.zfabrik.impl.workers.WorkerConstants

isActive() - Method in class com.zfabrik.impl.workers.home.io.StdOutHandler

isDetached() - Method in class com.zfabrik.impl.workers.home.WorkerProcess

isRunning() - Method in class com.zfabrik.impl.workers.home.WorkerProcess

IStreamEventHandler - Interface in com.zfabrik.impl.workers

M

MessageDistributionException - Exception in com.zfabrik.impl.workers

MessageDistributionException(String) - Constructor for exception com.zfabrik.impl.workers.MessageDistributionException

MessageDistributionException(String, Throwable) - Constructor for exception com.zfabrik.impl.workers.MessageDistributionException

MessageDistributionException(String, Map<String, Throwable>) - Constructor for exception com.zfabrik.impl.workers.MessageDistributionException

MessageException - Exception in com.zfabrik.impl.workers

MessageException(String) - Constructor for exception com.zfabrik.impl.workers.MessageException

MessageException(String, Throwable) - Constructor for exception com.zfabrik.impl.workers.MessageException

MessageExchange - Class in com.zfabrik.impl.workers

abstracts our communication model: Messages are pushed in from a stream and sent out to a stream.

MessageExchange(Logger, IMessageHandler, IThreadPool, OutputStream) - Constructor for class com.zfabrik.impl.workers.MessageExchange

MessageExchangeClosed - Exception in com.zfabrik.impl.workers

MessageExchangeClosed() - Constructor for exception com.zfabrik.impl.workers.MessageExchangeClosed

MessageHandlerFactory - Class in com.zfabrik.impl.workers

MessageHandlerFactory() - Constructor for class com.zfabrik.impl.workers.MessageHandlerFactory

MessageHandlerResource - Class in com.zfabrik.impl.workers

MessageHandlerResource(String) - Constructor for class com.zfabrik.impl.workers.MessageHandlerResource

MessageTimeOutException - Exception in com.zfabrik.impl.workers

MessageTimeOutException(long, long) - Constructor for exception com.zfabrik.impl.workers.MessageTimeOutException

P

PARAM_RESOURCES - Static variable in class com.zfabrik.impl.workers.home.HomeMessageHandler

PARAM_SCOPE - Static variable in class com.zfabrik.impl.workers.home.HomeMessageHandler

PARAM_WORKER - Static variable in class com.zfabrik.impl.workers.home.HomeMessageHandler

ping() - Method in interface com.zfabrik.impl.workers.home.WorkerProcessMBean

preInvalidation(ISynchronization) - Method in class com.zfabrik.impl.workers.home.WorkerSynchronizer

prepare() - Method in class com.zfabrik.impl.workers.home.WorkerProcessResource

prepare(String) - Method in interface com.zfabrik.impl.workers.home.HomeLayoutMBean

Prepare an arbitrary component.

process(String) - Method in class com.zfabrik.impl.workers.home.io.StdErrHandler

process(String) - Method in class com.zfabrik.impl.workers.home.io.StdOutHandler

this method gets called asynchronously when there is data available on the out stream of the child process.

process(String) - Method in interface com.zfabrik.impl.workers.IStreamEventHandler

process(String) - Method in class com.zfabrik.impl.workers.worker.WorkerEndPoint

processLine(String) - Method in class com.zfabrik.impl.workers.MessageExchange

process a line of input.

processMessage(Map<String, Serializable>) - Method in class com.zfabrik.impl.workers.home.HomeMessageHandler

processMessage(Map<String, Serializable>) - Method in class com.zfabrik.impl.workers.home.io.StdOutHandler

an unsolicited message has been received.

processMessage(Map<String, Serializable>) - Method in class com.zfabrik.impl.workers.worker.WorkerSoul

Handling of messages sent from home.

R

removeWatch(Object) - Method in class com.zfabrik.impl.workers.TimeOutWatchDog

RES_LOG - Static variable in class com.zfabrik.impl.workers.home.HomeMessageHandler

restart() - Method in interface com.zfabrik.impl.workers.home.WorkerProcessMBean

run() - Method in class com.zfabrik.impl.workers.home.io.WorkerNotifier

run() - Method in class com.zfabrik.impl.workers.StreamReader

run() - Method in class com.zfabrik.impl.workers.worker.WorkerSoul

S

sendMessage(Map<String, Serializable>, long) - Method in class com.zfabrik.impl.workers.home.io.StdOutHandler

send a message.

sendMessage(Map<String, Serializable>, long) - Method in class com.zfabrik.impl.workers.home.io.WorkerIO

sendMessage(Map<String, Serializable>, long) - Method in class com.zfabrik.impl.workers.home.WorkerProcess

sendMessage(Map<String, Serializable>, long) - Method in class com.zfabrik.impl.workers.MessageExchange

Send a message and wait for a response with a timeout.

sendMessage(Map<String, Serializable>, long) - Method in class com.zfabrik.impl.workers.worker.WorkerEndPoint

sendMessage(Map<String, Serializable>, long, boolean) - Method in class com.zfabrik.impl.workers.home.WorkerProcess

setClassPath(String) - Method in class com.zfabrik.impl.workers.home.CommandLineBuilder

setState(short) - Method in class com.zfabrik.impl.workers.home.WorkerProcess

split(String) - Static method in class com.zfabrik.impl.workers.home.CommandLineParser

start() - Method in class com.zfabrik.impl.workers.home.WorkerProcess

StdErrHandler - Class in com.zfabrik.impl.workers.home.io

Simply catches the output and writes it to some collected log...

StdErrHandler(String, Logger, Logger, IWorkerProcess) - Constructor for class com.zfabrik.impl.workers.home.io.StdErrHandler

StdOutHandler - Class in com.zfabrik.impl.workers.home.io

Handles the out stream of a worker process, i.e.

StdOutHandler(OutputStream, String, Logger, Logger, IWorkerProcess) - Constructor for class com.zfabrik.impl.workers.home.io.StdOutHandler

stop() - Method in class com.zfabrik.impl.workers.home.WorkerProcess

stop() - Method in interface com.zfabrik.impl.workers.home.WorkerProcessMBean

stop() - Method in class com.zfabrik.impl.workers.TimeOutWatchDog

stop(long) - Method in class com.zfabrik.impl.workers.home.WorkerProcess

StreamReader - Class in com.zfabrik.impl.workers

StreamReader(Reader, Logger, IStreamEventHandler) - Constructor for class com.zfabrik.impl.workers.StreamReader

T

test_getProcess() - Method in class com.zfabrik.impl.workers.home.WorkerProcess

TICKET - Static variable in class com.zfabrik.impl.workers.MessageExchange

TIMEOUT - Static variable in class com.zfabrik.impl.workers.MessageExchange

TimeOutWatchDog - Class in com.zfabrik.impl.workers

helper utility to warn about hanging threads

TimeOutWatchDog(String) - Constructor for class com.zfabrik.impl.workers.TimeOutWatchDog

toString() - Method in class com.zfabrik.impl.workers.home.WorkerProcess

toString() - Method in exception com.zfabrik.impl.workers.MessageDistributionException

toStringArray() - Method in class com.zfabrik.impl.workers.home.CommandLineBuilder

TYPE - Static variable in class com.zfabrik.impl.workers.MessageExchange

TYPE_M - Static variable in class com.zfabrik.impl.workers.MessageExchange

TYPE_R - Static variable in class com.zfabrik.impl.workers.MessageExchange

W

waitFor(long) - Method in class com.zfabrik.impl.workers.home.io.WorkerIO

spend some time waiting for termination

waitFor(long) - Method in class com.zfabrik.impl.workers.StreamReader

WORKER_LAUNCHER - Static variable in class com.zfabrik.impl.workers.home.CommandLineBuilder

WorkerConstants - Interface in com.zfabrik.impl.workers

Command line properties for worker processes

workerDesc() - Method in class com.zfabrik.impl.workers.worker.WorkerSoul

workerDetached(IWorkerProcess) - Static method in class com.zfabrik.impl.workers.home.WorkerProcess

WorkerEndPoint - Class in com.zfabrik.impl.workers.worker

End point to receive home messages.

WorkerEndPoint(IMessageHandler, Logger) - Constructor for class com.zfabrik.impl.workers.worker.WorkerEndPoint

WorkerIO - Class in com.zfabrik.impl.workers.home.io

WorkerIO(String, Process, IWorkerProcess) - Constructor for class com.zfabrik.impl.workers.home.io.WorkerIO

WorkerNotifier - Class in com.zfabrik.impl.workers.home.io

task that forwards a message to a dedicated worker process

WorkerNotifier(Map<String, Serializable>, IWorkerProcess, long, boolean) - Constructor for class com.zfabrik.impl.workers.home.io.WorkerNotifier

WorkerProcess - Class in com.zfabrik.impl.workers.home

An instance of this class represents a z2 worker process to the <home> process.

WorkerProcess(String, IComponentDescriptor, int) - Constructor for class com.zfabrik.impl.workers.home.WorkerProcess

WorkerProcessFactory - Class in com.zfabrik.impl.workers.home

WorkerProcessFactory() - Constructor for class com.zfabrik.impl.workers.home.WorkerProcessFactory

WorkerProcessMBean - Interface in com.zfabrik.impl.workers.home

WorkerProcessResource - Class in com.zfabrik.impl.workers.home

A worker process resource manages zero or more running worker instances.

WorkerProcessResource(String) - Constructor for class com.zfabrik.impl.workers.home.WorkerProcessResource

WorkerSoul - Class in com.zfabrik.impl.workers.worker

This component implementation is the life keeper of the worker processs.

WorkerSoul() - Constructor for class com.zfabrik.impl.workers.worker.WorkerSoul

workerStarted(IWorkerProcess) - Static method in class com.zfabrik.impl.workers.home.WorkerProcess

WorkerSynchronizer - Class in com.zfabrik.impl.workers.home

This synchronizer takes care that worker processes receive invalidations and attain their target states again.

WorkerSynchronizer() - Constructor for class com.zfabrik.impl.workers.home.WorkerSynchronizer

A B C D E F G H I M P R S T W
All Classes|All Packages|Constant Field Values|Serialized Form