@Test public void testGetKettleProperties() throws Exception { String encryptedResponse = "3c3f786d6c2076657273696f6e3d22312e302220656e636f64696e6" + "73d225554462d38223f3e0a3c21444f43545950452070726f706572" + "746965730a202053595354454d2022687474703a2f2f6a6176612e737" + "56e2e636f6d2f6474642f70726f706572746965732e647464223e0a3c" + "70726f706572746965733e0a2020203c636f6d6d656e743e3c2f636f6d6d6" + "56e743e0a2020203c656e747279206b65793d224167696c6542494461746162" + "617365223e4167696c6542493c2f656e7470c7a6a5f445d7808bbb1cbc64d797bc84"; doReturn( encryptedResponse ) .when( slaveServer ).execService( GetPropertiesServlet.CONTEXT_PATH + "/?xml=Y" ); slaveServer.getKettleProperties().getProperty( "AgileBIDatabase" ); assertEquals( "AgileBI", slaveServer.getKettleProperties().getProperty( "AgileBIDatabase" ) ); }
public Properties getKettleProperties() throws Exception { String xml = execService( GetPropertiesServlet.CONTEXT_PATH + "/?xml=Y" ); String decryptedXml = Encr.decryptPassword( xml ); InputStream in = new ByteArrayInputStream( decryptedXml.getBytes() ); Properties properties = new Properties(); properties.loadFromXML( in ); return properties; }
SlaveServer extends ChangedFlag implements Cloneable, SharedObjectInterface, VariableSpace,
  RepositoryElementInterface, XMLInterface { public Properties getKettleProperties() throws Exception { String xml = execService( GetPropertiesServlet.CONTEXT_PATH + "/?xml=Y" ); String decryptedXml = Encr.decryptPassword( xml ); InputStream in = new ByteArrayInputStream( decryptedXml.getBytes() ); Properties properties = new Properties(); properties.loadFromXML( in ); return properties; } }
SlaveServer extends ChangedFlag implements Cloneable, SharedObjectInterface, VariableSpace,
  RepositoryElementInterface, XMLInterface { public Properties getKettleProperties() throws Exception { String xml = execService( GetPropertiesServlet.CONTEXT_PATH + "/?xml=Y" ); String decryptedXml = Encr.decryptPassword( xml ); InputStream in = new ByteArrayInputStream( decryptedXml.getBytes() ); Properties properties = new Properties(); properties.loadFromXML( in ); return properties; } SlaveServer();  SlaveServer( String name, String hostname, String port, String username, String password );  SlaveServer( String name, String hostname, String port, String username, String password,
                      String proxyHostname, String proxyPort, String nonProxyHosts, boolean master );  SlaveServer( String name, String hostname, String port, String username, String password,
                      String proxyHostname, String proxyPort, String nonProxyHosts, boolean master, boolean ssl );  SlaveServer( Node slaveNode ); }
