public class IKafkaConfigurationTaskStub extends org.apache.axis.client.Stub implements IKafkaConfigurationTask
| Modifier and Type | Field and Description |
|---|---|
private java.util.Vector |
cachedDeserFactories |
private java.util.Vector |
cachedSerClasses |
private java.util.Vector |
cachedSerFactories |
private java.util.Vector |
cachedSerQNames |
| Constructor and Description |
|---|
IKafkaConfigurationTaskStub() |
IKafkaConfigurationTaskStub(javax.xml.rpc.Service service) |
IKafkaConfigurationTaskStub(java.net.URL endpointURL,
javax.xml.rpc.Service service) |
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
addKafkaConfiguration(KafkaConfigTO dto) |
private void |
addSerial(java.lang.String xmlns,
java.lang.String localname,
java.lang.Class cls,
java.lang.Object serializer,
java.lang.Object deserializer) |
protected org.apache.axis.client.Call |
createCall() |
void |
deleteKafkaConfiguration(java.lang.String keyID) |
KafkaConfigTO |
findKafkaConfigurationByKeyID(java.lang.String keyID) |
java.lang.Object |
findKafkaProducerNonReservedSettings() |
KafkaConfigTO[] |
listAllKafkaConfiguration() |
void |
updateKafkaConfiguration(KafkaConfigTO dto) |
private java.util.Vector cachedSerClasses
private java.util.Vector cachedSerQNames
private java.util.Vector cachedSerFactories
private java.util.Vector cachedDeserFactories
public IKafkaConfigurationTaskStub()
throws org.apache.axis.AxisFault
org.apache.axis.AxisFaultpublic IKafkaConfigurationTaskStub(java.net.URL endpointURL,
javax.xml.rpc.Service service)
throws org.apache.axis.AxisFault
org.apache.axis.AxisFaultpublic IKafkaConfigurationTaskStub(javax.xml.rpc.Service service)
throws org.apache.axis.AxisFault
org.apache.axis.AxisFaultprivate void addSerial(java.lang.String xmlns,
java.lang.String localname,
java.lang.Class cls,
java.lang.Object serializer,
java.lang.Object deserializer)
protected org.apache.axis.client.Call createCall()
throws java.rmi.RemoteException
java.rmi.RemoteExceptionpublic java.lang.Object findKafkaProducerNonReservedSettings()
throws java.rmi.RemoteException
findKafkaProducerNonReservedSettings in interface IKafkaConfigurationTaskjava.rmi.RemoteExceptionpublic void updateKafkaConfiguration(KafkaConfigTO dto) throws java.rmi.RemoteException
updateKafkaConfiguration in interface IKafkaConfigurationTaskjava.rmi.RemoteExceptionpublic KafkaConfigTO findKafkaConfigurationByKeyID(java.lang.String keyID) throws java.rmi.RemoteException
findKafkaConfigurationByKeyID in interface IKafkaConfigurationTaskjava.rmi.RemoteExceptionpublic KafkaConfigTO[] listAllKafkaConfiguration() throws java.rmi.RemoteException
listAllKafkaConfiguration in interface IKafkaConfigurationTaskjava.rmi.RemoteExceptionpublic java.lang.String addKafkaConfiguration(KafkaConfigTO dto) throws java.rmi.RemoteException
addKafkaConfiguration in interface IKafkaConfigurationTaskjava.rmi.RemoteExceptionpublic void deleteKafkaConfiguration(java.lang.String keyID)
throws java.rmi.RemoteException
deleteKafkaConfiguration in interface IKafkaConfigurationTaskjava.rmi.RemoteException