This is an automated email from the ASF dual-hosted git repository.
nizhikov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 6c529f5f856 [MINOR] Simplify GridClientOptimizedMarshaller (#12254)
6c529f5f856 is described below
commit 6c529f5f856f42bf2a33b37babdedfe0d5eedb2b
Author: Nikolay <[email protected]>
AuthorDate: Wed Aug 6 16:30:00 2025 +0300
[MINOR] Simplify GridClientOptimizedMarshaller (#12254)
---
.../optimized/GridClientOptimizedMarshaller.java | 38 ++--------------------
1 file changed, 2 insertions(+), 36 deletions(-)
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/client/marshaller/optimized/GridClientOptimizedMarshaller.java
b/modules/core/src/main/java/org/apache/ignite/internal/client/marshaller/optimized/GridClientOptimizedMarshaller.java
index 2af1841b715..267abee4784 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/client/marshaller/optimized/GridClientOptimizedMarshaller.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/client/marshaller/optimized/GridClientOptimizedMarshaller.java
@@ -21,7 +21,6 @@ import java.io.IOException;
import java.nio.ByteBuffer;
import java.util.List;
import org.apache.ignite.IgniteCheckedException;
-import org.apache.ignite.IgniteException;
import org.apache.ignite.internal.MarshallerContextImpl;
import org.apache.ignite.internal.client.marshaller.GridClientMarshaller;
import org.apache.ignite.internal.marshaller.optimized.OptimizedMarshaller;
@@ -47,7 +46,7 @@ public class GridClientOptimizedMarshaller implements
GridClientMarshaller {
public GridClientOptimizedMarshaller() {
opMarsh = new OptimizedMarshaller();
- opMarsh.setContext(new ClientMarshallerContext());
+ opMarsh.setContext(new MarshallerContextImpl(null, null));
}
/**
@@ -58,24 +57,7 @@ public class GridClientOptimizedMarshaller implements
GridClientMarshaller {
public GridClientOptimizedMarshaller(@Nullable List<PluginProvider>
plugins) {
opMarsh = new OptimizedMarshaller();
- opMarsh.setContext(new ClientMarshallerContext(plugins));
- }
-
- /**
- * Constructs optimized marshaller with specific parameters.
- *
- * @param requireSer Require serializable flag.
- * @param poolSize Object streams pool size.
- * @throws IOException If an I/O error occurs while writing stream header.
- * @throws IgniteException If this marshaller is not supported on the
current JVM.
- * @see OptimizedMarshaller
- */
- public GridClientOptimizedMarshaller(boolean requireSer, int poolSize)
throws IOException {
- opMarsh = new OptimizedMarshaller();
-
- opMarsh.setContext(new ClientMarshallerContext());
- opMarsh.setRequireSerializable(requireSer);
- opMarsh.setPoolSize(poolSize);
+ opMarsh.setContext(new MarshallerContextImpl(plugins, null));
}
/** {@inheritDoc} */
@@ -111,20 +93,4 @@ public class GridClientOptimizedMarshaller implements
GridClientMarshaller {
throw new IOException(e);
}
}
-
- /**
- */
- private static class ClientMarshallerContext extends MarshallerContextImpl
{
- /** */
- public ClientMarshallerContext() {
- super(null, null);
- }
-
- /**
- * @param plugins Plugins.
- */
- public ClientMarshallerContext(@Nullable List<PluginProvider> plugins)
{
- super(plugins, null);
- }
- }
}