Update generated classes after commit db32c1f (#660)

Co-authored-by: masesdevelopers <94312179+masesdevelopers@users.noreply.github.com>

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) {