diff --git a/bom/runtime/pom.xml b/bom/runtime/pom.xml index e5c7dde5c4961..2b501944afc02 100644 --- a/bom/runtime/pom.xml +++ b/bom/runtime/pom.xml @@ -119,8 +119,8 @@ 6.14.2 3.13.2 2.3 - 10.0.0.CR1 - 4.3.0.Alpha10 + 10.0.0.Final + 4.3.0.Final 2.6.2 4.1.42.Final 1.0.3 diff --git a/extensions/infinispan-client/runtime/pom.xml b/extensions/infinispan-client/runtime/pom.xml index 040ce6ac7f9b5..a1f9138c2e6b9 100644 --- a/extensions/infinispan-client/runtime/pom.xml +++ b/extensions/infinispan-client/runtime/pom.xml @@ -54,8 +54,8 @@ infinispan-client-hotrod - org.jboss.marshalling - jboss-marshalling-osgi + org.infinispan + infinispan-jboss-marshalling org.jboss.spec.javax.transaction diff --git a/extensions/infinispan-client/runtime/src/main/java/io/quarkus/infinispan/client/runtime/InfinispanClientProducer.java b/extensions/infinispan-client/runtime/src/main/java/io/quarkus/infinispan/client/runtime/InfinispanClientProducer.java index d6c629f5e6765..e628fab967b3e 100644 --- a/extensions/infinispan-client/runtime/src/main/java/io/quarkus/infinispan/client/runtime/InfinispanClientProducer.java +++ b/extensions/infinispan-client/runtime/src/main/java/io/quarkus/infinispan/client/runtime/InfinispanClientProducer.java @@ -1,6 +1,5 @@ package io.quarkus.infinispan.client.runtime; -import java.io.IOException; import java.io.InputStream; import java.lang.annotation.Annotation; import java.util.Map; @@ -26,7 +25,6 @@ import org.infinispan.client.hotrod.logging.Log; import org.infinispan.client.hotrod.logging.LogFactory; import org.infinispan.client.hotrod.marshall.ProtoStreamMarshaller; -import org.infinispan.commons.CacheConfigurationException; import org.infinispan.commons.marshall.Marshaller; import org.infinispan.commons.util.Util; import org.infinispan.counter.api.CounterManager; @@ -34,8 +32,8 @@ import org.infinispan.protostream.FileDescriptorSource; import org.infinispan.protostream.SerializationContext; import org.infinispan.protostream.SerializationContextInitializer; +import org.infinispan.protostream.WrappedMessage; import org.infinispan.query.remote.client.ProtobufMetadataManagerConstants; -import org.infinispan.query.remote.client.impl.MarshallerRegistration; /** * Produces a configured remote cache manager instance @@ -129,10 +127,10 @@ public static void handleProtoStreamRequirements(Properties properties) { // Note that the other half is done in QuerySubstitutions.SubstituteMarshallerRegistration class // Note that the registration of these files are done twice in normal VM mode // (once during init and once at runtime) - properties.put(InfinispanClientProducer.PROTOBUF_FILE_PREFIX + MarshallerRegistration.QUERY_PROTO_RES, - getContents(MarshallerRegistration.QUERY_PROTO_RES)); - properties.put(InfinispanClientProducer.PROTOBUF_FILE_PREFIX + MarshallerRegistration.MESSAGE_PROTO_RES, - getContents(MarshallerRegistration.MESSAGE_PROTO_RES)); + properties.put(InfinispanClientProducer.PROTOBUF_FILE_PREFIX + WrappedMessage.PROTO_FILE, + getContents("/" + WrappedMessage.PROTO_FILE)); + String queryProtoFile = "org/infinispan/query/remote/client/query.proto"; + properties.put(InfinispanClientProducer.PROTOBUF_FILE_PREFIX + queryProtoFile, getContents("/" + queryProtoFile)); } /** @@ -206,11 +204,7 @@ private static void handleProtoStreamMarshaller(ProtoStreamMarshaller marshaller .get(InfinispanClientProducer.PROTOBUF_INITIALIZERS); if (initializers != null) { initializers.forEach(sci -> { - try { - sci.registerSchema(serializationContext); - } catch (IOException e) { - throw new CacheConfigurationException(e); - } + sci.registerSchema(serializationContext); sci.registerMarshallers(serializationContext); }); } diff --git a/extensions/infinispan-client/runtime/src/main/java/io/quarkus/infinispan/client/runtime/graal/QuerySubstitutions.java b/extensions/infinispan-client/runtime/src/main/java/io/quarkus/infinispan/client/runtime/graal/QuerySubstitutions.java index 0d22d156fbf32..ac0b0da2963f1 100644 --- a/extensions/infinispan-client/runtime/src/main/java/io/quarkus/infinispan/client/runtime/graal/QuerySubstitutions.java +++ b/extensions/infinispan-client/runtime/src/main/java/io/quarkus/infinispan/client/runtime/graal/QuerySubstitutions.java @@ -22,6 +22,6 @@ final class SubstituteMarshallerRegistration { public static void init(SerializationContext ctx) throws IOException { // Skip loading the proto definition files as this was already done at compile time with // HandleProtostreamMarshaller#handleQueryRequirements - MarshallerRegistration.registerMarshallers(ctx); + MarshallerRegistration.INSTANCE.registerMarshallers(ctx); } } diff --git a/extensions/infinispan-embedded/deployment/src/main/java/io/quarkus/infinispan/embedded/deployment/InfinispanEmbeddedProcessor.java b/extensions/infinispan-embedded/deployment/src/main/java/io/quarkus/infinispan/embedded/deployment/InfinispanEmbeddedProcessor.java index 6474d6d5ae379..349f98da30117 100644 --- a/extensions/infinispan-embedded/deployment/src/main/java/io/quarkus/infinispan/embedded/deployment/InfinispanEmbeddedProcessor.java +++ b/extensions/infinispan-embedded/deployment/src/main/java/io/quarkus/infinispan/embedded/deployment/InfinispanEmbeddedProcessor.java @@ -17,10 +17,10 @@ import org.infinispan.configuration.parsing.ConfigurationParser; import org.infinispan.distribution.ch.ConsistentHashFactory; import org.infinispan.distribution.ch.impl.HashFunctionPartitioner; +import org.infinispan.factories.impl.ModuleMetadataBuilder; import org.infinispan.interceptors.AsyncInterceptor; import org.infinispan.marshall.exts.CollectionExternalizer; import org.infinispan.marshall.exts.MapExternalizer; -import org.infinispan.modules.ModuleMetadataBuilder; import org.infinispan.notifications.Listener; import org.infinispan.persistence.spi.CacheLoader; import org.infinispan.persistence.spi.CacheWriter; @@ -86,6 +86,7 @@ void setup(BuildProducer feature, BuildProducerquarkus-infinispan-embedded Quarkus - Infinispan - Embedded - Runtime - Run an embedded Infinispan data grid server for distributed caching + io.quarkus @@ -26,22 +26,27 @@ quarkus-caffeine + + + io.smallrye + smallrye-metrics + org.infinispan infinispan-core + + org.eclipse.microprofile.metrics + microprofile-metrics-api + org.jboss.spec.javax.transaction - - jboss-transaction-api_1.2_spec - + jboss-transaction-api_1.2_spec - - jakarta.transaction - jakarta.transaction-api - org.jboss.narayana.jta narayana-jta diff --git a/integration-tests/infinispan-client/pom.xml b/integration-tests/infinispan-client/pom.xml index 9fedcd848b150..352a66616e642 100644 --- a/integration-tests/infinispan-client/pom.xml +++ b/integration-tests/infinispan-client/pom.xml @@ -56,6 +56,10 @@ commons-logging commons-logging + + org.hibernate + hibernate-search-serialization-avro + test @@ -76,6 +80,24 @@ test-jar test + + + + com.fasterxml.jackson.core + jackson-core + 2.10.0 + + + com.fasterxml.jackson.core + jackson-databind + 2.10.0 + + + com.fasterxml.jackson.core + jackson-annotations + 2.10.0 + + diff --git a/integration-tests/infinispan-embedded/src/main/resources/10.0.xml b/integration-tests/infinispan-embedded/src/main/resources/10.0.xml index 3ca57d94954ad..e64c3d1eba12e 100644 --- a/integration-tests/infinispan-embedded/src/main/resources/10.0.xml +++ b/integration-tests/infinispan-embedded/src/main/resources/10.0.xml @@ -304,7 +304,7 @@ - +