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.AxisFault
public IKafkaConfigurationTaskStub(java.net.URL endpointURL, javax.xml.rpc.Service service) throws org.apache.axis.AxisFault
org.apache.axis.AxisFault
public IKafkaConfigurationTaskStub(javax.xml.rpc.Service service) throws org.apache.axis.AxisFault
org.apache.axis.AxisFault
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() throws java.rmi.RemoteException
java.rmi.RemoteException
public java.lang.Object findKafkaProducerNonReservedSettings() throws java.rmi.RemoteException
findKafkaProducerNonReservedSettings
in interface IKafkaConfigurationTask
java.rmi.RemoteException
public void updateKafkaConfiguration(KafkaConfigTO dto) throws java.rmi.RemoteException
updateKafkaConfiguration
in interface IKafkaConfigurationTask
java.rmi.RemoteException
public KafkaConfigTO findKafkaConfigurationByKeyID(java.lang.String keyID) throws java.rmi.RemoteException
findKafkaConfigurationByKeyID
in interface IKafkaConfigurationTask
java.rmi.RemoteException
public KafkaConfigTO[] listAllKafkaConfiguration() throws java.rmi.RemoteException
listAllKafkaConfiguration
in interface IKafkaConfigurationTask
java.rmi.RemoteException
public java.lang.String addKafkaConfiguration(KafkaConfigTO dto) throws java.rmi.RemoteException
addKafkaConfiguration
in interface IKafkaConfigurationTask
java.rmi.RemoteException
public void deleteKafkaConfiguration(java.lang.String keyID) throws java.rmi.RemoteException
deleteKafkaConfiguration
in interface IKafkaConfigurationTask
java.rmi.RemoteException