Package | Description |
---|---|
rsb | |
rsb.eventprocessing | |
rsb.filter | |
rsb.patterns | |
rsb.transport | |
rsb.transport.spread |
Modifier and Type | Method and Description |
---|---|
Event |
Informer.send(Event event)
Send an
Event to all subscribed participants. |
protected Event |
Informer.InformerStateActive.send(Event event) |
protected Event |
InformerState.send(Event e) |
Event |
Informer.send(T data)
Send data (of type
|
protected Event |
Informer.InformerStateActive.send(T data) |
protected Event |
InformerState.send(T d) |
Modifier and Type | Method and Description |
---|---|
abstract void |
AbstractEventHandler.handleEvent(Event event) |
void |
AbstractDataHandler.internalNotify(Event event) |
void |
AbstractEventHandler.internalNotify(Event event) |
void |
FilteringHandler.internalNotify(Event e) |
void |
Handler.internalNotify(Event e) |
Event |
Informer.send(Event event)
Send an
Event to all subscribed participants. |
protected Event |
Informer.InformerStateActive.send(Event event) |
protected Event |
InformerState.send(Event e) |
Modifier and Type | Method and Description |
---|---|
void |
SingleThreadEventReceivingStrategy.handle(Event e) |
void |
UnorderedParallelEventReceivingStrategy.handle(Event event) |
boolean |
MatchAndDispatchTask.match(Event event) |
Modifier and Type | Method and Description |
---|---|
abstract Event |
AbstractFilter.transform(Event e)
This method does the actual filtering step.
|
Event |
Filter.transform(Event e)
transform the given event into a result event according to this filters
rules.
|
Event |
MethodFilter.transform(Event e) |
Event |
OriginFilter.transform(Event e) |
Event |
ScopeFilter.transform(Event event) |
Event |
TypeFilter.transform(Event e) |
Modifier and Type | Method and Description |
---|---|
abstract Event |
AbstractFilter.transform(Event e)
This method does the actual filtering step.
|
Event |
Filter.transform(Event e)
transform the given event into a result event according to this filters
rules.
|
Event |
MethodFilter.transform(Event e) |
Event |
OriginFilter.transform(Event e) |
Event |
ScopeFilter.transform(Event event) |
Event |
TypeFilter.transform(Event e) |
Modifier and Type | Method and Description |
---|---|
Event |
RemoteServer.call(java.lang.String name,
Event event) |
Event |
EventCallback.invoke(Event request)
This method is called to invoke the actual behavior of an
exposed method.
|
Modifier and Type | Method and Description |
---|---|
Future<Event> |
RemoteEventMethod.call(Event event) |
Future<Event> |
RemoteServer.callAsync(java.lang.String name,
Event event) |
Modifier and Type | Method and Description |
---|---|
Future<Event> |
RemoteEventMethod.call(Event event) |
Event |
RemoteServer.call(java.lang.String name,
Event event) |
Future<Event> |
RemoteServer.callAsync(java.lang.String name,
Event event) |
protected void |
RemoteEventMethod.completeRequest(Future<Event> request,
Event event) |
protected abstract void |
AbstractRemoteMethod.completeRequest(Future<T> future,
Event event) |
protected void |
RemoteDataMethod.completeRequest(Future<T> request,
Event event) |
void |
AbstractRemoteMethod.internalNotify(Event event) |
Event |
EventCallback.invoke(Event request)
This method is called to invoke the actual behavior of an
exposed method.
|
protected Future<T> |
AbstractRemoteMethod.sendRequest(Event event) |
Modifier and Type | Method and Description |
---|---|
protected void |
RemoteEventMethod.completeRequest(Future<Event> request,
Event event) |
Modifier and Type | Method and Description |
---|---|
static Event |
EventBuilder.fromNotification(Notification n)
Build event from RSB Notification.
|
Modifier and Type | Method and Description |
---|---|
void |
EventHandler.handle(Event e) |
void |
Router.handle(Event e) |
void |
Router.publishSync(Event e)
Publish an
Event over the event bus. |
abstract void |
AbstractPort.push(Event event) |
void |
Port.push(Event e) |
Modifier and Type | Method and Description |
---|---|
void |
SpreadPort.push(Event event) |