diff options
| author | doufenghu <[email protected]> | 2024-11-14 09:54:50 +0800 |
|---|---|---|
| committer | doufenghu <[email protected]> | 2024-11-14 09:54:50 +0800 |
| commit | df18fbe845df119e884e2e8f281bbf019d96c7e7 (patch) | |
| tree | 88fad63d6bc0b4b6637467427d05119de809e265 /groot-formats/format-msgpack | |
| parent | d35dbe98007d341c7b41080535f5c6154063a448 (diff) | |
[Feature][api] AviatorFilterProcessorFactory renamed to FilterProcessorFactory.The Factory add supportsType method for supporting legency type of avaitor.
Diffstat (limited to 'groot-formats/format-msgpack')
| -rw-r--r-- | groot-formats/format-msgpack/src/main/java/com/geedgenetworks/formats/msgpack/MessagePackFormatFactory.java | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/groot-formats/format-msgpack/src/main/java/com/geedgenetworks/formats/msgpack/MessagePackFormatFactory.java b/groot-formats/format-msgpack/src/main/java/com/geedgenetworks/formats/msgpack/MessagePackFormatFactory.java index 2a3988f..2d57bad 100644 --- a/groot-formats/format-msgpack/src/main/java/com/geedgenetworks/formats/msgpack/MessagePackFormatFactory.java +++ b/groot-formats/format-msgpack/src/main/java/com/geedgenetworks/formats/msgpack/MessagePackFormatFactory.java @@ -25,6 +25,11 @@ public class MessagePackFormatFactory implements DecodingFormatFactory, Encoding } @Override + public boolean supportsType(String type) { + return IDENTIFIER.equalsIgnoreCase(type); + } + + @Override public DecodingFormat createDecodingFormat(ConnectorFactory.Context context, ReadableConfig formatOptions) { return new DecodingFormat() { |
