Verify if the error raised can be expected

[masesdevelopers]

A test reports:

Error: Exception in thread "TestApplication-98fc4afe-73e9-4aaa-b6f0-6af39382cf93-CloseThread" java.lang.UnsupportedOperationException: The method shall be implemented in .NET side since does not have a default implementation within the JVM
at org.mases.knet.generated.org.apache.kafka.streams.KafkaStreams_StateListener.onChange(KafkaStreams_StateListener.java:76)
at org.apache.kafka.streams.KafkaStreams.setState(KafkaStreams.java:367)
at org.apache.kafka.streams.KafkaStreams.lambda$shutdownHelper$23(KafkaStreams.java:1523)
at java.base/java.lang.Thread.run(Thread.java:1583)

The code shall be verified to check if it is an expected behavior in some conditions: other tests executes the same pattern, but the error is not raised.

Originally posted by @masesdevelopers in masesgroup/KEFCore#339 (comment)

[masesdevelopers]

The method

KNet/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/KafkaStreams_StateListener.java

Line 74 in 760f0a3

public void onChange(org.apache.kafka.streams.KafkaStreams.State arg0, org.apache.kafka.streams.KafkaStreams.State arg1) {

reports java.lang.UnsupportedOperationException: The method shall be implemented in .NET side since does not have a default implementation within the JVM if and only if org.mases.jnet.developed.JNetEventResult returns false from getHasOverride().
The value returned from getHasOverride() is filled in the method

KNet/src/net/KNet/Generated/Org/Apache/Kafka/Streams/KafkaStreams.cs

Line 732 in 760f0a3

void OnChangeEventHandler(object sender, CLRListenerEventArgs<CLREventData<MASES.JNet.Specific.JNetEventResult>> data)

The default value is

KNet/src/net/KNet/Generated/Org/Apache/Kafka/Streams/KafkaStreams.cs

Line 734 in 760f0a3

hasOverrideOnChange = true;

If the property

KNet/src/net/KNet/Generated/Org/Apache/Kafka/Streams/KafkaStreams.cs

Line 729 in 760f0a3

public global::System.Action<Org.Apache.Kafka.Streams.KafkaStreams.State, Org.Apache.Kafka.Streams.KafkaStreams.State> OnOnChange { get; set; } = null;

is not set, the fallback is

KNet/src/net/KNet/Generated/Org/Apache/Kafka/Streams/KafkaStreams.cs

Line 745 in 760f0a3

public virtual void OnChange(Org.Apache.Kafka.Streams.KafkaStreams.State arg0, Org.Apache.Kafka.Streams.KafkaStreams.State arg1)

which turns the value to false, if the method

KNet/src/net/KNet/Generated/Org/Apache/Kafka/Streams/KafkaStreams.cs

Line 745 in 760f0a3

public virtual void OnChange(Org.Apache.Kafka.Streams.KafkaStreams.State arg0, Org.Apache.Kafka.Streams.KafkaStreams.State arg1)

is overridden from the user the value of hasOverrideOnChange cannot be changed from user code since it is a private member of the base class.

At the end, the problem can be raised from an early reset of the value of

KNet/src/net/KNet/Generated/Org/Apache/Kafka/Streams/KafkaStreams.cs

Line 729 in 760f0a3

public global::System.Action<Org.Apache.Kafka.Streams.KafkaStreams.State, Org.Apache.Kafka.Streams.KafkaStreams.State> OnOnChange { get; set; } = null;

It is possible that the class using the instance of

KNet/src/net/KNet/Generated/Org/Apache/Kafka/Streams/KafkaStreams.cs

Line 697 in 760f0a3

public partial class StateListener

is still alive and, most of the time, the GC retires the object later than the last usage from

KNet/src/net/KNet/Generated/Org/Apache/Kafka/Streams/KafkaStreams.cs

Line 190 in 760f0a3

public partial class KafkaStreams

Try to reset the value using

KNet/src/net/KNet/Generated/Org/Apache/Kafka/Streams/KafkaStreams.cs

Line 492 in 760f0a3

public void SetStateListener(Org.Apache.Kafka.Streams.KafkaStreams.StateListener arg0)

just before Dispose the StateListener