SlaveServer extends ChangedFlag implements Cloneable, SharedObjectInterface, VariableSpace,
  RepositoryElementInterface, XMLInterface { public Properties getKettleProperties() throws Exception { String xml = execService( GetPropertiesServlet.CONTEXT_PATH + "/?xml=Y" ); String decryptedXml = Encr.decryptPassword( xml ); InputStream in = new ByteArrayInputStream( decryptedXml.getBytes() ); Properties properties = new Properties(); properties.loadFromXML( in ); return properties; } SlaveServer();  SlaveServer( String name, String hostname, String port, String username, String password );  SlaveServer( String name, String hostname, String port, String username, String password,
                      String proxyHostname, String proxyPort, String nonProxyHosts, boolean master );  SlaveServer( String name, String hostname, String port, String username, String password,
                      String proxyHostname, String proxyPort, String nonProxyHosts, boolean master, boolean ssl );  SlaveServer( Node slaveNode ); static int getBackoffIncrements(); LogChannelInterface getLogChannel(); String getXML(); Object clone(); void replaceMeta( SlaveServer slaveServer ); String toString(); String getServerAndPort(); boolean equals( Object obj ); int hashCode(); String getHostname(); void setHostname( String urlString ); String getPassword(); void setPassword( String password ); String getUsername(); void setUsername( String username ); String getWebAppName(); void setWebAppName( String webAppName ); String getNonProxyHosts(); void setNonProxyHosts( String nonProxyHosts ); String getProxyHostname(); void setProxyHostname( String proxyHostname ); String getProxyPort(); void setProxyPort( String proxyPort ); String getPropertiesMasterName(); boolean isOverrideExistingProperties(); String getPort(); void setPort( String port ); String getPortSpecification(); String constructUrl( String serviceAndArguments ); String sendXML( String xml, String service ); String sendExport( String filename, String type, String load ); void addCredentials( HttpRequestBase method ); boolean isMaster(); void setMaster( boolean master ); String execService( String service, boolean retry ); static long getDelay( int trial ); String execService( String service ); String execService( String service, Map<String, String> headerValues ); SlaveServerStatus getStatus(); List<SlaveServerDetection> getSlaveServerDetections(); SlaveServerTransStatus getTransStatus( String transName, String carteObjectId, int startLogLineNr ); SlaveServerJobStatus getJobStatus( String jobName, String carteObjectId, int startLogLineNr ); WebResult stopTransformation( String transName, String carteObjectId ); WebResult pauseResumeTransformation( String transName, String carteObjectId ); WebResult removeTransformation( String transName, String carteObjectId ); WebResult removeJob( String jobName, String carteObjectId ); WebResult stopJob( String transName, String carteObjectId ); WebResult startTransformation( String transName, String carteObjectId ); WebResult startJob( String jobName, String carteObjectId ); WebResult cleanupTransformation( String transName, String carteObjectId ); WebResult deAllocateServerSockets( String transName, String clusteredRunId ); Properties getKettleProperties(); static SlaveServer findSlaveServer( List<SlaveServer> slaveServers, String name ); static SlaveServer findSlaveServer( List<SlaveServer> slaveServers, ObjectId id ); static String[] getSlaveServerNames( List<SlaveServer> slaveServers ); int allocateServerSocket( String runId, int portRangeStart, String hostname,
                                   String transformationName, String sourceSlaveName,
                                   String sourceStepName, String sourceStepCopy,
                                   String targetSlaveName, String targetStepName, String targetStepCopy ); String getName(); void setName( String name ); boolean isShared(); void setShared( boolean shared ); void copyVariablesFrom( VariableSpace space ); String environmentSubstitute( String aString ); String[] environmentSubstitute( String[] aString ); String fieldSubstitute( String aString, RowMetaInterface rowMeta, Object[] rowData ); VariableSpace getParentVariableSpace(); void setParentVariableSpace( VariableSpace parent ); String getVariable( String variableName, String defaultValue ); String getVariable( String variableName ); boolean getBooleanValueOfVariable( String variableName, boolean defaultValue ); void initializeVariablesFrom( VariableSpace parent ); String[] listVariables(); void setVariable( String variableName, String variableValue ); void shareVariablesWith( VariableSpace space ); void injectVariables( Map<String, String> prop ); ObjectId getObjectId(); void setObjectId( ObjectId id ); RepositoryDirectoryInterface getRepositoryDirectory(); void setRepositoryDirectory( RepositoryDirectoryInterface repositoryDirectory ); RepositoryObjectType getRepositoryElementType(); ObjectRevision getObjectRevision(); void setObjectRevision( ObjectRevision objectRevision ); String getDescription(); void setDescription( String description ); String verifyAndModifySlaveServerName( List<SlaveServer> slaveServers, String oldname ); String sniffStep( String transName, String stepName, String copyNr, int lines, String type ); long getNextSlaveSequenceValue( String slaveSequenceName, long incrementValue ); SlaveServer getClient(); Date getChangedDate(); void setSslMode( boolean sslMode ); boolean isSslMode(); SslConfiguration getSslConfig(); }
