RTSDK-10325 ArrayOutOfBoundsException when process message in EMA and ETA Java

Author: V-Anyakin

CMake/rtsdkInfo.cmake

@@ -13,8 +13,8 @@ unset(rtsdk_DEPENDS_LIST)
 set(rtsdk_INTERNAL_API_VERSION_MAJOR 3)
 set(rtsdk_INTERNAL_API_VERSION_MINOR 9)
 set(rtsdk_INTERNAL_API_VERSION_PATCH 1)
-set(rtsdk_INTERNAL_API_VERSION_TWEAK 1)
-set(rtsdk_INTERNAL_RELEASE_TWEAK G1)
+set(rtsdk_INTERNAL_API_VERSION_TWEAK 3)
+set(rtsdk_INTERNAL_RELEASE_TWEAK G2)
 set(rtsdk_RELEASE_TYPE rrg)
 
 set( librssl_SO_VERSION 29 )

CMakeLists.txt

@@ -8,7 +8,7 @@ cmake_minimum_required (VERSION 3.22.0)
 # guarantee of a successful build if changed.
 
 project (rtsdk
-		VERSION 2.3.1.1
+		VERSION 2.3.1.3
 		LANGUAGES C CXX)
 
 set(rtsdk_CMAKE_DIR "${rtsdk_SOURCE_DIR}/CMake")

Java/CHANGELOG.md

@@ -9,27 +9,36 @@ There are three types of RTSDK releases that append a letter directly followed b
 "E" releases (E-Loads) are emergency RTSDK releases that are uploaded to MyAccount and Developer Community but not to GitHub. Also note that emergency releases may only be partial (i.e., Java or C++/C only).
 
 ----------------------------------------------------------------------------------------
-CURRENT RELEASE HIGHLIGHTS - RTSDK Java 2.3.1.G1 aka EMA/ETA 3.9.1.G1 aka 3.9.1.1
+CURRENT RELEASE HIGHLIGHTS - RTSDK Java 2.3.1.G2 aka EMA/ETA 3.9.1.G2 aka 3.9.1.3
 ----------------------------------------------------------------------------------------
 
 This is a maintenance release with critical fixes for customer issues.
 
 Customer Issues Resolved
 ------------------------
-- [Case Number: 15088925] - [RTSDK-10072] - Fixes to exceptions with multiple Consumers started in one application
-- [Case Number: 15242251] - [RTSDK-10184] - EMA Java com.refinitiv.eta.json.util.UtilQueue.growPool threw ArrayIndexOutOfBoundsException
+- [Case Number: 15439870] - [RTSDK-10325] - ArrayOutOfBoundsException when process message in EMA and ETA Java 
 
 ----------------------------------------------------------------------------------------
 FULL CHANGELOG
 ----------------------------------------------------------------------------------------
 
+--------------------------------------------
+RTSDK Java Release 2.3.1.G2 (Nov 25, 2025)
+--------------------------------------------
+
+This is a maintenance release with a critical fix.
+
+EMA Java 3.9.1.G2 Issues Resolved
+---------------------------------
+- [RTSDK-10325] - ArrayOutOfBoundsException when process message in EMA and ETA Java [Case Number: 15439870]
+
 --------------------------------------------
 RTSDK Java Release 2.3.1.G1 (Sep 30, 2025)
 --------------------------------------------
 
 This is a maintenance release with critical fixes for customer issues.
 
-Both ETA Java and EMA Java 3.9.1.L2 Issues Resolved
+Both ETA Java and EMA Java 3.9.1.G1 Issues Resolved
 ---------------------------------------------------
 - [RTSDK-10072] - Fixes to exceptions with multiple Consumers started in one application [Case Number: 15088925]
 - [RTSDK-10184] - EMA Java com.refinitiv.eta.json.util.UtilQueue.growPool threw ArrayIndexOutOfBoundsException [Case Number: 15242251]

Java/Ema/Core/src/main/java/com/refinitiv/ema/access/EmaObjectManager.java

@@ -9,11 +9,15 @@
 package com.refinitiv.ema.access;
 
 import java.nio.ByteBuffer;
+
 import java.util.ArrayList;
+import java.util.ArrayDeque;
 import java.util.Deque;
 import java.util.List;
+
 import java.util.concurrent.ConcurrentLinkedDeque;
-import java.util.ArrayDeque;
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
 
 import com.refinitiv.eta.valueadd.common.VaPool;
 
@@ -25,6 +29,7 @@ class EmaObjectManager
 	private final static int MAX_BYTE_BUFFER_CAPABILITY = 2000;
 	private final static int DEFAULT_ETA_CONTAINER_SIZE = 10;
 
+	private Lock _byteBufferLock = null;
 	private List<ByteBuffer>[] _byteBufferList;
 	private boolean _intialized;
 
