Package org.oddjob.events

Class OutboundEventSource<T>

java.lang.Object

org.oddjob.events.OutboundEventSource<T>

Type Parameters:

T - The Pipeline Outbound type.

All Implemented Interfaces:

Consumer<T>, Outbound<T>, EventSource<T>

public class OutboundEventSource<T>
extends Object
implements EventSource<T>, Consumer<T>, Outbound<T>

Create an Outbound consumer of a Bean Bus that is an EventSource.

Constructor Summary

Constructors

Constructor	Description
OutboundEventSource()

Method Summary

Modifier and Type	Method	Description
void	accept(T t)
String	getName()
int	getSubscriberCount()
Consumer<? super T>	getTo()
void	setName(String name)
void	setTo(Consumer<? super T> destination)	Set the out bound destination.
Restore	subscribe(Consumer<? super T> consumer)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Details

OutboundEventSource

public OutboundEventSource()

Method Details

accept

public void accept(T t)

Specified by:

accept in interface Consumer<T>

subscribe

public Restore subscribe(Consumer<? super T> consumer)

Specified by:

subscribe in interface EventSource<T>

getSubscriberCount

public int getSubscriberCount()

getName

public String getName()

setName

public void setName(String name)

setTo

public void setTo(Consumer<? super T> destination)

Description copied from interface: Outbound

Set the out bound destination.

Specified by:

setTo in interface Outbound<T>

Parameters:

destination -

getTo

public Consumer<? super T> getTo()

toString

public String toString()

Overrides:

toString in class Object