Package | Description |
---|---|
rsb |
The base package of RSB containing the user-level API.
|
rsb.eventprocessing |
Contains classes handling the flow of events from Participants to the
transport implementations and vice versa.
|
rsb.filter |
Contains implementations of filters used when receiving events.
|
rsb.transport.inprocess |
Contains the implementation of the local in-memory transport.
|
rsb.transport.socket |
Contains the implementation of the TCP socket transport.
|
rsb.transport.spread |
Contains the implementation of the spread-based transport.
|
Modifier and Type | Method and Description |
---|---|
Iterator<Filter> |
Listener.getFilterIterator()
Returns an iterator overall active filters on this listener.
|
List<Filter> |
Listener.getFilters()
Returns the filters currently being active on the listener.
|
Modifier and Type | Method and Description |
---|---|
void |
Listener.addFilter(Filter filter)
Activates the specified filter for this informer.
|
Constructor and Description |
---|
FilteringHandler(Handler decorated,
Filter filter)
Creates a filtering handler that wraps another handler and takes one
additional filter.
|
Constructor and Description |
---|
FilteringHandler(Handler decorated,
Set<Filter> filters)
Creates a filtering handler that wraps another handler and takes a set of
filters to apply.
|
Modifier and Type | Method and Description |
---|---|
void |
SingleThreadEventReceivingStrategy.addFilter(Filter filter) |
void |
UnorderedParallelEventReceivingStrategy.addFilter(Filter filter) |
void |
EventReceivingStrategy.addFilter(Filter filter)
Adds a filter that is applied for all registered handlers some time after
this method call.
|
void |
DefaultPushInRouteConfigurator.filterAdded(Filter filter) |
void |
InRouteConfigurator.filterAdded(Filter filter)
Called in case a new filter was added and should be reflected by this
route.
|
boolean |
DefaultPushInRouteConfigurator.filterRemoved(Filter filter) |
boolean |
InRouteConfigurator.filterRemoved(Filter filter)
Called in a case a filter should be removed from the route.
|
void |
SingleThreadEventReceivingStrategy.removeFilter(Filter filter) |
void |
UnorderedParallelEventReceivingStrategy.removeFilter(Filter filter) |
void |
EventReceivingStrategy.removeFilter(Filter filter)
Removes a filter that is remove for all registered handlers some time
after this method call.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractFilter
Deprecated.
this class will be removed in favor of directly implementing
Filter |
class |
CauseFilter
Filter events based on cause.
|
class |
MethodFilter
Filters for a specific method in the event.
|
class |
OriginFilter
Events matched by this filter have to originate from a particular
participant.
|
class |
ScopeFilter
A filter that only accepts events from a scope and all its subscopes.
|
class |
TypeFilter
A
Filter that only accepts events which have a payload of a specific
type. |
Modifier and Type | Method and Description |
---|---|
void |
FilterObserver.notify(Filter filter,
FilterAction action)
Called in case a
Filter was changed. |
void |
AbstractFilterObserver.notify(Filter filter,
FilterAction action)
Deprecated.
|
void |
FilterObservable.notifyObservers(Filter filter,
FilterAction action)
Notifies all registered observers about a change to a
Filter . |
Modifier and Type | Method and Description |
---|---|
void |
InPushConnector.notify(Filter filter,
FilterAction action) |
Modifier and Type | Method and Description |
---|---|
void |
SocketInPushConnector.notify(Filter filter,
FilterAction action) |
Modifier and Type | Method and Description |
---|---|
void |
MultiSpreadInPushConnector.notify(Filter filter,
FilterAction action) |
void |
SpreadInPushConnector.notify(Filter filter,
FilterAction action) |
Copyright © 2018 CoR-Lab. All rights reserved.