public class WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO extends org.apache.nifi.web.dao.impl.ComponentDAO implements org.apache.nifi.web.dao.RemoteProcessGroupDAO
{
private org.apache.nifi.controller.FlowController flowController;
private org.apache.nifi.web.dao.ComponentStateDAO componentStateDAO;
public void <init>()
{
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
specialinvoke v.<org.apache.nifi.web.dao.impl.ComponentDAO: void <init>()>();
return;
}
private org.apache.nifi.groups.RemoteProcessGroup locateRemoteProcessGroup(java.lang.String)
{
java.lang.Object[] v;
org.apache.nifi.groups.ProcessGroup v;
org.apache.nifi.controller.FlowController v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
org.apache.nifi.groups.RemoteProcessGroup v;
org.apache.nifi.web.ResourceNotFoundException v;
java.lang.String v, v;
org.apache.nifi.controller.flow.FlowManager v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: java.lang.String;
v = v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.controller.FlowController flowController>;
v = virtualinvoke v.<org.apache.nifi.controller.FlowController: org.apache.nifi.controller.flow.FlowManager getFlowManager()>();
v = interfaceinvoke v.<org.apache.nifi.controller.flow.FlowManager: org.apache.nifi.groups.ProcessGroup getRootGroup()>();
v = interfaceinvoke v.<org.apache.nifi.groups.ProcessGroup: org.apache.nifi.groups.RemoteProcessGroup findRemoteProcessGroup(java.lang.String)>(v);
if v != null goto label;
v = new org.apache.nifi.web.ResourceNotFoundException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Unable to find remote process group with id \'%s\'.", v);
specialinvoke v.<org.apache.nifi.web.ResourceNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public boolean hasRemoteProcessGroup(java.lang.String)
{
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
org.apache.nifi.groups.ProcessGroup v;
org.apache.nifi.groups.RemoteProcessGroup v;
java.lang.String v;
org.apache.nifi.controller.flow.FlowManager v;
org.apache.nifi.controller.FlowController v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: java.lang.String;
v = v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.controller.FlowController flowController>;
v = virtualinvoke v.<org.apache.nifi.controller.FlowController: org.apache.nifi.controller.flow.FlowManager getFlowManager()>();
v = interfaceinvoke v.<org.apache.nifi.controller.flow.FlowManager: org.apache.nifi.groups.ProcessGroup getRootGroup()>();
v = interfaceinvoke v.<org.apache.nifi.groups.ProcessGroup: org.apache.nifi.groups.RemoteProcessGroup findRemoteProcessGroup(java.lang.String)>(v);
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public org.apache.nifi.groups.RemoteProcessGroup createRemoteProcessGroup(java.lang.String, org.apache.nifi.web.api.dto.RemoteProcessGroupDTO)
{
org.apache.nifi.web.api.dto.RemoteProcessGroupDTO v;
org.apache.nifi.groups.ProcessGroup v;
int v;
java.lang.String v, v, v, v, v;
org.apache.nifi.controller.flow.FlowManager v, v;
boolean v;
java.lang.IllegalArgumentException v, v;
org.apache.nifi.controller.FlowController v, v, v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
org.apache.nifi.groups.RemoteProcessGroup v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.web.api.dto.RemoteProcessGroupDTO;
v = v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.controller.FlowController flowController>;
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.groups.ProcessGroup locateProcessGroup(org.apache.nifi.controller.FlowController,java.lang.String)>(v, v);
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getParentGroupId()>();
if v == null goto label;
v = v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.controller.FlowController flowController>;
v = virtualinvoke v.<org.apache.nifi.controller.FlowController: org.apache.nifi.controller.flow.FlowManager getFlowManager()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getParentGroupId()>();
v = interfaceinvoke v.<org.apache.nifi.controller.flow.FlowManager: boolean areGroupsSame(java.lang.String,java.lang.String)>(v, v);
if v != 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Cannot specify a different Parent Group ID than the Group to which the Remote Process Group is being added.");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getTargetUris()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.String: int length()>();
if v != 0 goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Cannot add a Remote Process Group without specifying the Target URI(s)");
throw v;
label:
v = v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.controller.FlowController flowController>;
v = virtualinvoke v.<org.apache.nifi.controller.FlowController: org.apache.nifi.controller.flow.FlowManager getFlowManager()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getId()>();
v = interfaceinvoke v.<org.apache.nifi.controller.flow.FlowManager: org.apache.nifi.groups.RemoteProcessGroup createRemoteProcessGroup(java.lang.String,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void initialize()>();
specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.groups.RemoteProcessGroup updateRemoteProcessGroup(org.apache.nifi.groups.RemoteProcessGroup,org.apache.nifi.web.api.dto.RemoteProcessGroupDTO)>(v, v);
interfaceinvoke v.<org.apache.nifi.groups.ProcessGroup: void addRemoteProcessGroup(org.apache.nifi.groups.RemoteProcessGroup)>(v);
return v;
}
public org.apache.nifi.groups.RemoteProcessGroup getRemoteProcessGroup(java.lang.String)
{
org.apache.nifi.groups.RemoteProcessGroup v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
java.lang.String v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: java.lang.String;
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.groups.RemoteProcessGroup locateRemoteProcessGroup(java.lang.String)>(v);
return v;
}
public java.util.Set getRemoteProcessGroups(java.lang.String)
{
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
org.apache.nifi.groups.ProcessGroup v;
java.util.Set v;
java.lang.String v;
org.apache.nifi.controller.FlowController v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: java.lang.String;
v = v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.controller.FlowController flowController>;
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.groups.ProcessGroup locateProcessGroup(org.apache.nifi.controller.FlowController,java.lang.String)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.groups.ProcessGroup: java.util.Set getRemoteProcessGroups()>();
return v;
}
public void verifyUpdate(org.apache.nifi.web.api.dto.RemoteProcessGroupDTO)
{
org.apache.nifi.web.api.dto.RemoteProcessGroupDTO v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
org.apache.nifi.groups.RemoteProcessGroup v;
java.lang.String v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: org.apache.nifi.web.api.dto.RemoteProcessGroupDTO;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getId()>();
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.groups.RemoteProcessGroup locateRemoteProcessGroup(java.lang.String)>(v);
specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: void verifyUpdate(org.apache.nifi.groups.RemoteProcessGroup,org.apache.nifi.web.api.dto.RemoteProcessGroupDTO)>(v, v);
return;
}
private void verifyUpdate(org.apache.nifi.groups.RemoteProcessGroup, org.apache.nifi.web.api.dto.RemoteProcessGroupDTO)
{
org.apache.nifi.web.api.dto.RemoteProcessGroupDTO v;
java.lang.Integer v;
java.lang.Boolean v, v, v;
java.lang.String v, v, v, v, v, v;
boolean v, v, v, v, v, v, v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
java.util.List v;
org.apache.nifi.groups.RemoteProcessGroup v;
java.io.Serializable[] v;
org.apache.nifi.controller.exception.ValidationException v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: org.apache.nifi.groups.RemoteProcessGroup;
v := @parameter: org.apache.nifi.web.api.dto.RemoteProcessGroupDTO;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.Boolean isTransmitting()>();
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: boolean isTransmitting()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.Boolean isTransmitting()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void verifyCanStartTransmitting()>();
goto label;
label:
v = interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: boolean isTransmitting()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.Boolean isTransmitting()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v != 0 goto label;
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void verifyCanStopTransmitting()>();
label:
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: java.util.List validateProposedRemoteProcessGroupConfiguration(org.apache.nifi.web.api.dto.RemoteProcessGroupDTO)>(v);
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
v = new org.apache.nifi.controller.exception.ValidationException;
specialinvoke v.<org.apache.nifi.controller.exception.ValidationException: void <init>(java.util.List)>(v);
throw v;
label:
v = newarray (java.io.Serializable)[7];
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getYieldDuration()>();
v[0] = v;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getLocalNetworkInterface()>();
v[1] = v;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getCommunicationsTimeout()>();
v[2] = v;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getProxyHost()>();
v[3] = v;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.Integer getProxyPort()>();
v[4] = v;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getProxyUser()>();
v[5] = v;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getProxyPassword()>();
v[6] = v;
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isAnyNotNull(java.lang.Object[])>(v);
if v == 0 goto label;
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void verifyCanUpdate()>();
label:
return;
}
public void verifyUpdateInputPort(java.lang.String, org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO)
{
java.lang.Object[] v;
org.apache.nifi.remote.RemoteGroupPort v;
org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
org.apache.nifi.groups.RemoteProcessGroup v;
org.apache.nifi.web.ResourceNotFoundException v;
java.lang.String v, v, v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO;
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.groups.RemoteProcessGroup locateRemoteProcessGroup(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.String getId()>();
v = interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: org.apache.nifi.remote.RemoteGroupPort getInputPort(java.lang.String)>(v);
if v != null goto label;
v = new org.apache.nifi.web.ResourceNotFoundException;
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.String getId()>();
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Unable to find remote process group input port with id \'%s\'.", v);
specialinvoke v.<org.apache.nifi.web.ResourceNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: void verifyUpdatePort(org.apache.nifi.remote.RemoteGroupPort,org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO)>(v, v);
return;
}
public void verifyUpdateOutputPort(java.lang.String, org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO)
{
java.lang.Object[] v;
org.apache.nifi.remote.RemoteGroupPort v;
org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
org.apache.nifi.groups.RemoteProcessGroup v;
org.apache.nifi.web.ResourceNotFoundException v;
java.lang.String v, v, v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO;
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.groups.RemoteProcessGroup locateRemoteProcessGroup(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.String getId()>();
v = interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: org.apache.nifi.remote.RemoteGroupPort getOutputPort(java.lang.String)>(v);
if v != null goto label;
v = new org.apache.nifi.web.ResourceNotFoundException;
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.String getId()>();
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Unable to find remote process group output port with id \'%s\'.", v);
specialinvoke v.<org.apache.nifi.web.ResourceNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: void verifyUpdatePort(org.apache.nifi.remote.RemoteGroupPort,org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO)>(v, v);
return;
}
private void verifyUpdatePort(org.apache.nifi.remote.RemoteGroupPort, org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO)
{
java.lang.Object[] v;
java.lang.Integer v;
java.lang.Boolean v, v, v, v;
boolean v, v, v, v, v, v, v;
org.apache.nifi.remote.RemoteGroupPort v;
org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
java.util.List v;
org.apache.nifi.web.api.dto.BatchSettingsDTO v;
org.apache.nifi.controller.exception.ValidationException v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: org.apache.nifi.remote.RemoteGroupPort;
v := @parameter: org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.Boolean isTransmitting()>();
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.remote.RemoteGroupPort: boolean isRunning()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.Boolean isTransmitting()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.nifi.remote.RemoteGroupPort: void verifyCanStart()>();
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.remote.RemoteGroupPort: boolean isRunning()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.Boolean isTransmitting()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v != 0 goto label;
virtualinvoke v.<org.apache.nifi.remote.RemoteGroupPort: void verifyCanStop()>();
label:
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: java.util.List validateProposedRemoteProcessGroupPortConfiguration(org.apache.nifi.remote.RemoteGroupPort,org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO)>(v, v);
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
v = new org.apache.nifi.controller.exception.ValidationException;
specialinvoke v.<org.apache.nifi.controller.exception.ValidationException: void <init>(java.util.List)>(v);
throw v;
label:
v = newarray (java.lang.Object)[3];
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.Integer getConcurrentlySchedulableTaskCount()>();
v[0] = v;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.Boolean getUseCompression()>();
v[1] = v;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: org.apache.nifi.web.api.dto.BatchSettingsDTO getBatchSettings()>();
v[2] = v;
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isAnyNotNull(java.lang.Object[])>(v);
if v == 0 goto label;
virtualinvoke v.<org.apache.nifi.remote.RemoteGroupPort: void verifyCanUpdate()>();
label:
return;
}
private java.util.List validateProposedRemoteProcessGroupPortConfiguration(org.apache.nifi.remote.RemoteGroupPort, org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO)
{
java.lang.Integer v, v, v;
java.util.regex.Matcher v, v;
boolean v, v, v, v, v, v;
org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO v;
java.util.regex.Pattern v, v;
java.lang.Object[] v, v, v, v;
java.util.ArrayList v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.remote.RemoteGroupPort v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
org.apache.nifi.web.api.dto.BatchSettingsDTO v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: org.apache.nifi.remote.RemoteGroupPort;
v := @parameter: org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.Integer getConcurrentlySchedulableTaskCount()>();
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.Integer getConcurrentlySchedulableTaskCount()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v > 0 goto label;
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.nifi.remote.RemoteGroupPort: java.lang.String getName()>();
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Concurrent tasks for port \'%s\' must be a positive integer.", v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: org.apache.nifi.web.api.dto.BatchSettingsDTO getBatchSettings()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BatchSettingsDTO: java.lang.Integer getCount()>();
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v >= 0 goto label;
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.nifi.remote.RemoteGroupPort: java.lang.String getName()>();
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Batch count for port \'%s\' must be a positive integer.", v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BatchSettingsDTO: java.lang.String getSize()>();
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: int length()>();
if v <= 0 goto label;
v = <org.apache.nifi.processor.DataUnit: java.util.regex.Pattern DATA_SIZE_PATTERN>;
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = virtualinvoke v.<java.lang.String: java.lang.String toUpperCase()>();
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
if v != 0 goto label;
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.nifi.remote.RemoteGroupPort: java.lang.String getName()>();
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Batch size for port \'%s\' must be of format <Data Size> <Data Unit> where <Data Size> is a non-negative integer and <Data Unit> is a supported Data Unit, such as: B, KB, MB, GB, TB", v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BatchSettingsDTO: java.lang.String getDuration()>();
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: int length()>();
if v <= 0 goto label;
v = <org.apache.nifi.util.FormatUtils: java.util.regex.Pattern TIME_DURATION_PATTERN>;
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
if v != 0 goto label;
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.nifi.remote.RemoteGroupPort: java.lang.String getName()>();
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Batch duration for port \'%s\' must be of format <duration> <TimeUnit> where <duration> is a non-negative integer and TimeUnit is a supported Time Unit, such as: nanos, millis, secs, mins, hrs, days", v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return v;
}
private java.util.List validateProposedRemoteProcessGroupConfiguration(org.apache.nifi.web.api.dto.RemoteProcessGroupDTO)
{
org.apache.nifi.web.api.dto.RemoteProcessGroupDTO v;
java.lang.Integer v;
java.util.ArrayList v;
java.util.regex.Matcher v, v;
java.lang.String v, v, v, v, v, v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
java.util.regex.Pattern v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: org.apache.nifi.web.api.dto.RemoteProcessGroupDTO;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getCommunicationsTimeout()>();
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
v = <org.apache.nifi.util.FormatUtils: java.util.regex.Pattern TIME_DURATION_PATTERN>;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getCommunicationsTimeout()>();
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
if v != 0 goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("Communications timeout is not a valid time duration (ie 30 sec, 5 min)");
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getYieldDuration()>();
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
v = <org.apache.nifi.util.FormatUtils: java.util.regex.Pattern TIME_DURATION_PATTERN>;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getYieldDuration()>();
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
if v != 0 goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("Yield duration is not a valid time duration (ie 30 sec, 5 min)");
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getProxyPassword()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getProxyUser()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getProxyHost()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.Integer getProxyPort()>();
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
v = staticinvoke <org.apache.nifi.util.StringUtils: boolean isEmpty(java.lang.String)>(v);
if v == 0 goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("Proxy port was specified, but proxy host was empty.");
label:
v = staticinvoke <org.apache.nifi.util.StringUtils: boolean isEmpty(java.lang.String)>(v);
if v != 0 goto label;
v = staticinvoke <org.apache.nifi.util.StringUtils: boolean isEmpty(java.lang.String)>(v);
if v == 0 goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("Proxy user name was specified, but proxy host was empty.");
label:
v = staticinvoke <org.apache.nifi.util.StringUtils: boolean isEmpty(java.lang.String)>(v);
if v == 0 goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("User password should be specified if Proxy server needs user authentication.");
label:
v = staticinvoke <org.apache.nifi.util.StringUtils: boolean isEmpty(java.lang.String)>(v);
if v != 0 goto label;
v = staticinvoke <org.apache.nifi.util.StringUtils: boolean isEmpty(java.lang.String)>(v);
if v == 0 goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("Proxy user password was specified, but proxy host was empty.");
label:
v = staticinvoke <org.apache.nifi.util.StringUtils: boolean isEmpty(java.lang.String)>(v);
if v == 0 goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("User name should be specified if Proxy server needs user authentication.");
label:
return v;
}
public org.apache.nifi.remote.RemoteGroupPort updateRemoteProcessGroupInputPort(java.lang.String, org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO)
{
java.lang.Object[] v;
org.apache.nifi.groups.ProcessGroup v;
org.apache.nifi.remote.RemoteGroupPort v;
org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
org.apache.nifi.groups.RemoteProcessGroup v;
org.apache.nifi.web.ResourceNotFoundException v;
java.lang.String v, v, v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO;
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.groups.RemoteProcessGroup locateRemoteProcessGroup(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.String getId()>();
v = interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: org.apache.nifi.remote.RemoteGroupPort getInputPort(java.lang.String)>(v);
if v != null goto label;
v = new org.apache.nifi.web.ResourceNotFoundException;
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.String getId()>();
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Unable to find remote process group input port with id \'%s\'.", v);
specialinvoke v.<org.apache.nifi.web.ResourceNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: void verifyUpdatePort(org.apache.nifi.remote.RemoteGroupPort,org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO)>(v, v);
specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: void updatePort(org.apache.nifi.remote.RemoteGroupPort,org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO,org.apache.nifi.groups.RemoteProcessGroup)>(v, v, v);
v = interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: org.apache.nifi.groups.ProcessGroup getProcessGroup()>();
interfaceinvoke v.<org.apache.nifi.groups.ProcessGroup: void onComponentModified()>();
return v;
}
public org.apache.nifi.remote.RemoteGroupPort updateRemoteProcessGroupOutputPort(java.lang.String, org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO)
{
java.lang.Object[] v;
org.apache.nifi.groups.ProcessGroup v;
org.apache.nifi.remote.RemoteGroupPort v;
org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
org.apache.nifi.groups.RemoteProcessGroup v;
org.apache.nifi.web.ResourceNotFoundException v;
java.lang.String v, v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO;
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.groups.RemoteProcessGroup locateRemoteProcessGroup(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.String getId()>();
v = interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: org.apache.nifi.remote.RemoteGroupPort getOutputPort(java.lang.String)>(v);
if v != null goto label;
v = new org.apache.nifi.web.ResourceNotFoundException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Unable to find remote process group output port with id \'%s\'.", v);
specialinvoke v.<org.apache.nifi.web.ResourceNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: void verifyUpdatePort(org.apache.nifi.remote.RemoteGroupPort,org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO)>(v, v);
specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: void updatePort(org.apache.nifi.remote.RemoteGroupPort,org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO,org.apache.nifi.groups.RemoteProcessGroup)>(v, v, v);
v = interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: org.apache.nifi.groups.ProcessGroup getProcessGroup()>();
interfaceinvoke v.<org.apache.nifi.groups.ProcessGroup: void onComponentModified()>();
return v;
}
private void updatePort(org.apache.nifi.remote.RemoteGroupPort, org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO, org.apache.nifi.groups.RemoteProcessGroup)
{
java.lang.Integer v, v, v;
int v;
java.lang.Boolean v, v, v;
java.lang.String v, v;
boolean v, v, v, v, v, v, v, v, v;
org.apache.nifi.remote.RemoteGroupPort v;
org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
org.apache.nifi.web.api.dto.BatchSettingsDTO v;
org.apache.nifi.groups.RemoteProcessGroup v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: org.apache.nifi.remote.RemoteGroupPort;
v := @parameter: org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO;
v := @parameter: org.apache.nifi.groups.RemoteProcessGroup;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.Integer getConcurrentlySchedulableTaskCount()>();
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.Integer getConcurrentlySchedulableTaskCount()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<org.apache.nifi.remote.RemoteGroupPort: void setMaxConcurrentTasks(int)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.Boolean getUseCompression()>();
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.Boolean getUseCompression()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<org.apache.nifi.remote.RemoteGroupPort: void setUseCompression(boolean)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: org.apache.nifi.web.api.dto.BatchSettingsDTO getBatchSettings()>();
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BatchSettingsDTO: java.lang.Integer getCount()>();
virtualinvoke v.<org.apache.nifi.remote.RemoteGroupPort: void setBatchCount(java.lang.Integer)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BatchSettingsDTO: java.lang.String getSize()>();
virtualinvoke v.<org.apache.nifi.remote.RemoteGroupPort: void setBatchSize(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BatchSettingsDTO: java.lang.String getDuration()>();
virtualinvoke v.<org.apache.nifi.remote.RemoteGroupPort: void setBatchDuration(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO: java.lang.Boolean isTransmitting()>();
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.remote.RemoteGroupPort: boolean isRunning()>();
if v != 0 goto label;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void startTransmitting(org.apache.nifi.remote.RemoteGroupPort)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.remote.RemoteGroupPort: boolean isRunning()>();
if v == 0 goto label;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v != 0 goto label;
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void stopTransmitting(org.apache.nifi.remote.RemoteGroupPort)>(v);
label:
return;
}
public org.apache.nifi.groups.RemoteProcessGroup updateRemoteProcessGroup(org.apache.nifi.web.api.dto.RemoteProcessGroupDTO)
{
org.apache.nifi.web.api.dto.RemoteProcessGroupDTO v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
org.apache.nifi.groups.RemoteProcessGroup v, v;
java.lang.String v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: org.apache.nifi.web.api.dto.RemoteProcessGroupDTO;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getId()>();
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.groups.RemoteProcessGroup locateRemoteProcessGroup(java.lang.String)>(v);
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.groups.RemoteProcessGroup updateRemoteProcessGroup(org.apache.nifi.groups.RemoteProcessGroup,org.apache.nifi.web.api.dto.RemoteProcessGroupDTO)>(v, v);
return v;
}
private org.apache.nifi.groups.RemoteProcessGroup updateRemoteProcessGroup(org.apache.nifi.groups.RemoteProcessGroup, org.apache.nifi.web.api.dto.RemoteProcessGroupDTO)
{
org.apache.nifi.groups.ProcessGroup v;
java.lang.Integer v;
org.apache.nifi.web.api.dto.PositionDTO v, v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.connectable.Position v;
org.apache.nifi.groups.RemoteProcessGroup v;
org.apache.nifi.web.api.dto.RemoteProcessGroupDTO v;
java.lang.Double v, v;
org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol v;
java.lang.Boolean v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
double v, v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: org.apache.nifi.groups.RemoteProcessGroup;
v := @parameter: org.apache.nifi.web.api.dto.RemoteProcessGroupDTO;
specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: void verifyUpdate(org.apache.nifi.groups.RemoteProcessGroup,org.apache.nifi.web.api.dto.RemoteProcessGroupDTO)>(v, v);
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getTargetUris()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getName()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getComments()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getCommunicationsTimeout()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getYieldDuration()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getProxyHost()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.Integer getProxyPort()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getProxyUser()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getProxyPassword()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getTransportProtocol()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.String getLocalNetworkInterface()>();
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void setTargetUris(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void setName(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void setComments(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void setCommunicationsTimeout(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void setYieldDuration(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: org.apache.nifi.web.api.dto.PositionDTO getPosition()>();
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
v = new org.apache.nifi.connectable.Position;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: org.apache.nifi.web.api.dto.PositionDTO getPosition()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.PositionDTO: java.lang.Double getX()>();
v = virtualinvoke v.<java.lang.Double: double doubleValue()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: org.apache.nifi.web.api.dto.PositionDTO getPosition()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.PositionDTO: java.lang.Double getY()>();
v = virtualinvoke v.<java.lang.Double: double doubleValue()>();
specialinvoke v.<org.apache.nifi.connectable.Position: void <init>(double,double)>(v, v);
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void setPosition(org.apache.nifi.connectable.Position)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String toUpperCase()>();
v = staticinvoke <org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol: org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol valueOf(java.lang.String)>(v);
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void setTransportProtocol(org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol)>(v);
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void setProxyHost(java.lang.String)>(v);
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void setProxyPort(java.lang.Integer)>(v);
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void setProxyUser(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
v = "********";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void setProxyPassword(java.lang.String)>(v);
label:
if v == null goto label;
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isBlank(java.lang.CharSequence)>(v);
if v == 0 goto label;
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void setNetworkInterface(java.lang.String)>(null);
goto label;
label:
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void setNetworkInterface(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.RemoteProcessGroupDTO: java.lang.Boolean isTransmitting()>();
v = virtualinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: boolean isNotNull(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: boolean isConfiguredToTransmit()>();
if v != 0 goto label;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void startTransmitting()>();
goto label;
label:
v = interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: boolean isConfiguredToTransmit()>();
if v == 0 goto label;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v != 0 goto label;
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: java.util.concurrent.Future stopTransmitting()>();
label:
v = interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: org.apache.nifi.groups.ProcessGroup getProcessGroup()>();
if v == null goto label;
interfaceinvoke v.<org.apache.nifi.groups.ProcessGroup: void onComponentModified()>();
label:
return v;
}
public void verifyDelete(java.lang.String)
{
org.apache.nifi.groups.RemoteProcessGroup v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
java.lang.String v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: java.lang.String;
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.groups.RemoteProcessGroup locateRemoteProcessGroup(java.lang.String)>(v);
interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: void verifyCanDelete()>();
return;
}
public void deleteRemoteProcessGroup(java.lang.String)
{
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
org.apache.nifi.groups.ProcessGroup v;
org.apache.nifi.groups.RemoteProcessGroup v;
java.lang.String v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: java.lang.String;
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.groups.RemoteProcessGroup locateRemoteProcessGroup(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: org.apache.nifi.groups.ProcessGroup getProcessGroup()>();
interfaceinvoke v.<org.apache.nifi.groups.ProcessGroup: void removeRemoteProcessGroup(org.apache.nifi.groups.RemoteProcessGroup)>(v);
return;
}
public org.apache.nifi.components.state.StateMap getState(java.lang.String, org.apache.nifi.components.state.Scope)
{
org.apache.nifi.web.dao.ComponentStateDAO v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
org.apache.nifi.components.state.Scope v;
org.apache.nifi.groups.RemoteProcessGroup v;
java.lang.String v;
org.apache.nifi.components.state.StateMap v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.components.state.Scope;
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.groups.RemoteProcessGroup locateRemoteProcessGroup(java.lang.String)>(v);
v = v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.web.dao.ComponentStateDAO componentStateDAO>;
v = interfaceinvoke v.<org.apache.nifi.web.dao.ComponentStateDAO: org.apache.nifi.components.state.StateMap getState(org.apache.nifi.groups.RemoteProcessGroup,org.apache.nifi.components.state.Scope)>(v, v);
return v;
}
public void setFlowController(org.apache.nifi.controller.FlowController)
{
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
org.apache.nifi.controller.FlowController v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: org.apache.nifi.controller.FlowController;
v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.controller.FlowController flowController> = v;
return;
}
public void setComponentStateDAO(org.apache.nifi.web.dao.ComponentStateDAO)
{
org.apache.nifi.web.dao.ComponentStateDAO v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO;
v := @parameter: org.apache.nifi.web.dao.ComponentStateDAO;
v.<org.apache.nifi.web.dao.impl.StandardRemoteProcessGroupDAO: org.apache.nifi.web.dao.ComponentStateDAO componentStateDAO> = v;
return;
}
}