-
-
Notifications
You must be signed in to change notification settings - Fork 6
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* Update generated classes after commit 64c46f2 * Add JNet on compilation classpath --------- Co-authored-by: masesdevelopers <94312179+masesdevelopers@users.noreply.github.com>
- Loading branch information
1 parent
a4d2898
commit 1c0166d
Showing
1,124 changed files
with
65,236 additions
and
65,283 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
93 changes: 70 additions & 23 deletions
93
.../java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerInterceptor.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -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"); | ||
| } | ||
|
|
||
| } |
99 changes: 74 additions & 25 deletions
99
...org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
90 changes: 68 additions & 22 deletions
90
...org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.