ISPN-5222 Support combined filter/converter in remote listeners

* update JPACacheEventFilterConverterFactory to implement CacheEventFilterConverterFactory

client/hotrod-client/src/test/java/org/infinispan/client/hotrod/event/CustomEventLogListener.java

@@ -6,7 +6,6 @@
 import static org.testng.AssertJUnit.assertTrue;
 
 import java.io.Serializable;
-import java.util.Date;
 import java.util.Iterator;
 import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.BlockingQueue;

client/hotrod-client/src/test/java/org/infinispan/client/hotrod/event/RemoteListenerWithDslFilterTest.java

@@ -60,8 +60,7 @@ protected void createCacheManagers() throws Throwable {
       // Register the filter/converter factory. This should normally be discovered by the server via class path instead
       // of being added manually here, but this is ok in a test.
       JPACacheEventFilterConverterFactory factory = new JPACacheEventFilterConverterFactory();
-      server(0).addCacheEventFilterFactory(JPACacheEventFilterConverterFactory.FACTORY_NAME, factory);
-      server(0).addCacheEventConverterFactory(JPACacheEventFilterConverterFactory.FACTORY_NAME, factory);
+      server(0).addCacheEventFilterConverterFactory(JPACacheEventFilterConverterFactory.FACTORY_NAME, factory);
 
       remoteCache = client(0).getCache();
 

remote-query/remote-query-server/src/main/java/org/infinispan/query/remote/filter/JPACacheEventFilterConverterFactory.java

@@ -1,17 +1,16 @@
 package org.infinispan.query.remote.filter;
 
 import org.infinispan.commons.CacheException;
-import org.infinispan.notifications.cachelistener.filter.CacheEventConverter;
-import org.infinispan.notifications.cachelistener.filter.CacheEventConverterFactory;
-import org.infinispan.notifications.cachelistener.filter.CacheEventFilter;
-import org.infinispan.notifications.cachelistener.filter.CacheEventFilterFactory;
+import org.infinispan.notifications.cachelistener.filter.CacheEventFilterConverter;
+import org.infinispan.notifications.cachelistener.filter.CacheEventFilterConverterFactory;
 import org.infinispan.notifications.cachelistener.filter.NamedFactory;
 import org.infinispan.objectfilter.impl.ProtobufMatcher;
 import org.infinispan.protostream.ProtobufUtil;
 import org.infinispan.protostream.SerializationContext;
 import org.infinispan.protostream.config.Configuration;
 import org.infinispan.query.dsl.embedded.impl.JPAFilterAndConverter;
 import org.infinispan.query.remote.client.BaseProtoStreamMarshaller;
+import org.kohsuke.MetaInfServices;
 
 import java.io.IOException;
 
@@ -20,7 +19,8 @@
  * @since 7.2
  */
 @NamedFactory(name = JPACacheEventFilterConverterFactory.FACTORY_NAME)
-public class JPACacheEventFilterConverterFactory implements CacheEventFilterFactory, CacheEventConverterFactory {
+@MetaInfServices
+public class JPACacheEventFilterConverterFactory implements CacheEventFilterConverterFactory {
 
    public static final String FACTORY_NAME = "query-dsl-filter-converter-factory";
 
@@ -35,16 +35,7 @@ protected SerializationContext getSerializationContext() {
    };
 
    @Override
-   public CacheEventFilter<byte[], byte[]> getFilter(Object[] params) {
-      return getCacheEventFilterConverter(params);
-   }
-
-   @Override
-   public CacheEventConverter<byte[], byte[], byte[]> getConverter(Object[] params) {
-      return getCacheEventFilterConverter(params);
-   }
-
-   private JPAProtobufCacheEventFilterConverter getCacheEventFilterConverter(Object[] params) {
+   public CacheEventFilterConverter<byte[], byte[], byte[]> getFilterConverter(Object[] params) {
       String jpql;
       try {
          jpql = (String) paramMarshaller.objectFromByteBuffer((byte[]) params[0]);