public interface RetryStore extends ComponentLifecycle, ComponentLifecycleExtension
Modifier and Type | Method and Description |
---|---|
default AdaptrisMessage |
buildForRetry(java.lang.String msgId)
Retrieve the message id from the store.
|
default AdaptrisMessage |
buildForRetry(java.lang.String msgId,
java.util.Map<java.lang.String,java.lang.String> metadata)
Retrieve the message id from the store.
|
AdaptrisMessage |
buildForRetry(java.lang.String msgId,
java.util.Map<java.lang.String,java.lang.String> metadata,
AdaptrisMessageFactory factory)
Build the message for retrying from the store.
|
default boolean |
delete(java.lang.String msgId)
Delete a message from the store (optional operation).
|
java.util.Map<java.lang.String,java.lang.String> |
getMetadata(java.lang.String msgId)
Retrieve the metadata associated with the msgId the store.
|
default void |
prepare()
Prepare for initialisation.
|
default java.lang.Iterable<RemoteBlob> |
report()
Report on a list of blobs that is present in the store (optional operation).
|
void |
write(AdaptrisMessage msg)
Write a message to the store.
|
close, init, start, stop
default java.lang.Iterable<RemoteBlob> report() throws InterlokException
InterlokException
void write(AdaptrisMessage msg) throws InterlokException
InterlokException
default AdaptrisMessage buildForRetry(java.lang.String msgId) throws InterlokException
InterlokException
buildForRetry(String, Map)
via
getMetadata(String)
default AdaptrisMessage buildForRetry(java.lang.String msgId, java.util.Map<java.lang.String,java.lang.String> metadata) throws InterlokException
InterlokException
buildForRetry(String, Map, AdaptrisMessageFactory)
via
getMetadata(String)
AdaptrisMessage buildForRetry(java.lang.String msgId, java.util.Map<java.lang.String,java.lang.String> metadata, AdaptrisMessageFactory factory) throws InterlokException
msgId
- the message id.metadata
- the metadata you want to apply to the messagefactory
- the message factory to useCoreException
InterlokException
java.util.Map<java.lang.String,java.lang.String> getMetadata(java.lang.String msgId) throws InterlokException
This is used to assert that the workflow exists in this instance for that message; there is no point building the whole message only to fail because the workflow doesn't exist.
InterlokException
- if no metadata could be retrieved (e.g the msgId doesn't exist)default boolean delete(java.lang.String msgId) throws InterlokException
InterlokException
UnsupportedOperationException
and performs no other action.default void prepare() throws CoreException
ComponentLifecycleExtension
prepare
in interface ComponentLifecycleExtension
CoreException