public class MessageValidator extends Object
| Constructor and Description |
|---|
MessageValidator(RouterContext context)MessageValidator. |
| Modifier and Type | Method and Description |
|---|---|
(package private) void | shutdown()Stop the message validator and clean up resources. |
void | startup()Start the message validator, initializing the duplicate detection filter. |
String | validateMessage(long expiration)Only check the expiration for the message |
String | validateMessage(long messageId,
long expiration)Determine if this message should be accepted as valid (not expired, not a duplicate) |
public MessageValidator(RouterContext context)
void shutdown()
public void startup()
public String validateMessage(long expiration)
public String validateMessage(long messageId, long expiration)