Package | Description |
---|---|
net.sf.eBus.client |
This package contains the top-level eBus API which
applications use to interact with eBus.
|
net.sf.eBus.client.monitor |
This package is centered on
RQMonitor class. |
net.sf.eBus.feed.historic |
This package contains a specialized feed providing
notification feeds which support both historic and live
messages.
|
net.sf.eBus.feed.historic.store |
This package contains two implementations of
IEMessageStore interface:
InMemoryMessageStore
and
SqlMessageStore . |
net.sf.eBus.feed.pattern |
This package contains specialized feeds extending the basic
feeds in
net.sf.eBus.client . |
net.sf.eBus.messages |
Messages are the heart of eBus.
|
net.sf.eBusx.io |
This package provides the ability to monitor file/directory
creation, modification, and deletion via the
file notification . |
net.sf.eBusx.monitor |
This package provides messages to monitor both the on-going
state and transient events of an eBus application at the
object-level.
|
Modifier and Type | Interface and Description |
---|---|
interface |
NotifyCallback<T extends ENotificationMessage>
This functional interface may be used to handle notification
message delivery instead of
ESubscriber.notify(ENotificationMessage, IESubscribeFeed)
by passing a NotifyCallback instance to
ESubscribeFeed.Builder.notifyCallback(NotifyCallback) . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractEBusMessage
Base class for eBus
ConnectionMessage and
ServerMessage classes. |
class |
ConnectionMessage
This message reports when a
remote connection has either
logged on or logged off . |
class |
MulticastMessage
Reports multicast connection current state.
|
class |
ServerMessage
This message reports the
remote Internet address and TCP port
of a connection newly accepted by EServer but not yet
logged in. |
Modifier and Type | Method and Description |
---|---|
<T extends ENotificationMessage> |
EMultiSubscribeFeed.Builder.notifyCallback(NotifyCallback<T> cb)
Puts the notification message callback in place.
|
<T extends ENotificationMessage> |
ESubscribeFeed.Builder.notifyCallback(NotifyCallback<T> cb)
Puts the notification message callback in place.
|
Modifier and Type | Method and Description |
---|---|
ENotificationMessage |
EClient.RQStats.getUpdate()
Returns
RQThreadUpdate message associated with
this RQThread stat. |
Modifier and Type | Method and Description |
---|---|
java.lang.Class<? extends ENotificationMessage> |
EMulticastConnection.MulticastKey.messageClass()
Returns notification message class.
|
Modifier and Type | Method and Description |
---|---|
default void |
ESubscriber.notify(ENotificationMessage msg,
IESubscribeFeed feed)
An incoming notification message from
feed . |
void |
EMulticastPublisher.notify(ENotificationMessage msg,
IESubscribeFeed feed)
Forwards eBus notification messages to multicast group,
if joined.
|
void |
ERemoteApp.notify(ENotificationMessage msg,
IESubscribeFeed feed)
Forwards the message to the remote eBus application if the
subscription is still in place.
|
void |
EMultiPublishFeed.publish(ENotificationMessage msg)
Posts a notification message to all subscribers via the
subordinate publish feed which matches the message's key.
|
void |
IEPublishFeed.publish(ENotificationMessage msg)
Posts this notification message to all interested
subscribers.
|
void |
EPublishFeed.publish(ENotificationMessage msg)
Posts this notification message to all interested
subscribers.
|
void |
EClient.RQStats.setUpdate(ENotificationMessage update)
Stores the
RQThreadUpdate message posted
for this current RQThread stat. |
Constructor and Description |
---|
NotifyTask(ENotificationMessage message,
ECondition condition,
IESubscribeFeed feed,
NotifyCallback cb)
Creates a notify callback task for the given
parameters.
|
Modifier and Type | Class and Description |
---|---|
class |
EBusObjectReport
Reports current status of all existing
eBus objects . |
class |
RQThreadReport
Reports current status of all existing run queue threads.
|
class |
ThreadDenialUpdate
Reports that an
eBus object is in a
EClient.RunState.READY state but
has not been placed on to a run queue thread for a excessive
amount of time. |
class |
ThreadOverrunUpdate
Reports a change in an
EClient run queue thread
(net.sf.eBus.client.EClient.RQThread ) state. |
Modifier and Type | Class and Description |
---|---|
class |
PublishStatusEvent
Notification event used to report and persist publish feed
status updates.
|
Modifier and Type | Field and Description |
---|---|
ENotificationMessage[] |
HistoricReply.notifications
One of more historic notification messages.
|
Modifier and Type | Method and Description |
---|---|
java.util.Collection<ENotificationMessage> |
IEMessageStore.retrieve(EInterval interval)
Retrieves historic messages as defined by given date/time
interval.
|
Modifier and Type | Method and Description |
---|---|
void |
HistoricNotifyCallback.call(ENotificationMessage msg,
EHistoricSubscribeFeed feed)
An incoming notification message from an historic
notification feed.
|
int |
EHistoricSubscribeFeed.PastComparator.compare(ENotificationMessage o1,
ENotificationMessage o2)
Compares two eBus notification messages for order.
|
HistoricReply.Builder |
HistoricReply.Builder.notifications(ENotificationMessage[] messages)
Sets historic messages returned in this reply.
|
default void |
IEHistoricSubscriber.notify(ENotificationMessage msg,
EHistoricSubscribeFeed feed)
Reports latest notification message.
|
void |
EHistoricPublishFeed.publish(ENotificationMessage msg)
First persists this notification to message store and
then, if the notification feed is up.
|
void |
IEMessageStore.store(ENotificationMessage message)
Persists given notification message to store.
|
Modifier and Type | Method and Description |
---|---|
HistoricReply.Builder |
HistoricReply.Builder.notifications(java.util.Collection<ENotificationMessage> messages)
Sets historic messages returned in this reply.
|
Modifier and Type | Method and Description |
---|---|
ENotificationMessage |
IMessageDecoder.toMessage(EMessageKey key,
java.sql.ResultSet rs)
Returns eBus notification message created from the given
message key and SQL result set.
|
Modifier and Type | Method and Description |
---|---|
java.util.Collection<ENotificationMessage> |
SqlMessageStore.retrieve(EInterval interval) |
java.util.Collection<ENotificationMessage> |
InMemoryMessageStore.retrieve(EInterval interval) |
java.util.Collection<ENotificationMessage> |
InMemoryMessageStore.retrieve(int numMessages)
Returns up to
numMessages last messages placed
into message store. |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
IInsertGenerator.insertStatement(ENotificationMessage message)
Returns SQL statement used to insert given eBus
notification message into database.
|
void |
SqlMessageStore.store(ENotificationMessage message) |
void |
InMemoryMessageStore.store(ENotificationMessage message)
Inserts given message into in-memory message store.
|
Modifier and Type | Class and Description |
---|---|
class |
MatchEvent
A match event reports an event pattern match.
|
Modifier and Type | Field and Description |
---|---|
static java.util.function.BiPredicate<java.util.List<ENotificationMessage>,ENotificationMessage> |
EventPattern.DEFAULT_UNTIL
The default until predicate always returns
true . |
static java.util.function.BiPredicate<java.util.List<ENotificationMessage>,ENotificationMessage> |
EventPattern.DEFAULT_UNTIL
The default until predicate always returns
true . |
java.util.Map<java.lang.String,java.util.List<ENotificationMessage>> |
MatchEvent.groups
The collected events for each pattern group.
|
protected java.util.List<ENotificationMessage> |
EPatternFeed.AbstractMatchFrame.mAllEvents
Contains all events matching the pattern so far.
|
protected java.util.Map<ENotificationMessage,java.util.List<EPatternFeed.AbstractMatchFrame>> |
EPatternFeed.mEventFrames
Maps an accepted notification event to the match frames
in which it appears.
|
protected java.util.function.BiPredicate<java.util.List<ENotificationMessage>,ENotificationMessage> |
EPatternFeed.mUntil
Collected matching events must satisfy this until
predicate.
|
protected java.util.function.BiPredicate<java.util.List<ENotificationMessage>,ENotificationMessage> |
EPatternFeed.mUntil
Collected matching events must satisfy this until
predicate.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<ENotificationMessage> |
EPatternFeed.AbstractMatchFrame.allEvents()
Returns the "all events" collection as an unmodifiable
list.
|
java.util.List<ENotificationMessage> |
MatchEvent.group(java.lang.String name)
Returns the notification list associated with the given
group name.
|
protected abstract java.util.Map<java.lang.String,java.util.List<ENotificationMessage>> |
EPatternFeed.AbstractMatchFrame.groupMap()
Returns a read-only copy of the group map.
|
Modifier and Type | Method and Description |
---|---|
protected void |
EPatternFeed.addMapping(ENotificationMessage event,
EPatternFeed.AbstractMatchFrame mf)
Adds a mapping from the given event to the match frame
which now contains the event.
|
protected static boolean |
EPatternFeed.componentTest(ENotificationMessage e,
EPatternFeed.AbstractMatchFrame mf,
MatchCondition mc) |
protected abstract void |
EPatternFeed.matchEvent(ENotificationMessage event,
int eventId)
Applies
event to the pattern. |
protected void |
EPatternFeed.onEvent(ENotificationMessage event,
IESubscribeFeed feed)
Runs
event through the state machine if-and-only-if
all the subordinate feeds are up. |
boolean |
MatchCondition.test(ENotificationMessage event,
java.util.Map<java.lang.String,java.util.List<ENotificationMessage>> groups,
java.util.Map<java.lang.Object,java.lang.Object> userCache)
Returns
true if event satisfies this
condition, allowing the event pattern matching to continue
or complete. |
Modifier and Type | Method and Description |
---|---|
MatchEvent.Builder |
MatchEvent.Builder.groups(java.util.Map<java.lang.String,java.util.List<ENotificationMessage>> groups)
Sets the message collection map to the given value.
|
protected void |
EPatternFeed.markDefunct(java.util.List<ENotificationMessage> events)
Marks all of the match frames associated with the given
events as defunct.
|
boolean |
MatchCondition.test(ENotificationMessage event,
java.util.Map<java.lang.String,java.util.List<ENotificationMessage>> groups,
java.util.Map<java.lang.Object,java.lang.Object> userCache)
Returns
true if event satisfies this
condition, allowing the event pattern matching to continue
or complete. |
EventPattern.Builder |
EventPattern.Builder.until(java.util.function.BiPredicate<java.util.List<ENotificationMessage>,ENotificationMessage> p) |
EventPattern.Builder |
EventPattern.Builder.until(java.util.function.BiPredicate<java.util.List<ENotificationMessage>,ENotificationMessage> p) |
Modifier and Type | Class and Description |
---|---|
static class |
ENotificationMessage.Builder<M extends ENotificationMessage,B extends ENotificationMessage.Builder<M,?>>
Base class for all
ENotificationMessage builders. |
Modifier and Type | Class and Description |
---|---|
class |
EFileNotification
Used to transmit a Java
WatchEvent
asynchronously to all interested listeners. |
Modifier and Type | Class and Description |
---|---|
class |
ApplicationInfo
Reports the application information.
|
class |
MonitorUpdate
|
class |
PersistentStatusMessage
Reports a monitorable object's on-going status.
|
class |
TransientStatusMessage
Reports a monitored object's transient event.
|
Copyright © 2001 - 2024. Charles W. Rapp. All rights reserved.