public final class ProcessorFilter extends ForwarderFilter.Abstract
ForwarderFilter.Abstract
Modifier and Type | Field and Description |
---|---|
static Messages.Entry |
CONFIRM_ALWAYS
Values are always confirmed.
|
static String |
CONFIRM_ALWAYS_KEYWORD |
static Messages.Entry |
CONFIRM_MARKED
Values are confirmed when marked.
|
static String |
CONFIRM_MARKED_KEYWORD |
static Messages.Entry |
CONFIRM_NEVER
Values are never confirmed.
|
static String |
CONFIRM_NEVER_KEYWORD |
static String |
CONFIRM_PROPERTY
Specifies when a value existence is confirmed.
|
static Messages.Entry |
CONFIRM_REPLICATED
Values are confirmed when replicated.
|
static String |
CONFIRM_REPLICATED_KEYWORD |
static String |
CONFIRM_VALUE_PROPERTY
Specifies if a value is verified when confirmed.
|
static String |
PROCESSOR_PROPERTY
Processor property.
|
static String |
REPLICATES_PROPERTY
Replicates property.
|
static String |
RESYNCHRONIZES_PROPERTY
Resynchronizes property.
|
FILTER_UUID_PROPERTY, NO_MESSAGES, WARN_DROPPED_PROPERTY
Constructor and Description |
---|
ProcessorFilter() |
Modifier and Type | Method and Description |
---|---|
Serializable[] |
filter(Serializable message)
Filters a message.
|
boolean |
needsMetadata()
Asks if this filter needs metadata.
|
protected boolean |
onNewMetadata(Metadata metadata)
Called on new metadata.
|
boolean |
setUp(ForwarderModule forwarderModule,
KeyedGroups filterProperties)
Sets up this filter.
|
getMetadata, getModule, getThisLogger, getUUID, knownPointValue, loadMetadata, logDropped, onMetadataRefreshed, tearDown
public static final String CONFIRM_ALWAYS_KEYWORD
public static final String CONFIRM_MARKED_KEYWORD
public static final String CONFIRM_NEVER_KEYWORD
public static final String CONFIRM_PROPERTY
public static final Messages.Entry CONFIRM_NEVER
public static final Messages.Entry CONFIRM_MARKED
public static final Messages.Entry CONFIRM_ALWAYS
public static final Messages.Entry CONFIRM_REPLICATED
public static final String CONFIRM_REPLICATED_KEYWORD
public static final String CONFIRM_VALUE_PROPERTY
public static final String PROCESSOR_PROPERTY
public static final String REPLICATES_PROPERTY
public static final String RESYNCHRONIZES_PROPERTY
public Serializable[] filter(Serializable message) throws InterruptedException, ServiceNotAvailableException
message
- The original message.InterruptedException
- When the service is stopped.ServiceNotAvailableException
- When the service is not available.public boolean needsMetadata()
needsMetadata
in interface ForwarderFilter
needsMetadata
in class ForwarderFilter.Abstract
public boolean setUp(ForwarderModule forwarderModule, KeyedGroups filterProperties)
setUp
in interface ForwarderFilter
setUp
in class ForwarderFilter.Abstract
forwarderModule
- The owner of this filter.filterProperties
- The filter properties.protected boolean onNewMetadata(Metadata metadata)
onNewMetadata
in class ForwarderFilter.Abstract
metadata
- The new metadata.Copyright © 2003-2019 Serge Brisson. All Rights Reserved.