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.client.sysmessages |
This package defines the eBus system messages.
|
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.util |
This package provides an eBus interface for accessing
Timer API. |
Modifier and Type | Field and Description |
---|---|
static EMessageKey |
ConnectionMessage.MESSAGE_KEY
The connection message key
ConnectionMessage.class:/eBus . |
static EMessageKey |
ServerMessage.MESSAGE_KEY
The server message key
ServerMessage.class :/eBus. |
static EMessageKey |
MulticastMessage.MESSAGE_KEY
Multicast connection messages are published under this
key.
|
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<EMessageKey,EMulticastConnection.KeyInfo> |
EMulticastConnection.mKeyIds
Maps message key to its associated information.
|
protected java.util.Map<MultiKey2<java.util.UUID,java.lang.Integer>,EMessageKey> |
EMulticastConnection.mKeys
Maps a (JVM identifier, key identifier) pair to its
associated message key.
|
Modifier and Type | Method and Description |
---|---|
EMessageKey |
IEFeed.key()
Returns the message key associated with this feed.
|
EMessageKey |
EMulticastConnection.KeyInfo.key()
Returns notification message key.
|
EMessageKey |
EMultiFeed.key()
Returns a message key with
EMultiFeed.messageClass() as the
class and EMultiFeed.MULTIFEED_SUBJECT as the subject. |
Modifier and Type | Method and Description |
---|---|
java.util.Map<EMessageKey,EFeedState> |
EMultiFeed.feedStates()
Returns a mapping between the current subordinate feed
message keys and the subordinate feed state.
|
static java.util.List<EMessageKey> |
EFeed.findKeys()
Returns a non-
null , possibly empty, message key
list taken from the current message key dictionary
entries. |
static java.util.List<EMessageKey> |
EFeed.findKeys(java.lang.Class<? extends EMessage> mc)
Returns a list containing message keys for the given
message class found in the message key dictionary.
|
static java.util.List<EMessageKey> |
EFeed.findKeys(java.lang.Class<? extends EMessage> mc,
Pattern query)
Returns a list containing message keys for the given
message class and subject pattern found in the message key
dictionary.
|
java.util.List<EMessageKey> |
EMultiFeed.keys()
Returns the current subordinate feed message keys.
|
Modifier and Type | Method and Description |
---|---|
static void |
EFeed.addKey(EMessageKey key)
Adds
key to the eBus message key dictionary if
key is not already defined. |
protected static void |
EFeed.checkScopes(EMessageKey key,
EFeed.FeedScope scope)
Checks if the message scope and feed scope are in
agreement.
|
protected ESubscribeFeed |
EMultiSubscribeFeed.createFeed(EMessageKey key)
Returns a newly minted subordinate subscribe feed for the
given key.
|
protected ESubscribeFeed |
EMultiSubscribeFeed.Builder.createFeed(EMessageKey key) |
protected EPublishFeed |
EMultiPublishFeed.createFeed(EMessageKey key)
Returns a newly minted subordinate publish feed for the
given key.
|
protected EPublishFeed |
EMultiPublishFeed.Builder.createFeed(EMessageKey key) |
protected ERequestFeed |
EMultiRequestFeed.createFeed(EMessageKey key)
Returns a newly minted subordinate request feed for the
given key.
|
protected ERequestFeed |
EMultiRequestFeed.Builder.createFeed(EMessageKey key) |
protected EReplyFeed |
EMultiReplyFeed.createFeed(EMessageKey key)
Returns a newly minted subordinate reply feed for the
given key.
|
protected EReplyFeed |
EMultiReplyFeed.Builder.createFeed(EMessageKey key) |
protected abstract F |
EMultiFeed.createFeed(EMessageKey key)
Returns a newly minted subordinate feed for the given
message key.
|
protected abstract F |
EMultiFeed.Builder.createFeed(EMessageKey key)
Returns a subordinate feed for the given message key.
|
ERequestFeed.Builder |
ERequestFeed.Builder.messageKey(EMessageKey key)
Sets eBus message key defining this feed.
|
void |
EMulticastPublisher.subjectUpdate(SubjectType subjectType,
EMessageKey subjectKey)
If subject is a notification then check if the subject's
message key matches any of the multicast keys.
|
void |
ISubjectListener.subjectUpdate(SubjectType subjectType,
EMessageKey subjectKey)
Forwards a newly added subject's type and message key to
the listener.
|
void |
EMultiFeed.subjectUpdate(SubjectType subjectType,
EMessageKey subjectKey)
If the new subject's message type and subject matches
this feed's message type and subject query, then add
create a new subordinate feed and put that new feed
into the proper state.
|
protected static void |
EPublishFeed.validateOpenParams(EPublisher client,
EMessageKey key,
EFeed.FeedScope scope)
Verifies that meet the required feed opening constraints;
if this verification fails, then the appropriate
exception is thrown.
|
protected static void |
ESubscribeFeed.validateOpenParams(ESubscriber client,
EMessageKey key,
EFeed.FeedScope scope)
Verifies that given parameters are not set to
null
and that key references a notification message and
that the message scope and feed scope are in agreement. |
Modifier and Type | Method and Description |
---|---|
static void |
EFeed.addAllKeys(java.util.Collection<EMessageKey> keys)
Adds the given message key collection to the message key
dictionary if all keys are not null and reference
notification and/or request messages.
|
Constructor and Description |
---|
KeyInfo(EMessageKey key,
java.net.InetSocketAddress source,
java.util.UUID mcastId,
int id,
EFeedState state)
Creates a multicast key information instance for the
given message key, associated source address, unique
message key identifier, and feed state.
|
KeyInfo(EMessageKey key,
java.net.InetSocketAddress source,
java.util.UUID mcastId,
int id,
EFeedState state,
EMulticastConnection.MessageReader reader)
Creates a multicast key information instance for the
given message key, associated source address, unique
message key identifier, and feed state.
|
Modifier and Type | Field and Description |
---|---|
static EMessageKey |
RQMonitor.EOBJECT_REPORT_KEY
Message key for
EBusObjectReport notifications. |
static EMessageKey |
RQMonitor.RQTHREAD_REPORT_KEY
Message key for
RQThreadReport notifications. |
static EMessageKey |
RQMonitor.RQTHREAD_UPDATE_KEY
Message key for
ThreadOverrunUpdate notifications. |
static EMessageKey |
RQMonitor.THREAD_DENIAL_KEY
Message key for
ThreadDenialUpdate notifications. |
Modifier and Type | Method and Description |
---|---|
EMessageKey |
AbstractKeyMessage.messageKey()
Returns the message key based on the message class name
and subject.
|
Modifier and Type | Method and Description |
---|---|
B |
AbstractKeyMessage.Builder.messageKey(EMessageKey key)
Sets both the message class name and subject based on
the given message key.
|
Modifier and Type | Field and Description |
---|---|
EMessageKey |
PublishStatusEvent.key
Feed state applies to this notification message key.
|
protected EMessageKey |
EAbstractHistoricFeed.mKey
Notifications published on this message key.
|
protected EMessageKey |
EAbstractHistoricFeed.Builder.mKey
Notification message key.
|
protected EMessageKey |
EAbstractHistoricFeed.mRequestKey
Historic message request feed key.
|
protected EMessageKey |
EAbstractHistoricFeed.Builder.mRequestKey
Historic notification request key.
|
protected EMessageKey |
EAbstractHistoricFeed.mStatusKey
PublishStatusEvent published on this message key. |
protected EMessageKey |
EAbstractHistoricFeed.Builder.mStatusKey
PublishStatusEvent message key. |
Modifier and Type | Method and Description |
---|---|
EMessageKey |
IEMessageStore.key()
Returns message key associated with message store.
|
EMessageKey |
EAbstractHistoricFeed.key()
Returns notification message key.
|
EMessageKey |
EAbstractHistoricFeed.publisherStatusKey()
Returns notification message key used to publish
PublishStatusEvent messages. |
EMessageKey |
EAbstractHistoricFeed.requestKey()
Returns historic request message key.
|
Modifier and Type | Method and Description |
---|---|
static EHistoricPublishFeed.Builder |
EHistoricPublishFeed.builder(EMessageKey key,
IEHistoricPublisher publisher)
Returns a new historic publish feed builder for the
specified notification message key and publisher
identifier.
|
static EHistoricSubscribeFeed.Builder |
EHistoricSubscribeFeed.builder(EMessageKey key,
IEHistoricSubscriber subscriber)
Returns a new historic subscribe feed builder for the
specified notification message key and historic
subscriber.
|
PublishStatusEvent.Builder |
PublishStatusEvent.Builder.key(EMessageKey key)
Sets message key to which feed status applies.
|
Constructor and Description |
---|
Builder(T owner,
java.lang.Class<F> feedClass,
EMessageKey key)
Initializes historic feed abstract elements with the
given parameters.
|
Modifier and Type | Method and Description |
---|---|
EMessageKey |
SqlMessageStore.key() |
EMessageKey |
InMemoryMessageStore.key() |
Modifier and Type | Method and Description |
---|---|
SqlMessageStore.Builder |
SqlMessageStore.Builder.key(EMessageKey key)
Sets eBus notification message key.
|
InMemoryMessageStore.Builder |
InMemoryMessageStore.Builder.key(EMessageKey key)
Sets eBus notification message key.
|
java.lang.String |
IRetrieveGenerator.retrieveStatement(EMessageKey key,
EInterval interval)
Returns SQL select statement used to retrieve the given
eBus notification message type.
|
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 | Field and Description |
---|---|
protected EMessageKey |
EPatternFeed.mPubKey
Publish match events on this message key.
|
Modifier and Type | Method and Description |
---|---|
EMessageKey |
EPatternFeed.key()
Returns a message key with
MatchEvent as the class
and the event pattern name as the subject. |
EMessageKey |
EventPattern.FeedInfo.messageKey()
Returns the subscription notification message key.
|
EMessageKey |
EventPattern.messageKey(java.lang.String feedName)
Returns the message key associated with the given feed
name.
|
Modifier and Type | Method and Description |
---|---|
EventPattern.Builder |
EventPattern.Builder.messageKey(EMessageKey key)
Sets the parameter notification message key.
|
Constructor and Description |
---|
FeedInfo(EMessageKey key,
EFeed.FeedScope scope)
Creates subscription feed information for the given
notification message key and feed scope.
|
FeedInfo(EMessageKey key,
EFeed.FeedScope scope,
ECondition condition)
Creates subscription feed information for the given
notification message key, feed scope, and optional
feed condition.
|
Modifier and Type | Method and Description |
---|---|
EMessageKey |
EMessageList.key()
Returns the list element message key.
|
EMessageKey |
EMessage.key()
Returns the unique message key based on the message class
and subject.
|
EMessageKey |
EMessageHeader.messageKey()
Returns the encapsulated message key.
|
static EMessageKey |
EMessageKey.parseKey(java.lang.String s)
Returns a message key parsed from the given input.
|
Modifier and Type | Method and Description |
---|---|
int |
EMessageKey.compareTo(EMessageKey key)
Returns an integer value that is <, equal to or >
zero if
this EMessageKey is <, equal to or
> key . |
boolean |
EMessageKey.isAssignableFrom(EMessageKey key)
Returns
true if key 's message class is
assignable from this key's message class and the
subjects are equal; otherwise returns false . |
Constructor and Description |
---|
EMessageList(java.util.Collection<E> c,
EMessageKey key)
Creates a message list instance containing the same
elements as
c and in the order returned by the
collection's iterator. |
EMessageList(EMessageKey key)
Creates an empty message list instance with an initial
capacity of ten.
|
EMessageList(int initialCapacity,
EMessageKey key)
Creates an empty message list instance with the specified
initial capacity.
|
Modifier and Type | Method and Description |
---|---|
static EMessageKey |
EFileWatcher.key(java.io.File file)
Returns the
EFileWatcher message key for the given
file or directory. |
static EMessageKey |
EFileWatcher.startFileWatcher(java.io.File file,
long rate)
Creates an eBus file watcher service for the specified
file or directory and checking at a given watch rate.
|
Modifier and Type | Field and Description |
---|---|
static EMessageKey |
ETimer.TIMER_KEY
The advertised request message key is
TimerRequest:/eBusTimer.
|
Copyright © 2001 - 2024. Charles W. Rapp. All rights reserved.