Changes by GitHub action

src/jvm/knet/pom.xml

@@ -43,6 +43,7 @@
 		<kafkaVersion>3.8.0</kafkaVersion>
 		<knetVersion>2.8.0.0</knetVersion>
 		<jcobridgepath>../../../bin/net8.0/JCOBridge.jar</jcobridgepath>
+		<jnetpath>../../../bin/net8.0/jars/jnet-2.5.9.0.jar</jnetpath>
 	</properties>
 	<distributionManagement>
 		<snapshotRepository>
@@ -134,7 +135,7 @@
 				<configuration>
 					<compilerArgs>
 						<arg>-cp</arg>
-						<arg>${originalClassPath}${path.separator}${basedir}/${jcobridgepath}</arg>
+						<arg>${originalClassPath}${path.separator}${basedir}/${jcobridgepath}${path.separator}${basedir}/${jnetpath}</arg>
 					</compilerArgs>
 				</configuration>
 			</plugin>

src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerInterceptor.java

@@ -1,47 +1,94 @@
 /*
- *  Copyright 2024 MASES s.r.l.
- *
- *  Licensed under the Apache License, Version 2.0 (the "License");
- *  you may not use this file except in compliance with the License.
- *  You may obtain a copy of the License at
- *
- *  http://www.apache.org/licenses/LICENSE-2.0
- *
- *  Unless required by applicable law or agreed to in writing, software
- *  distributed under the License is distributed on an "AS IS" BASIS,
- *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- *  See the License for the specific language governing permissions and
- *  limitations under the License.
- *
- *  Refer to LICENSE for more information.
- */
+*  Copyright 2024 MASES s.r.l.
+*
+*  Licensed under the Apache License, Version 2.0 (the "License");
+*  you may not use this file except in compliance with the License.
+*  You may obtain a copy of the License at
+*
+*  http://www.apache.org/licenses/LICENSE-2.0
+*
+*  Unless required by applicable law or agreed to in writing, software
+*  distributed under the License is distributed on an "AS IS" BASIS,
+*  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+*  See the License for the specific language governing permissions and
+*  limitations under the License.
+*
+*  Refer to LICENSE for more information.
+*/
 
 /*
-*  This file is generated by MASES.JNetReflector (ver. 2.5.8.0)
+*  This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
 */
 
 package org.mases.knet.generated.org.apache.kafka.clients.consumer;
 
