A B C D E F G H I L M O P R S T

A

ActiveInputChannel<M> - Interface in org.jph.channels.active

Work in progress.

ActiveOutputChannel<M> - Interface in org.jph.channels.active

The ActiveOutputChannel wraps an OutputChannel to make it active (use his own threads) and not the thread that is putting the message on the OutputChannel.

ActiveOutputChannelMBean - Interface in org.jph.channels.active.jmx

ActiveOutputChannelMBeanImpl - Class in org.jph.channels.active.jmx

ActiveOutputChannelMBeanImpl(ActiveOutputChannel) - Constructor for class org.jph.channels.active.jmx.ActiveOutputChannelMBeanImpl

add(OutRouterEntry<M>) - Method in interface org.jph.channels.router.RoutingOutputChannel

add(OutRouterEntry<M>) - Method in class org.jph.channels.router.StdRoutingOutputChannel

B

BufferedChannel<M> - Interface in org.jph.channels.bufferedChannel

The BufferedChannel is a Channel where messages can stored if they are faster send than removed.

C

Channel<M> - Interface in org.jph.channels

A Channel is something messages can flow through.

ChannelUtil - Class in org.jph.channels

De ChannelUtil is een util class waar methodes in staan die niet in de Channel implementatie horen.

clone(M) - Method in interface org.jph.channels.MessageCloner

Clones the msg.

clone(M) - Method in class org.jph.channels.SelfMessageCloner

close() - Method in interface org.jph.channels.regulate.jmx.RegulatingOutputChannelMBean

Signals the RegulatingOutputChannel to close.

close() - Method in class org.jph.channels.regulate.jmx.RegulatingOutputChannelMBeanImpl

close() - Method in interface org.jph.channels.regulate.RegulatingOutputChannel

Closes this RegulatingOutputChannel.

close(long, TimeUnit) - Method in interface org.jph.channels.regulate.RegulatingOutputChannel

Closes this RegulatingOutputChannel.

close() - Method in class org.jph.channels.regulate.StdRegulatingOutputChannel

close(long, TimeUnit) - Method in class org.jph.channels.regulate.StdRegulatingOutputChannel

ComposedChannel<M> - Class in org.jph.channels

Example:

ComposedChannel(OutputChannel<M>, InputChannel<M>) - Constructor for class org.jph.channels.ComposedChannel

D

DeadLetterOutputChannel<M> - Class in org.jph.channels

The DeadLetterOutputChannel is an OutputChannel that receives messages but doesn`t so anything with them.

DeadLetterOutputChannel() - Constructor for class org.jph.channels.DeadLetterOutputChannel

DEFAULT - Static variable in class org.jph.channels.active.StdActiveOuputChannel

deregister(I) - Method in interface org.jph.channels.ProcessingMap

deregister(I) - Method in class org.jph.channels.StdProcessingMap

E

entries() - Method in interface org.jph.channels.router.RoutingOutputChannel

Returns all the OutRouterEntries.

entries() - Method in class org.jph.channels.router.StdRoutingOutputChannel

ExceptionUtil - Class in org.jph.channels.logging

F

filter(OutputChannel<M>, Predicate<M>) - Static method in class org.jph.channels.ChannelUtil

Make a new channel based on another channel and a filter.

FilteringInputChannel<M> - Interface in org.jph.channels.filter

The FilteredIntputChannel is a InputChannel that can filter messages from a target InputChannel.

FilteringOutputChannel<M> - Interface in org.jph.channels.filter

The FilteringOutputChannel is an OutputChannel that can filter messages.

G

getActivatingInputChannel() - Method in interface org.jph.channels.active.ActiveInputChannel

getActivatingInputChannel() - Method in class org.jph.channels.active.StdActiveInputChannel

getAddedTotal() - Method in class org.jph.channels.management.MonitoringOutputChannel

getBlockedExecutor() - Method in interface org.jph.channels.active.ActiveInputChannel

getBlockedExecutor() - Method in interface org.jph.channels.active.ActiveOutputChannel

Returns the BlockingExecutor this ActiveoutputChannel is using to put messages on the target.

getBlockedExecutor() - Method in class org.jph.channels.active.StdActiveInputChannel

getBlockedExecutor() - Method in class org.jph.channels.active.StdActiveOuputChannel

getCapacity() - Method in class org.jph.channels.active.jmx.ActiveOutputChannelMBeanImpl

getChannel() - Method in class org.jph.channels.router.OutRouterEntry

Returns the OutputChannel where the message can be send to.

getExceptionHandler() - Method in interface org.jph.channels.process.ProcessingOutputChannel

Return the ProcessExceptionHandler this ProcessingOutputChannel uses to deal with errors that occured while processing the message.

getExceptionHandler() - Method in class org.jph.channels.process.StdProcessingOutputChannel

getFailOutputChannel() - Method in interface org.jph.channels.router.RoutingOutputChannel

Returns the OutputChannel that is used if a message could not be send to a receiver.

getFailOutputChannel() - Method in class org.jph.channels.router.StdRoutingOutputChannel

Returns the OutputChannel where all messages are send to that can`t be delivered.