SlaveServer extends ChangedFlag implements Cloneable, SharedObjectInterface, VariableSpace,
  RepositoryElementInterface, XMLInterface { public Properties getKettleProperties() throws Exception { String xml = execService( GetPropertiesServlet.CONTEXT_PATH + "/?xml=Y" ); String decryptedXml = Encr.decryptPassword( xml ); InputStream in = new ByteArrayInputStream( decryptedXml.getBytes() ); Properties properties = new Properties(); properties.loadFromXML( in ); return properties; } SlaveServer();  SlaveServer( String name, String hostname, String port, String username, String password );  SlaveServer( String name, String hostname, String port, String username, String password,
                      String proxyHostname, String proxyPort, String nonProxyHosts, boolean master );  SlaveServer( String name, String hostname, String port, String username, String password,
                      String proxyHostname, String proxyPort, String nonProxyHosts, boolean master, boolean ssl );  SlaveServer( Node slaveNode ); static int getBackoffIncrements(); LogChannelInterface getLogChannel(); String getXML(); Object clone(); void replaceMeta( SlaveServer slaveServer ); String toString(); String getServerAndPort(); boolean equals( Object obj ); int hashCode(); String getHostname(); void setHostname( String urlString ); String getPassword(); void setPassword( String password ); String getUsername(); void setUsername( String username ); String getWebAppName(); void setWebAppName( String webAppName ); String getNonProxyHosts(); void setNonProxyHosts( String nonProxyHosts ); String getProxyHostname(); void setProxyHostname( String proxyHostname ); String getProxyPort(); void setProxyPort( String proxyPort ); String getPropertiesMasterName(); boolean isOverrideExistingProperties(); String getPort(); void setPort( String port ); String getPortSpecification(); String constructUrl( String serviceAndArguments ); String sendXML( String xml, String service ); String sendExport( String filename, String type, String load ); void addCredentials( HttpRequestBase method ); boolean isMaster(); void setMaster( boolean master ); String execService( String service, boolean retry ); static long getDelay( int trial ); String execService( String service ); String execService( String service, Map<String, String> headerValues ); SlaveServerStatus getStatus(); List<SlaveServerDetection> getSlaveServerDetections(); SlaveServerTransStatus getTransStatus( String transName, String carteObjectId, int startLogLineNr ); SlaveServerJobStatus getJobStatus( String jobName, String carteObjectId, int startLogLineNr ); WebResult stopTransformation( String transName, String carteObjectId ); WebResult pauseResumeTransformation( String transName, String carteObjectId ); WebResult removeTransformation( String transName, String carteObjectId ); WebResult removeJob( String jobName, String carteObjectId ); WebResult stopJob( String transName, String carteObjectId ); WebResult startTransformation( String transName, String carteObjectId ); WebResult startJob( String jobName, String carteObjectId ); WebResult cleanupTransformation( String transName, String carteObjectId ); WebResult deAllocateServerSockets( String transName, String clusteredRunId ); Properties getKettleProperties(); static SlaveServer findSlaveServer( List<SlaveServer> slaveServers, String name ); static SlaveServer findSlaveServer( List<SlaveServer> slaveServers, ObjectId id ); static String[] getSlaveServerNames( List<SlaveServer> slaveServers ); int allocateServerSocket( String runId, int portRangeStart, String hostname,
                                   String transformationName, String sourceSlaveName,
                                   String sourceStepName, String sourceStepCopy,
                                   String targetSlaveName, String targetStepName, String targetStepCopy ); String getName(); void setName( String name ); boolean isShared(); void setShared( boolean shared ); void copyVariablesFrom( VariableSpace space ); String environmentSubstitute( String aString ); String[] environmentSubstitute( String[] aString ); String fieldSubstitute( String aString, RowMetaInterface rowMeta, Object[] rowData ); VariableSpace getParentVariableSpace(); void setParentVariableSpace( VariableSpace parent ); String getVariable( String variableName, String defaultValue ); String getVariable( String variableName ); boolean getBooleanValueOfVariable( String variableName, boolean defaultValue ); void initializeVariablesFrom( VariableSpace parent ); String[] listVariables(); void setVariable( String variableName, String variableValue ); void shareVariablesWith( VariableSpace space ); void injectVariables( Map<String, String> prop ); ObjectId getObjectId(); void setObjectId( ObjectId id ); RepositoryDirectoryInterface getRepositoryDirectory(); void setRepositoryDirectory( RepositoryDirectoryInterface repositoryDirectory ); RepositoryObjectType getRepositoryElementType(); ObjectRevision getObjectRevision(); void setObjectRevision( ObjectRevision objectRevision ); String getDescription(); void setDescription( String description ); String verifyAndModifySlaveServerName( List<SlaveServer> slaveServers, String oldname ); String sniffStep( String transName, String stepName, String copyNr, int lines, String type ); long getNextSlaveSequenceValue( String slaveSequenceName, long incrementValue ); SlaveServer getClient(); Date getChangedDate(); void setSslMode( boolean sslMode ); boolean isSslMode(); SslConfiguration getSslConfig(); static final String STRING_SLAVESERVER; static final String XML_TAG; static final RepositoryObjectType REPOSITORY_ELEMENT_TYPE; static final String SSL_MODE_TAG; static final int KETTLE_CARTE_RETRIES; static final int KETTLE_CARTE_RETRY_BACKOFF_INCREMENTS; }