@@ -113,6 +118,11 @@ class EmaObjectManager
 
 	EmaObjectManager(boolean globalLock)
 	{
+		if (globalLock)
+		{
+			_byteBufferLock = new ReentrantLock();
+		}
+
 		_ommIntPool = new VaPool(globalLock);
 		_ommUIntPool = new VaPool(globalLock);
 		_ommFloatPool = new VaPool(globalLock);
@@ -375,33 +385,44 @@ ByteBuffer acquireByteBuffer(int length)
 		int pos = length / DEFAULT_BYTE_BUFFER_SIZE;
 		ByteBuffer retVal;
 
-		if (pos < MAX_NUM_BYTE_BUFFER)
+		if (_byteBufferLock != null)
+			_byteBufferLock.lock();
+
+		try
 		{
-			if (!_byteBufferList[pos].isEmpty())
+			if (pos < MAX_NUM_BYTE_BUFFER)
 			{
-				retVal = _byteBufferList[pos].remove(_byteBufferList[pos].size() - 1);
-				retVal.clear();
-				return retVal;
-			}
+				if (!_byteBufferList[pos].isEmpty())
+				{
+					retVal = _byteBufferList[pos].remove(_byteBufferList[pos].size() - 1);
+					retVal.clear();
+					return retVal;
+				}
 
-			return ByteBuffer.allocate((pos + 1) * DEFAULT_BYTE_BUFFER_SIZE);
-		} else
-		{
-			if (!_byteBufferList[MAX_NUM_BYTE_BUFFER].isEmpty())
+				return ByteBuffer.allocate((pos + 1) * DEFAULT_BYTE_BUFFER_SIZE);
+			} else
 			{
-				int size = _byteBufferList[MAX_NUM_BYTE_BUFFER].size() - 1;
-				for (int index = size; index >= 0; --index)
+				if (!_byteBufferList[MAX_NUM_BYTE_BUFFER].isEmpty())
 				{
-					if (length < _byteBufferList[MAX_NUM_BYTE_BUFFER].get(index).capacity())
+					int size = _byteBufferList[MAX_NUM_BYTE_BUFFER].size() - 1;
+					for (int index = size; index >= 0; --index)
 					{
-						retVal = _byteBufferList[MAX_NUM_BYTE_BUFFER].remove(index);
-						retVal.clear();
-						return retVal;
+						if (length < _byteBufferList[MAX_NUM_BYTE_BUFFER].get(index).capacity())
+						{
+							retVal = _byteBufferList[MAX_NUM_BYTE_BUFFER].remove(index);
+							retVal.clear();
+							return retVal;
+						}
 					}
 				}
-			}
 
-			return ByteBuffer.allocate(length);
+				return ByteBuffer.allocate(length);
+			}
+		}
+		finally
+		{
+			if (_byteBufferLock != null)
+				_byteBufferLock.unlock();
 		}
 	}
 
@@ -410,12 +431,23 @@ void releaseByteBuffer(ByteBuffer buffer)
 		if (buffer == null)
 			return;
 
-		int pos = buffer.capacity() / DEFAULT_BYTE_BUFFER_SIZE - 1;
+		if (_byteBufferLock != null)
+			_byteBufferLock.lock();
 
-		if (pos < MAX_NUM_BYTE_BUFFER)
-			_byteBufferList[pos].add(buffer);
-		else
-			_byteBufferList[MAX_NUM_BYTE_BUFFER].add(buffer);
+		try
+		{
+			int pos = buffer.capacity() / DEFAULT_BYTE_BUFFER_SIZE - 1;
+
+			if (pos < MAX_NUM_BYTE_BUFFER)
+				_byteBufferList[pos].add(buffer);
+			else
+				_byteBufferList[MAX_NUM_BYTE_BUFFER].add(buffer);
+		}
+		finally
+		{
+			if (_byteBufferLock != null)
+				_byteBufferLock.unlock();
+		}
 	}
 
 	@SuppressWarnings("unchecked")

Java/Ema/README.md

@@ -72,9 +72,9 @@ In addtion, HTML documentation is available in Java/Ema/Docs. For addtional docu
 
     Library Name            Package Version
     ------------            ----------------
-    ema-3.9.1.0.jar         ema3.9.1.L1
+    ema-3.9.1.3.jar         ema3.9.1.G2
 
-    NOTE: ema-3.9.1.0-test.jar containing test utilities is available and published to Maven Central. This may also be built using `gradlew packageTests`.
+    NOTE: ema-3.9.1.3-test.jar containing test utilities is available and published to Maven Central. This may also be built using `gradlew packageTests`.
 
 # EMA Java Issues and Workarounds
 

Java/Eta/README.md

@@ -121,21 +121,21 @@ The distribution contains several JAR files and other non-Java libraries, intend
 
     Library Name                  Package Version   Description
     ------------                  ----------------  -----------
-    eta-3.9.1.0.jar               eta3.9.1.L1       The ETA - Java Edition library.  Includes
+    eta-3.9.1.3.jar               eta3.9.1.G2       The ETA - Java Edition library.  Includes
                                                     the ETA transport package and the RWF codec.
 