-public final class ConsumerInterceptor extends org.mases.jcobridge.JCListener implements org.apache.kafka.clients.consumer.ConsumerInterceptor {
+public final class ConsumerInterceptor implements org.mases.jcobridge.IJCListener, org.apache.kafka.clients.consumer.ConsumerInterceptor {
+    final org.mases.jcobridge.JCListener _internalListener;
+
     public ConsumerInterceptor(String key) throws org.mases.jcobridge.JCNativeException {
-        super(key);
+        super();
+        _internalListener = new org.mases.jcobridge.JCListener(key);
+    }
+
+    public synchronized void release() {
+       _internalListener.release();
+    }
+
+    public synchronized void raiseEvent(String eventName) {
+       _internalListener.raiseEvent(eventName);
+    }
+
+    public synchronized void raiseEvent(String eventName, Object e) {
+       _internalListener.raiseEvent(eventName, e);
+    }
+
+    public synchronized void raiseEvent(String eventName, Object e, Object... objects) {
+       _internalListener.raiseEvent(eventName, e, objects);
+    }
+
+    public Object getEventData() {
+       return _internalListener.getEventData();
+    }
+
+    public boolean hasExtraData() {
+       return _internalListener.hasExtraData();
+    }
+
+    public int extraDataLength() {
+       return _internalListener.extraDataLength();
+    }
+
+    public Object[] extraData() {
+       return _internalListener.extraData();
+    }
+
+    public Object getReturnData() {
+       return _internalListener.getReturnData();
+    }
+
+    public void setReturnData(Object retData) {
+       _internalListener.setReturnData(retData);
     }
 
     //@Override
     public org.apache.kafka.clients.consumer.ConsumerRecords onConsume(org.apache.kafka.clients.consumer.ConsumerRecords arg0) {
-        raiseEvent("onConsume", arg0); Object retVal = getReturnData(); return (org.apache.kafka.clients.consumer.ConsumerRecords)retVal;
+        org.mases.jnet.developed.JNetEventResult eventDataExchange = new org.mases.jnet.developed.JNetEventResult();
+        raiseEvent("onConsume", eventDataExchange, arg0); if (!eventDataExchange.getHasOverride()) throw new UnsupportedOperationException("The method shall be implemented in .NET side since does not have a default implementation within the JVM"); Object retVal = eventDataExchange.getReturnData(); return (org.apache.kafka.clients.consumer.ConsumerRecords)retVal;
     }
     //@Override
     public void close() {
-        raiseEvent("close");
+        org.mases.jnet.developed.JNetEventResult eventDataExchange = new org.mases.jnet.developed.JNetEventResult();
+        raiseEvent("close", eventDataExchange); if (!eventDataExchange.getHasOverride()) throw new UnsupportedOperationException("The method shall be implemented in .NET side since does not have a default implementation within the JVM");
     }
     //@Override
     public void onCommit(java.util.Map arg0) {
-        raiseEvent("onCommit", arg0);
+        org.mases.jnet.developed.JNetEventResult eventDataExchange = new org.mases.jnet.developed.JNetEventResult();
+        raiseEvent("onCommit", eventDataExchange, arg0); if (!eventDataExchange.getHasOverride()) throw new UnsupportedOperationException("The method shall be implemented in .NET side since does not have a default implementation within the JVM");
     }
     //@Override
     public void configure(java.util.Map arg0) {
-        raiseEvent("configure", arg0);
+        org.mases.jnet.developed.JNetEventResult eventDataExchange = new org.mases.jnet.developed.JNetEventResult();
+        raiseEvent("configure", eventDataExchange, arg0); if (!eventDataExchange.getHasOverride()) throw new UnsupportedOperationException("The method shall be implemented in .NET side since does not have a default implementation within the JVM");
     }
 
 }

src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.java

@@ -1,67 +1,116 @@
 /*
- *  Copyright 2024 MASES s.r.l.
- *
- *  Licensed under the Apache License, Version 2.0 (the "License");
- *  you may not use this file except in compliance with the License.
- *  You may obtain a copy of the License at
- *
- *  http://www.apache.org/licenses/LICENSE-2.0
- *
- *  Unless required by applicable law or agreed to in writing, software
- *  distributed under the License is distributed on an "AS IS" BASIS,
- *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- *  See the License for the specific language governing permissions and
- *  limitations under the License.
- *
- *  Refer to LICENSE for more information.
- */
+*  Copyright 2024 MASES s.r.l.
+*
+*  Licensed under the Apache License, Version 2.0 (the "License");
+*  you may not use this file except in compliance with the License.
+*  You may obtain a copy of the License at
+*
+*  http://www.apache.org/licenses/LICENSE-2.0
+*
+*  Unless required by applicable law or agreed to in writing, software
+*  distributed under the License is distributed on an "AS IS" BASIS,
+*  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+*  See the License for the specific language governing permissions and
+*  limitations under the License.
+*
+*  Refer to LICENSE for more information.
+*/
 
 /*
-*  This file is generated by MASES.JNetReflector (ver. 2.5.8.0)
+*  This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
 */
 
 package org.mases.knet.generated.org.apache.kafka.clients.consumer;
 
-public final class ConsumerPartitionAssignor extends org.mases.jcobridge.JCListener implements org.apache.kafka.clients.consumer.ConsumerPartitionAssignor {
+public final class ConsumerPartitionAssignor implements org.mases.jcobridge.IJCListener, org.apache.kafka.clients.consumer.ConsumerPartitionAssignor {
+    final org.mases.jcobridge.JCListener _internalListener;
+
     public ConsumerPartitionAssignor(String key) throws org.mases.jcobridge.JCNativeException {
-        super(key);
+        super();
+        _internalListener = new org.mases.jcobridge.JCListener(key);
+    }
+
+    public synchronized void release() {
+       _internalListener.release();
+    }
+
+    public synchronized void raiseEvent(String eventName) {
+       _internalListener.raiseEvent(eventName);
+    }
+
+    public synchronized void raiseEvent(String eventName, Object e) {
+       _internalListener.raiseEvent(eventName, e);
+    }
+
+    public synchronized void raiseEvent(String eventName, Object e, Object... objects) {
+       _internalListener.raiseEvent(eventName, e, objects);
+    }
+
+    public Object getEventData() {
+       return _internalListener.getEventData();
+    }
+
+    public boolean hasExtraData() {
+       return _internalListener.hasExtraData();
+    }
+
+    public int extraDataLength() {
+       return _internalListener.extraDataLength();
+    }
+
+    public Object[] extraData() {
+       return _internalListener.extraData();
+    }
+
+    public Object getReturnData() {
+       return _internalListener.getReturnData();
+    }
+
+    public void setReturnData(Object retData) {
+       _internalListener.setReturnData(retData);
     }
 
     //@Override
     public java.lang.String name() {
-        raiseEvent("name"); Object retVal = getReturnData(); return (java.lang.String)retVal;
+        org.mases.jnet.developed.JNetEventResult eventDataExchange = new org.mases.jnet.developed.JNetEventResult();
+        raiseEvent("name", eventDataExchange); if (!eventDataExchange.getHasOverride()) throw new UnsupportedOperationException("The method shall be implemented in .NET side since does not have a default implementation within the JVM"); Object retVal = eventDataExchange.getReturnData(); return (java.lang.String)retVal;
     }
     //@Override
     public org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.GroupAssignment assign(org.apache.kafka.common.Cluster arg0, org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.GroupSubscription arg1) {
-        raiseEvent("assign", arg0, arg1); Object retVal = getReturnData(); return (org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.GroupAssignment)retVal;
+        org.mases.jnet.developed.JNetEventResult eventDataExchange = new org.mases.jnet.developed.JNetEventResult();
+        raiseEvent("assign", eventDataExchange, arg0, arg1); if (!eventDataExchange.getHasOverride()) throw new UnsupportedOperationException("The method shall be implemented in .NET side since does not have a default implementation within the JVM"); Object retVal = eventDataExchange.getReturnData(); return (org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.GroupAssignment)retVal;
     }
     //@Override
     public java.nio.ByteBuffer subscriptionUserData(java.util.Set arg0) {
-        raiseEvent("subscriptionUserData", arg0); Object retVal = getReturnData(); return (java.nio.ByteBuffer)retVal;
+        org.mases.jnet.developed.JNetEventResult eventDataExchange = new org.mases.jnet.developed.JNetEventResult();
+        raiseEvent("subscriptionUserData", eventDataExchange, arg0); Object retVal; if (!eventDataExchange.getHasOverride()) retVal = org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.super.subscriptionUserData(arg0); else retVal = eventDataExchange.getReturnData(); return (java.nio.ByteBuffer)retVal;
     }
     //@Override
     public java.nio.ByteBuffer subscriptionUserDataDefault(java.util.Set arg0) {
         return org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.super.subscriptionUserData(arg0);
     }
     //@Override
     public java.util.List supportedProtocols() {
-        raiseEvent("supportedProtocols"); Object retVal = getReturnData(); return (java.util.List)retVal;
+        org.mases.jnet.developed.JNetEventResult eventDataExchange = new org.mases.jnet.developed.JNetEventResult();
+        raiseEvent("supportedProtocols", eventDataExchange); Object retVal; if (!eventDataExchange.getHasOverride()) retVal = org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.super.supportedProtocols(); else retVal = eventDataExchange.getReturnData(); return (java.util.List)retVal;
     }
     //@Override
     public java.util.List supportedProtocolsDefault() {
         return org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.super.supportedProtocols();
     }
     //@Override
     public short version() {
-        raiseEvent("version"); Object retVal = getReturnData(); return (short)retVal;
+        org.mases.jnet.developed.JNetEventResult eventDataExchange = new org.mases.jnet.developed.JNetEventResult();
+        raiseEvent("version", eventDataExchange); Object retVal; if (!eventDataExchange.getHasOverride()) retVal = org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.super.version(); else retVal = eventDataExchange.getReturnData(); return (short)retVal;
     }
     //@Override
     public short versionDefault() {
         return org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.super.version();
     }
     //@Override
     public void onAssignment(org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.Assignment arg0, org.apache.kafka.clients.consumer.ConsumerGroupMetadata arg1) {
-        raiseEvent("onAssignment", arg0, arg1);
+        org.mases.jnet.developed.JNetEventResult eventDataExchange = new org.mases.jnet.developed.JNetEventResult();
+        raiseEvent("onAssignment", eventDataExchange, arg0, arg1); if (!eventDataExchange.getHasOverride()) org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.super.onAssignment(arg0, arg1);
     }
     //@Override
     public void onAssignmentDefault(org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.Assignment arg0, org.apache.kafka.clients.consumer.ConsumerGroupMetadata arg1) {

src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java

@@ -1,43 +1,89 @@
 /*
- *  Copyright 2024 MASES s.r.l.
- *
- *  Licensed under the Apache License, Version 2.0 (the "License");
- *  you may not use this file except in compliance with the License.
- *  You may obtain a copy of the License at
- *
- *  http://www.apache.org/licenses/LICENSE-2.0
- *
- *  Unless required by applicable law or agreed to in writing, software
- *  distributed under the License is distributed on an "AS IS" BASIS,
- *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- *  See the License for the specific language governing permissions and
- *  limitations under the License.
- *
- *  Refer to LICENSE for more information.
- */
+*  Copyright 2024 MASES s.r.l.
+*
+*  Licensed under the Apache License, Version 2.0 (the "License");
+*  you may not use this file except in compliance with the License.
+*  You may obtain a copy of the License at
+*
+*  http://www.apache.org/licenses/LICENSE-2.0
+*
+*  Unless required by applicable law or agreed to in writing, software
+*  distributed under the License is distributed on an "AS IS" BASIS,
+*  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+*  See the License for the specific language governing permissions and
+*  limitations under the License.
+*
+*  Refer to LICENSE for more information.
+*/
 
 /*
-*  This file is generated by MASES.JNetReflector (ver. 2.5.8.0)
+*  This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
 */
 
 package org.mases.knet.generated.org.apache.kafka.clients.consumer;
 
-public final class ConsumerRebalanceListener extends org.mases.jcobridge.JCListener implements org.apache.kafka.clients.consumer.ConsumerRebalanceListener {
+public final class ConsumerRebalanceListener implements org.mases.jcobridge.IJCListener, org.apache.kafka.clients.consumer.ConsumerRebalanceListener {
+    final org.mases.jcobridge.JCListener _internalListener;
+
     public ConsumerRebalanceListener(String key) throws org.mases.jcobridge.JCNativeException {
-        super(key);
+        super();
+        _internalListener = new org.mases.jcobridge.JCListener(key);
+    }
+
+    public synchronized void release() {
+       _internalListener.release();
+    }
+
+    public synchronized void raiseEvent(String eventName) {
+       _internalListener.raiseEvent(eventName);
+    }
+
+    public synchronized void raiseEvent(String eventName, Object e) {
+       _internalListener.raiseEvent(eventName, e);
+    }
+
+    public synchronized void raiseEvent(String eventName, Object e, Object... objects) {
+       _internalListener.raiseEvent(eventName, e, objects);
+    }
+
+    public Object getEventData() {
+       return _internalListener.getEventData();
+    }
+
+    public boolean hasExtraData() {
+       return _internalListener.hasExtraData();
+    }
+
+    public int extraDataLength() {
+       return _internalListener.extraDataLength();
+    }
+
+    public Object[] extraData() {
+       return _internalListener.extraData();
+    }
+
+    public Object getReturnData() {
+       return _internalListener.getReturnData();
+    }
+
+    public void setReturnData(Object retData) {
+       _internalListener.setReturnData(retData);
     }
 
     //@Override
     public void onPartitionsAssigned(java.util.Collection arg0) {
-        raiseEvent("onPartitionsAssigned", arg0);
+        org.mases.jnet.developed.JNetEventResult eventDataExchange = new org.mases.jnet.developed.JNetEventResult();
+        raiseEvent("onPartitionsAssigned", eventDataExchange, arg0); if (!eventDataExchange.getHasOverride()) throw new UnsupportedOperationException("The method shall be implemented in .NET side since does not have a default implementation within the JVM");
     }
     //@Override
     public void onPartitionsRevoked(java.util.Collection arg0) {
-        raiseEvent("onPartitionsRevoked", arg0);
+        org.mases.jnet.developed.JNetEventResult eventDataExchange = new org.mases.jnet.developed.JNetEventResult();
+        raiseEvent("onPartitionsRevoked", eventDataExchange, arg0); if (!eventDataExchange.getHasOverride()) throw new UnsupportedOperationException("The method shall be implemented in .NET side since does not have a default implementation within the JVM");
     }
     //@Override
     public void onPartitionsLost(java.util.Collection arg0) {
-        raiseEvent("onPartitionsLost", arg0);
+        org.mases.jnet.developed.JNetEventResult eventDataExchange = new org.mases.jnet.developed.JNetEventResult();
+        raiseEvent("onPartitionsLost", eventDataExchange, arg0); if (!eventDataExchange.getHasOverride()) org.apache.kafka.clients.consumer.ConsumerRebalanceListener.super.onPartitionsLost(arg0);
     }
     //@Override
     public void onPartitionsLostDefault(java.util.Collection arg0) {