Package net.sf.eBus.feed.historic.store
This package contains two implementations of
IEMessageStore interface:
InMemoryMessageStore
and
SqlMessageStore.
In-memory stores eBus messages (and
publish status events
in a fixed-size ring buffer. These messages are not
persisted. When the application stores, the messages are lost
unless persisted by the application itself.
SQL message store persists messages to an SQL database. The
user is required to provide code which generates SQL
statements to insert, retrieve, and decode eBus messages. This
code provides the link between SqlMessageStore and the
actual database. This allows SqlMessageStore to work
with multiple SQL database engines.
See InMemoryMessageStore and SqlMessageStore
javadocs for detailed explanation on how to use these classes.
-
Interface Summary Interface Description IInsertGenerator Generates SQL insert statement used to put an eBusnotification messageinto database.IMessageDecoder ConvertsResultSetinto eBusnotification messagefor given message key.IRetrieveGenerator Generates SQL statement to retrieve the specified eBus notification message key for the given time interval. -
Class Summary Class Description InMemoryMessageStore This class implementsIEMessageStoreproviding the ability to store events to and retrieve events from an in-memoryeBus notification message array.InMemoryMessageStore.Builder InMemoryMessageStoreinstances are created using aBuilder.SqlMessageStore This class implementsIEMessageStoreproviding the ability to store events to and retrieve events from aJava SQL connection.SqlMessageStore.Builder SqlMessageStoreinstances created using aBuilderinstance.