-    etaValueAdd-3.9.1.0.jar       eta3.9.1.L1       The Value Add library for ETA Java Edition.
+    etaValueAdd-3.9.1.3.jar       eta3.9.1.G2       The Value Add library for ETA Java Edition.
                                                     Includes the ETA Value Add Reactor and
                                                     Administration Domain Model Representations.
 
-    etaValueAddCache-3.9.1.0.jar  eta3.9.1.L1       The Value Add payload cache library for ETA
+    etaValueAddCache-3.9.1.3.jar  eta3.9.1.G2       The Value Add payload cache library for ETA
                                                     Java Edition.
 
-    etajConverter-3.9.1.0.jar     eta3.9.1.L1       The RWF/JSON Converter library.
+    etajConverter-3.9.1.3.jar     eta3.9.1.G2       The RWF/JSON Converter library.
 
     jDacsEtalib.jar               dacs7.12          The ETA Java DACS library.
 
-    ansipage-3.9.1.0.jar          eta3.9.1.L1       The ANSI decoders and encoders.
+    ansipage-3.9.1.3.jar          eta3.9.1.G2       The ANSI decoders and encoders.
                   
 
     ETAC/ETA/RSSL JNI Libs        eta3.9.1.L1       The JNI libraries for Reliable Multicast

Java/README.md

@@ -225,40 +225,40 @@ You can download RTSDK libraries and dependencies from Maven Central using sever
     <dependency>
         <groupId>com.refinitiv.ema</groupId>
         <artifactId>ema</artifactId>
-        <version>3.9.1.0</version>
+        <version>3.9.1.3</version>
     </dependency>
 
     <dependency>
         <groupId>com.refinitiv.eta</groupId>
         <artifactId>eta</artifactId>
-        <version>3.9.1.0</version>
+        <version>3.9.1.3</version>
     </dependency>
 
     <dependency>
         <groupId>com.refinitiv.eta.valueadd</groupId>
         <artifactId>etaValueAdd</artifactId>
-        <version>3.9.1.0</version>
+        <version>3.9.1.3</version>
     </dependency>
 
     <dependency>
         <groupId>com.refinitiv.eta.valueadd.cache</groupId>
         <artifactId>etaValueAddCache</artifactId>
-        <version>3.9.1.0</version>
+        <version>3.9.1.3</version>
     </dependency>
 
     <dependency>
         <groupId>com.refinitiv.eta.ansi</groupId>
         <artifactId>ansipage</artifactId>
-        <version>3.9.1.0</version>
+        <version>3.9.1.3</version>
     </dependency>
 
 Gradle uses the following syntax to specify RTSDK dependencies:
 
-    compile group: 'com.refinitiv.ema', name: 'ema', version: '3.9.1.0'
-    compile group: 'com.refinitiv.eta', name: 'eta', version: '3.9.1.0'
-    compile group: 'com.refinitiv.eta.valueadd', name: 'etaValueAdd', version: '3.9.1.0'
-    compile group: 'com.refinitiv.eta.valueadd.cache', name: 'etaValueAddCache', version: '3.9.1.0'
-    compile group: 'com.refinitiv.eta.ansi', name: 'ansipage', version: '3.9.1.0'
+    compile group: 'com.refinitiv.ema', name: 'ema', version: '3.9.1.3'
+    compile group: 'com.refinitiv.eta', name: 'eta', version: '3.9.1.3'
+    compile group: 'com.refinitiv.eta.valueadd', name: 'etaValueAdd', version: '3.9.1.3'
+    compile group: 'com.refinitiv.eta.valueadd.cache', name: 'etaValueAddCache', version: '3.9.1.3'
+    compile group: 'com.refinitiv.eta.ansi', name: 'ansipage', version: '3.9.1.3'
 
 # Developing 
 

Java/build.gradle

@@ -37,16 +37,16 @@ repositories {
 
 ext.YEAR = '2025'
 
-ext.BuildDate = 'Tue Sep 30 8:00:00 CDT ' + "$YEAR"
-ext.SpecificationVersion = '3.9.1.1'
+ext.BuildDate = 'Thu Nov 20 8:00:00 CDT ' + "$YEAR"
+ext.SpecificationVersion = '3.9.1.3'
 ext.SpecificationVersionShort = '3.9.1'
 
 // Comment out line below to publish offical release
 // ext.SpecificationVersion = "$SpecificationVersion" + "-SNAPSHOT"
 
 // Update below to L1.all.rrg, G1.all.gload, or E1.all.eload when needed
-ext.etaImplementationVersion = 'etaj' + "$SpecificationVersionShort" + '.G1.all.rrg'
-ext.emaImplementationVersion = 'emaj' + "$SpecificationVersionShort" + '.G1.all.rrg'
+ext.etaImplementationVersion = 'etaj' + "$SpecificationVersionShort" + '.G2.all.rrg'
+ext.emaImplementationVersion = 'emaj' + "$SpecificationVersionShort" + '.G2.all.rrg'
 
 // NOTE! update with new asset version
 ext.BINARY_PACK_VERSION_TO_DOWNLOAD = '2.3.1.L1'