getFailureDestination() - Method in interface org.jph.channels.filter.FilteringOutputChannel

Returns the OutputChannel the message is send to if it is rejected.

getFailureDestination() - Method in class org.jph.channels.filter.StdFilteringOutputChannel

getFilterPredicate() - Method in interface org.jph.channels.filter.FilteringInputChannel

Returns the MessagePredicate that checks if a message is valid or not.

getFilterPredicate() - Method in interface org.jph.channels.filter.FilteringOutputChannel

Returns the MessageFilter this FilteringOutputChannel uses to filter the messages.

getFilterPredicate() - Method in class org.jph.channels.filter.StdFilteringInputChannel

getFilterPredicate() - Method in class org.jph.channels.filter.StdFilteringOutputChannel

getInterruptedCounter() - Method in class org.jph.channels.management.MonitoringOutputChannel

getInterruptHandler() - Method in interface org.jph.channels.active.ActiveOutputChannel

Returns the InterruptHandler this ActiveOutputChannels calls if an post/offer is interrupted.

getInterruptHandler() - Method in class org.jph.channels.active.StdActiveOuputChannel

getJobCount() - Method in class org.jph.channels.active.jmx.ActiveOutputChannelMBeanImpl

getMessageCloner() - Method in class org.jph.channels.router.StdRoutingOutputChannel

getMod() - Method in interface org.jph.channels.logging.jmx.LoggingOutputChannelMBean

getMod() - Method in class org.jph.channels.logging.jmx.LoggingOutputChannelMBeanImpl

getMod() - Method in class org.jph.channels.logging.Log4jOutputChannel

getMod() - Method in interface org.jph.channels.logging.LoggingOutputChannel

getMod() - Method in class org.jph.channels.logging.SimpleLoggingOutputChannel

getMsgProcessor() - Method in interface org.jph.channels.process.ProcessingOutputChannel

Returns the Processor this ProcessingOutputChannel uses to process the messages.

getMsgProcessor() - Method in class org.jph.channels.process.StdProcessingOutputChannel

getOfferCount() - Method in class org.jph.channels.management.MonitoringOutputChannel

getOfferFailedCount() - Method in class org.jph.channels.management.MonitoringOutputChannel

getPredicate() - Method in class org.jph.channels.router.OutRouterEntry

Returns the MessagePredicate that checks if a message can be send to the OutputChannel.

getPutCount() - Method in class org.jph.channels.management.MonitoringOutputChannel

getQueue() - Method in interface org.jph.channels.bufferedChannel.BufferedChannel

Returns the BlockingQueue this BufferedChannel uses to store the messages that aren`t retrieved.

getQueue() - Method in class org.jph.channels.bufferedChannel.StdBufferedChannel

Returns the BlockingQueue that is used to store messages that aren`t retrieved.

getSource() - Method in interface org.jph.channels.filter.FilteringInputChannel

getSource() - Method in class org.jph.channels.filter.StdFilteringInputChannel

getSuccesDestination() - Method in interface org.jph.channels.filter.FilteringOutputChannel

Returns the OutputChannel the message is send to, if it is accepted.

getSuccesDestination() - Method in class org.jph.channels.filter.StdFilteringOutputChannel

getTarget() - Method in interface org.jph.channels.active.ActiveOutputChannel

Returns the OutputChannel (target) this ActiveOutputChannel is making active.

getTarget() - Method in class org.jph.channels.active.StdActiveOuputChannel

getTarget() - Method in class org.jph.channels.logging.Log4jInputChannel

getTarget() - Method in class org.jph.channels.logging.Log4jOutputChannel

getTarget() - Method in interface org.jph.channels.logging.LoggingInputChannel

Returns the InputChannel to log.

getTarget() - Method in interface org.jph.channels.logging.LoggingOutputChannel

Returns the OutputChannel to log.

getTarget() - Method in class org.jph.channels.logging.SimpleLoggingOutputChannel

getTarget() - Method in class org.jph.channels.management.MonitoringOutputChannel

getTarget() - Method in interface org.jph.channels.process.ProcessingOutputChannel

Returns the OutputChannel the resulting message (if it isn`t null) is send to.

getTarget() - Method in class org.jph.channels.process.StdProcessingOutputChannel

getTarget() - Method in interface org.jph.channels.regulate.RegulatingOutputChannel

Returns the target OutputChannel to be opened/closed.

getTarget() - Method in class org.jph.channels.regulate.StdRegulatingOutputChannel

getToString() - Method in class org.jph.channels.logging.Log4jInputChannel

getToString() - Method in class org.jph.channels.logging.Log4jOutputChannel

getToString() - Method in class org.jph.channels.logging.SimpleLoggingOutputChannel

H

halt() - Method in interface org.jph.channels.active.jmx.ActiveOutputChannelMBean

halt() - Method in class org.jph.channels.active.jmx.ActiveOutputChannelMBeanImpl

handle(M, ActiveOutputChannel<M>) - Method in interface org.jph.channels.active.InterruptHandler

handle(M, ActiveOutputChannel<M>) - Method in class org.jph.channels.active.ThrowingInterruptHandler

handleError(ProcessingOutputChannel, M, Exception) - Method in interface org.jph.channels.process.ProcessExceptionHandler

handleError(ProcessingOutputChannel, M, Exception) - Method in class org.jph.channels.process.ThrowingProcessExceptionHandler

I

InputChannel<M> - Interface in org.jph.channels

The InputChannel is the backend of a Channel where messages can be retrieved from.

INSTANCE - Static variable in class org.jph.channels.DeadLetterOutputChannel

INSTANCE - Static variable in class org.jph.channels.SelfMessageCloner

INSTANCE - Static variable in class org.jph.channels.StdMessageToString

InterruptHandler<M> - Interface in org.jph.channels.active

The InterruptHandler is called by the ActiveOutputChannel if a offer/put is interrupted.

isBeingExecuted(I) - Method in interface org.jph.channels.ProcessingMap

isBeingExecuted(I) - Method in class org.jph.channels.StdProcessingMap

isFair() - Method in class org.jph.channels.bufferedChannel.SynchronousChannel

Returns true if threads contend in FIFO order for access; and false if the order is unspecified.

isLogging() - Method in interface org.jph.channels.logging.jmx.LoggingInputChannelMBean

Returns true if the LoggingIntputChannel is logging, false otherwise.

isLogging() - Method in class org.jph.channels.logging.jmx.LoggingInputChannelMBeanImpl

isLogging() - Method in interface org.jph.channels.logging.jmx.LoggingOutputChannelMBean

Returns true if the LoggingOutputChannel is logging, false otherwise.

isLogging() - Method in class org.jph.channels.logging.jmx.LoggingOutputChannelMBeanImpl

isLogging() - Method in class org.jph.channels.logging.Log4jInputChannel

isLogging() - Method in class org.jph.channels.logging.Log4jOutputChannel

isLogging() - Method in interface org.jph.channels.logging.LoggingInputChannel

Returns true if this LoggingInputChannel is logging, false otherwise.

isLogging() - Method in interface org.jph.channels.logging.LoggingOutputChannel

Returns true if this LoggingOutputChannel is logging, false otherwise.

isLogging() - Method in class org.jph.channels.logging.SimpleLoggingOutputChannel

isMonitoring() - Method in class org.jph.channels.management.MonitoringOutputChannel

isOpen() - Method in interface org.jph.channels.regulate.jmx.RegulatingOutputChannelMBean

Checks if the RegulatingOutputChannel is open.

isOpen() - Method in class org.jph.channels.regulate.jmx.RegulatingOutputChannelMBeanImpl

isOpen() - Method in interface org.jph.channels.regulate.RegulatingOutputChannel

Returns true if this RegulatingOutputChannel is open and false otherwise.

isOpen() - Method in class org.jph.channels.regulate.StdRegulatingOutputChannel

isSerialized() - Method in class org.jph.channels.regulate.StdRegulatingOutputChannel

Returns true if all calls to this StdRegulatingOutputChannel are serialized.

isShowAfter() - Method in class org.jph.channels.logging.SimpleLoggingOutputChannel

isShowBefore() - Method in class org.jph.channels.logging.SimpleLoggingOutputChannel

isStopAfterFirst() - Method in interface org.jph.channels.router.RoutingOutputChannel

Returns true if this RoutingOutputChannel should stop sending messages to other receivers if one receiver succesfully has received a message.

isStopAfterFirst() - Method in class org.jph.channels.router.StdRoutingOutputChannel

L

Log4jInputChannel<M> - Class in org.jph.channels.logging

The Log4jIntputChannel is a LoggingInputChannel that uses log4j to log messages.

Log4jInputChannel(InputChannel<M>) - Constructor for class org.jph.channels.logging.Log4jInputChannel

Default no logging.

Log4jInputChannel(InputChannel<M>, MessageToString<M>) - Constructor for class org.jph.channels.logging.Log4jInputChannel

default no logging.

Log4jInputChannel(InputChannel<M>, MessageToString<M>, boolean) - Constructor for class org.jph.channels.logging.Log4jInputChannel

Log4jOutputChannel<M> - Class in org.jph.channels.logging

The Log4jOutputChannel is a OutputChannel that logs all messages to log4j, and sends the message to the next OutputChannel.

Log4jOutputChannel(OutputChannel<M>) - Constructor for class org.jph.channels.logging.Log4jOutputChannel

default not logging

Log4jOutputChannel(OutputChannel<M>, MessageToString<M>) - Constructor for class org.jph.channels.logging.Log4jOutputChannel

Default not logging

Log4jOutputChannel(OutputChannel<M>, MessageToString<M>, boolean) - Constructor for class org.jph.channels.logging.Log4jOutputChannel

LoggingInputChannel<M> - Interface in org.jph.channels.logging

A LoggingInputChannel is an InputChannel than can log.

LoggingInputChannelMBean - Interface in org.jph.channels.logging.jmx

The LoggingInputChannelMBean is the MBean for the LoggingInputChannel.

LoggingInputChannelMBeanImpl - Class in org.jph.channels.logging.jmx

The LoggingInputChannelMBeanImpl is the implementation of the LoggingInputChannelMBean.

LoggingInputChannelMBeanImpl(LoggingInputChannel) - Constructor for class org.jph.channels.logging.jmx.LoggingInputChannelMBeanImpl

LoggingOutputChannel<M> - Interface in org.jph.channels.logging

A LoggingOutputChannel is an OutputChannel than can log.

LoggingOutputChannelMBean - Interface in org.jph.channels.logging.jmx

The LoggingOutputChannelMBean is the MBean for the LoggingOutputChannel.

LoggingOutputChannelMBeanImpl - Class in org.jph.channels.logging.jmx

The LoggingOutputChannelMBeanImpl is the implementation of the LoggingOutputChannelMBean.

LoggingOutputChannelMBeanImpl(LoggingOutputChannel) - Constructor for class org.jph.channels.logging.jmx.LoggingOutputChannelMBeanImpl

M

makeActive(OutputChannel<M>, int) - Static method in class org.jph.channels.ChannelUtil

makeActive(OutputChannel<M>, int, int) - Static method in class org.jph.channels.ChannelUtil

Make a channel active.

MessageCloner<M> - Interface in org.jph.channels

The MessageCloner clones messages.

MessageToString<M> - Interface in org.jph.channels

The MessageToString is a strategy for creating a string representation for a message.

MonitoringOutputChannel<M> - Class in org.jph.channels.management

MonitoringOutputChannel(OutputChannel<M>) - Constructor for class org.jph.channels.management.MonitoringOutputChannel

MonitoringOutputChannel(OutputChannel<M>, boolean) - Constructor for class org.jph.channels.management.MonitoringOutputChannel

MonitoringOutputChannelMBean - Interface in org.jph.channels.management.jmx

MonitoringOutputChannelMBeanImpl - Class in org.jph.channels.management.jmx

The MonitoringOutputChannelMBeanImpl is the implementation of the MonitoringOutputChannelMBean.

MonitoringOutputChannelMBeanImpl(MonitoringOutputChannel) - Constructor for class org.jph.channels.management.jmx.MonitoringOutputChannelMBeanImpl

O

offer(M, long, TimeUnit) - Method in class org.jph.channels.active.StdActiveOuputChannel

offer(M, long, TimeUnit) - Method in class org.jph.channels.bufferedChannel.StdBufferedChannel

offer(M, long, TimeUnit) - Method in class org.jph.channels.bufferedChannel.SynchronousChannel

offer(M, long, TimeUnit) - Method in class org.jph.channels.ComposedChannel

offer(M, long, TimeUnit) - Method in class org.jph.channels.DeadLetterOutputChannel

offer(M, long, TimeUnit) - Method in class org.jph.channels.filter.StdFilteringOutputChannel

offer(M, long, TimeUnit) - Method in class org.jph.channels.logging.Log4jOutputChannel

offer(M, long, TimeUnit) - Method in class org.jph.channels.logging.SimpleLoggingOutputChannel

offer(M, long, TimeUnit) - Method in class org.jph.channels.management.MonitoringOutputChannel

offer(M, long, TimeUnit) - Method in interface org.jph.channels.OutputChannel

Place msg in channel only if it can be accepted within msecs milliseconds.

offer(Min, long, TimeUnit) - Method in class org.jph.channels.process.StdProcessingOutputChannel

offer(M, long, TimeUnit) - Method in class org.jph.channels.regulate.StdRegulatingOutputChannel

offer(M, long, TimeUnit) - Method in class org.jph.channels.router.StdRoutingOutputChannel

offerAll(OutputChannel<M>, List<M>, long, TimeUnit) - Static method in class org.jph.channels.ChannelUtil

Voegt alle messages uit de msglist toe aan de channel mbv een offer.

open() - Method in interface org.jph.channels.regulate.jmx.RegulatingOutputChannelMBean

Signals the RegulatingOutputChannel to open.

open() - Method in class org.jph.channels.regulate.jmx.RegulatingOutputChannelMBeanImpl

open() - Method in interface org.jph.channels.regulate.RegulatingOutputChannel

Opens this RegulatingOutputChannel.

open(long, TimeUnit) - Method in interface org.jph.channels.regulate.RegulatingOutputChannel

Opens this RegulatingOutputChannel.

open() - Method in class org.jph.channels.regulate.StdRegulatingOutputChannel

open(long, TimeUnit) - Method in class org.jph.channels.regulate.StdRegulatingOutputChannel

org.jph.channels - package org.jph.channels

org.jph.channels.active - package org.jph.channels.active

This package contains interfaces and classes for channels that can make other channels active (have their own threads to get/put the messages).

org.jph.channels.active.jmx - package org.jph.channels.active.jmx

org.jph.channels.bufferedChannel - package org.jph.channels.bufferedChannel

org.jph.channels.filter - package org.jph.channels.filter

This package contains interfaces and classes for InputChannels and OutputChannels that can filter messages.

org.jph.channels.logging - package org.jph.channels.logging

This package contains interfaces and classes for InputChannels and OutputChannels that log.

org.jph.channels.logging.jmx - package org.jph.channels.logging.jmx

org.jph.channels.management - package org.jph.channels.management

This package contains interfaces and classes for monitoring InputChannels and OutputChannels.

org.jph.channels.management.jmx - package org.jph.channels.management.jmx

org.jph.channels.process - package org.jph.channels.process

This package contains interfaces and classes for InputChannels and OutputChannels that can process messages.

org.jph.channels.regulate - package org.jph.channels.regulate

This package contains interfaces and classes for InputChannels and OutputChannels that can regulate the messages that are being send/retrieved.

org.jph.channels.regulate.jmx - package org.jph.channels.regulate.jmx

org.jph.channels.router - package org.jph.channels.router

This package contains interfaces and classes for InputChannels and OutputChannels that can route messages.

OutInfo - Class in org.jph.channels.management

OutInfo() - Constructor for class org.jph.channels.management.OutInfo

OutputChannel<M> - Interface in org.jph.channels

The OutputChannel is the frontend of a Channel where messages can be put into.

OutRouterEntry<M> - Class in org.jph.channels.router

The OutRouterEntry is a entry for in the RoutingOutputChannel.

OutRouterEntry(OutputChannel<M>) - Constructor for class org.jph.channels.router.OutRouterEntry

Constructs a OutRouterEntry with a TrueMessagePredicate.

OutRouterEntry(OutputChannel<M>, Predicate<M>) - Constructor for class org.jph.channels.router.OutRouterEntry

Constructs a OutRouterEntry with the given OutputChannel and MessagePredicate.

P

peek() - Method in class org.jph.channels.active.StdActiveInputChannel

peek() - Method in class org.jph.channels.bufferedChannel.StdBufferedChannel

peek() - Method in class org.jph.channels.bufferedChannel.SynchronousChannel

peek() - Method in class org.jph.channels.ComposedChannel

peek() - Method in class org.jph.channels.filter.StdFilteringInputChannel

peek() - Method in interface org.jph.channels.InputChannel

Peeks if there is a message available (the message is not removed).

peek() - Method in class org.jph.channels.logging.Log4jInputChannel

poll(long, TimeUnit) - Method in class org.jph.channels.active.StdActiveInputChannel

poll(long, TimeUnit) - Method in class org.jph.channels.bufferedChannel.StdBufferedChannel

poll(long, TimeUnit) - Method in class org.jph.channels.bufferedChannel.SynchronousChannel

poll(long, TimeUnit) - Method in class org.jph.channels.ComposedChannel

poll(long, TimeUnit) - Method in class org.jph.channels.filter.StdFilteringInputChannel

poll(long, TimeUnit) - Method in interface org.jph.channels.InputChannel

Return and remove an item from channel only if one is available within msecs milliseconds.

poll(long, TimeUnit) - Method in class org.jph.channels.logging.Log4jInputChannel

process(Min) - Method in interface org.jph.channels.process.Processor

Processes the message.

ProcessExceptionHandler<M> - Interface in org.jph.channels.process

The ProcessExceptionHandler is called if something goes wrong in the ProcessingOutputChannel while processing the message.

ProcessingMap<I> - Interface in org.jph.channels

todo: documentation.

ProcessingOutputChannel<Min,Mout> - Interface in org.jph.channels.process

The ProcessingOutputChannel is an OutputChannel that processes a message and posts the resulting message on an OutputChannel.

Processor<Min,Mout> - Interface in org.jph.channels.process

The Processor processes a message and is primarily used by the ProcessingOutputChannel.

put(M) - Method in class org.jph.channels.active.StdActiveOuputChannel

put(M) - Method in class org.jph.channels.bufferedChannel.StdBufferedChannel

put(M) - Method in class org.jph.channels.bufferedChannel.SynchronousChannel

put(M) - Method in class org.jph.channels.ComposedChannel

put(M) - Method in class org.jph.channels.DeadLetterOutputChannel

put(M) - Method in class org.jph.channels.filter.StdFilteringOutputChannel

put(M) - Method in class org.jph.channels.logging.Log4jOutputChannel

put(M) - Method in class org.jph.channels.logging.SimpleLoggingOutputChannel

put(M) - Method in class org.jph.channels.management.MonitoringOutputChannel

put(M) - Method in interface org.jph.channels.OutputChannel

Place msg in the channel, possibly waiting indefinitely until it can be accepted.

put(Min) - Method in class org.jph.channels.process.StdProcessingOutputChannel

put(M) - Method in class org.jph.channels.regulate.StdRegulatingOutputChannel

put(M) - Method in class org.jph.channels.router.StdRoutingOutputChannel

putAll(OutputChannel<M>, List<M>) - Static method in class org.jph.channels.ChannelUtil

Voegt alle messages uit de msgList toe aan de channel.

R

register(I) - Method in interface org.jph.channels.ProcessingMap

Stuurt true terug als het gelukt is, anders false.

register(I) - Method in class org.jph.channels.StdProcessingMap

RegulatingOutputChannel<M> - Interface in org.jph.channels.regulate

The RegulatingOutputChannel is a OutputChannel that can open/close a target OutputChannel.

RegulatingOutputChannelMBean - Interface in org.jph.channels.regulate.jmx

The RegulatingOutputChannelMBean is a MBean for the RegulatingOutputChannel.

RegulatingOutputChannelMBeanImpl - Class in org.jph.channels.regulate.jmx

The RegulatingOutputChannelMBeanImpl is the implementation of the RegulatingOutputChannelMBean.

RegulatingOutputChannelMBeanImpl(RegulatingOutputChannel) - Constructor for class org.jph.channels.regulate.jmx.RegulatingOutputChannelMBeanImpl

reset() - Method in interface org.jph.channels.management.jmx.MonitoringOutputChannelMBean

reset() - Method in class org.jph.channels.management.jmx.MonitoringOutputChannelMBeanImpl

reset() - Method in class org.jph.channels.management.MonitoringOutputChannel

resetAndStart() - Method in interface org.jph.channels.management.jmx.MonitoringOutputChannelMBean

resetAndStart() - Method in class org.jph.channels.management.jmx.MonitoringOutputChannelMBeanImpl

RoutingOutputChannel<M> - Interface in org.jph.channels.router

The RoutingOutputChannel is an OutputChannel that receives messages and publishes them to one or more subscribing outputchannels.

S

SelfMessageCloner<M> - Class in org.jph.channels

The SelfMessageCloner doesn`t make a new message, but sends back the original message-object.

SelfMessageCloner() - Constructor for class org.jph.channels.SelfMessageCloner

setMod(int) - Method in interface org.jph.channels.logging.jmx.LoggingOutputChannelMBean

setMod(int) - Method in class org.jph.channels.logging.jmx.LoggingOutputChannelMBeanImpl

setMod(int) - Method in class org.jph.channels.logging.Log4jOutputChannel

setMod(int) - Method in interface org.jph.channels.logging.LoggingOutputChannel

setMod(int) - Method in class org.jph.channels.logging.SimpleLoggingOutputChannel

setShowAfter(boolean) - Method in class org.jph.channels.logging.SimpleLoggingOutputChannel

setShowBefore(boolean) - Method in class org.jph.channels.logging.SimpleLoggingOutputChannel

SimpleLoggingOutputChannel<M> - Class in org.jph.channels.logging

todo: counter todo: mod op de counter en dan loggen.

SimpleLoggingOutputChannel(OutputChannel<M>) - Constructor for class org.jph.channels.logging.SimpleLoggingOutputChannel

SimpleLoggingOutputChannel(OutputChannel<M>, boolean) - Constructor for class org.jph.channels.logging.SimpleLoggingOutputChannel

SimpleLoggingOutputChannel(OutputChannel<M>, MessageToString<M>, boolean, boolean, boolean) - Constructor for class org.jph.channels.logging.SimpleLoggingOutputChannel

stackTraceToString(Exception) - Static method in class org.jph.channels.logging.ExceptionUtil

start() - Method in interface org.jph.channels.logging.jmx.LoggingInputChannelMBean

Signals the LoggingInputChannel to start logging.

start() - Method in class org.jph.channels.logging.jmx.LoggingInputChannelMBeanImpl

start() - Method in interface org.jph.channels.logging.jmx.LoggingOutputChannelMBean

Signals the LoggingOutputChannel to start logging.

start() - Method in class org.jph.channels.logging.jmx.LoggingOutputChannelMBeanImpl

start() - Method in class org.jph.channels.logging.Log4jInputChannel

start() - Method in class org.jph.channels.logging.Log4jOutputChannel

start() - Method in interface org.jph.channels.logging.LoggingInputChannel

Starts logging.

start() - Method in interface org.jph.channels.logging.LoggingOutputChannel

Starts logging.

start() - Method in class org.jph.channels.logging.SimpleLoggingOutputChannel

start() - Method in interface org.jph.channels.management.jmx.MonitoringOutputChannelMBean

start() - Method in class org.jph.channels.management.jmx.MonitoringOutputChannelMBeanImpl

start() - Method in class org.jph.channels.management.MonitoringOutputChannel

StdActiveInputChannel<M> - Class in org.jph.channels.active

Work in progress

StdActiveInputChannel(BlockingExecutor, InputChannel<M>, BlockingQueue<M>) - Constructor for class org.jph.channels.active.StdActiveInputChannel

StdActiveOuputChannel<M> - Class in org.jph.channels.active

The StdActiveOutputChannel is the default implementation of a ActiveOutputChannel.

StdActiveOuputChannel(int, OutputChannel<M>) - Constructor for class org.jph.channels.active.StdActiveOuputChannel

StdActiveOuputChannel(int, int, OutputChannel<M>) - Constructor for class org.jph.channels.active.StdActiveOuputChannel

StdActiveOuputChannel(BlockingExecutor, OutputChannel<M>) - Constructor for class org.jph.channels.active.StdActiveOuputChannel

Creates a StdActiveOuputChannel with the default InterruptHandler (throuws a runtimeexception)

StdActiveOuputChannel(BlockingExecutor, OutputChannel<M>, InterruptHandler<M>) - Constructor for class org.jph.channels.active.StdActiveOuputChannel

Creates a StdActiveOuputChannel

StdBufferedChannel<M> - Class in org.jph.channels.bufferedChannel

The BufferedChannel is a ChannelPipo implementation that bufferes messages if the messages are faster created than removed.

StdBufferedChannel() - Constructor for class org.jph.channels.bufferedChannel.StdBufferedChannel

Creates a BufferedChannel with an unbound BlockingQueue.

StdBufferedChannel(int) - Constructor for class org.jph.channels.bufferedChannel.StdBufferedChannel

Creates a BufferedChannel with the given capacity.

StdBufferedChannel(BlockingQueue<M>) - Constructor for class org.jph.channels.bufferedChannel.StdBufferedChannel

Creates a BufferedChannel with a given BlockingQueue.

StdFilteringInputChannel<M> - Class in org.jph.channels.filter

Work in progress.

StdFilteringInputChannel(InputChannel<M>, Predicate<M>) - Constructor for class org.jph.channels.filter.StdFilteringInputChannel

StdFilteringOutputChannel<M> - Class in org.jph.channels.filter

The StdFilteringOutputChannel is the default implementation of the FilteringOutputChannel.

StdFilteringOutputChannel(OutputChannel<M>, Predicate<M>) - Constructor for class org.jph.channels.filter.StdFilteringOutputChannel

StdFilteringOutputChannel(OutputChannel<M>, OutputChannel<M>, Predicate<M>) - Constructor for class org.jph.channels.filter.StdFilteringOutputChannel

StdMessageToString<M> - Class in org.jph.channels

The StdMessageToString is the default implementation of the MessageToString and uses the toString method of the message.

StdMessageToString() - Constructor for class org.jph.channels.StdMessageToString

StdProcessingMap<I> - Class in org.jph.channels

The StdProcessingMap is the default implementation of the ProcessingMap.

StdProcessingMap() - Constructor for class org.jph.channels.StdProcessingMap

StdProcessingOutputChannel<Min,Mout> - Class in org.jph.channels.process

The StdProcessingOutputChannel is the default implementation of the ProcessingOutputChannel.

StdProcessingOutputChannel(OutputChannel<Mout>, Processor<Min, Mout>) - Constructor for class org.jph.channels.process.StdProcessingOutputChannel

Creates a new StdProcessingOutputChannel with a ThrowingProcessExceptionHandler.

StdProcessingOutputChannel(OutputChannel<Mout>, Processor<Min, Mout>, ProcessExceptionHandler<Min>) - Constructor for class org.jph.channels.process.StdProcessingOutputChannel

StdRegulatingOutputChannel<M> - Class in org.jph.channels.regulate

The StdRegulatingOutputChannel is the default implementation for RegulatingOutputChannel interface.

StdRegulatingOutputChannel(OutputChannel<M>) - Constructor for class org.jph.channels.regulate.StdRegulatingOutputChannel

Constructs a StdRegulatingOutputChannel that is open.

StdRegulatingOutputChannel(OutputChannel<M>, boolean) - Constructor for class org.jph.channels.regulate.StdRegulatingOutputChannel

Constructs a StdRegulatingOutputChannel that is not serialized.

StdRegulatingOutputChannel(OutputChannel<M>, boolean, boolean) - Constructor for class org.jph.channels.regulate.StdRegulatingOutputChannel

StdRoutingOutputChannel<M> - Class in org.jph.channels.router

De StdRoutingOutputChannel is the default implementation of the RoutingOutputChannel.

StdRoutingOutputChannel(OutRouterEntry<M>, boolean) - Constructor for class org.jph.channels.router.StdRoutingOutputChannel

StdRoutingOutputChannel(List<OutRouterEntry<M>>, boolean) - Constructor for class org.jph.channels.router.StdRoutingOutputChannel

StdRoutingOutputChannel(List<OutRouterEntry<M>>, OutputChannel<M>, boolean) - Constructor for class org.jph.channels.router.StdRoutingOutputChannel

stop() - Method in interface org.jph.channels.logging.jmx.LoggingInputChannelMBean

Signals the LoggingInputChannel to stop logging.

stop() - Method in class org.jph.channels.logging.jmx.LoggingInputChannelMBeanImpl

stop() - Method in interface org.jph.channels.logging.jmx.LoggingOutputChannelMBean

Signals the LoggingOutputChannel to stop logging.

stop() - Method in class org.jph.channels.logging.jmx.LoggingOutputChannelMBeanImpl

stop() - Method in class org.jph.channels.logging.Log4jInputChannel

stop() - Method in class org.jph.channels.logging.Log4jOutputChannel

stop() - Method in interface org.jph.channels.logging.LoggingInputChannel

Stops logging.

stop() - Method in interface org.jph.channels.logging.LoggingOutputChannel

Stops logging.

stop() - Method in class org.jph.channels.logging.SimpleLoggingOutputChannel

stop() - Method in interface org.jph.channels.management.jmx.MonitoringOutputChannelMBean

stop() - Method in class org.jph.channels.management.jmx.MonitoringOutputChannelMBeanImpl

stop() - Method in class org.jph.channels.management.MonitoringOutputChannel

subscribe(OutputChannel<M>) - Method in interface org.jph.channels.router.RoutingOutputChannel

Adds the subscriber to this RoutingOutputChannel.

subscribe(Predicate, OutputChannel<M>) - Method in interface org.jph.channels.router.RoutingOutputChannel

Adds a subscriber to this RoutingOutputChannel.

subscribe(OutputChannel<M>) - Method in class org.jph.channels.router.StdRoutingOutputChannel

subscribe(Predicate, OutputChannel<M>) - Method in class org.jph.channels.router.StdRoutingOutputChannel

SynchronousChannel<M> - Class in org.jph.channels.bufferedChannel

A SynchronousChannel is a Channel with no internal capacity (not even one).

SynchronousChannel() - Constructor for class org.jph.channels.bufferedChannel.SynchronousChannel

Creates a SynchronousChannel with fairness = false.

SynchronousChannel(boolean) - Constructor for class org.jph.channels.bufferedChannel.SynchronousChannel

Creates a SynchronousChannel.

T

take() - Method in class org.jph.channels.active.StdActiveInputChannel

take() - Method in class org.jph.channels.bufferedChannel.StdBufferedChannel

take() - Method in class org.jph.channels.bufferedChannel.SynchronousChannel

take() - Method in class org.jph.channels.ComposedChannel

take() - Method in class org.jph.channels.filter.StdFilteringInputChannel

take() - Method in interface org.jph.channels.InputChannel

Return and remove a msg from channel, possibly waiting indefinitely until such an item exists.

take() - Method in class org.jph.channels.logging.Log4jInputChannel

ThrowingInterruptHandler<M> - Class in org.jph.channels.active

todo:

ThrowingInterruptHandler() - Constructor for class org.jph.channels.active.ThrowingInterruptHandler

ThrowingProcessExceptionHandler<M> - Class in org.jph.channels.process

The ThrowingProcessExceptionHandler is an ProcessExceptionHandler that throws a RuntimeException if something went wrong while processing a message.

ThrowingProcessExceptionHandler() - Constructor for class org.jph.channels.process.ThrowingProcessExceptionHandler

toString(M) - Method in interface org.jph.channels.MessageToString

Sends back a string representation of a msg.

toString() - Method in class org.jph.channels.router.OutRouterEntry

toString(M) - Method in class org.jph.channels.StdMessageToString

A B C D E F G H I L M O P R S T