How to use CitrusRuntimeException method of com.consol.citrus.ftp.client.SftpClient class

Best Citrus code snippet using com.consol.citrus.ftp.client.SftpClient.CitrusRuntimeException

Source:SftpClient.java

...14 * limitations under the License.15 */16package com.consol.citrus.ftp.client;17import com.consol.citrus.context.TestContext;18import com.consol.citrus.exceptions.CitrusRuntimeException;19import com.consol.citrus.ftp.message.FtpMessage;20import com.consol.citrus.ftp.model.*;21import com.consol.citrus.util.FileUtils;22import com.jcraft.jsch.*;23import org.apache.commons.codec.binary.Base64;24import org.apache.commons.net.ftp.FTPCmd;25import org.apache.commons.net.ftp.FTPReply;26import org.apache.ftpserver.ftplet.DataType;27import org.apache.sshd.client.keyverifier.KnownHostsServerKeyVerifier;28import org.slf4j.Logger;29import org.slf4j.LoggerFactory;30import org.springframework.util.*;31import java.io.*;32import java.nio.file.*;33import java.util.*;34/**35 * @author Christoph Deppisch36 * @since 2.7.537 */38public class SftpClient extends FtpClient {39    /** Logger */40    private static Logger log = LoggerFactory.getLogger(SftpClient.class);41    /** Session for the SSH communication */42    private Session session;43    /** Apache ftp client */44    private JSch ssh;45    private ChannelSftp sftp;46    /**47     * Default constructor initializing endpoint configuration.48     */49    public SftpClient() {50        this(new SftpEndpointConfiguration());51    }52    /**53     * Default constructor using endpoint configuration.54     * @param endpointConfiguration55     */56    protected SftpClient(SftpEndpointConfiguration endpointConfiguration) {57        super(endpointConfiguration);58    }59    @Override60    public SftpEndpointConfiguration getEndpointConfiguration() {61        return (SftpEndpointConfiguration) super.getEndpointConfiguration();62    }63    @Override64    protected FtpMessage executeCommand(CommandType ftpCommand, TestContext context) {65        if (ftpCommand.getSignal().equals(FTPCmd.MKD.getCommand())) {66            return createDir(ftpCommand);67        } else if (ftpCommand.getSignal().equals(FTPCmd.LIST.getCommand())) {68            return listFiles(FtpMessage.list(ftpCommand.getArguments()).getPayload(ListCommand.class), context);69        } else if (ftpCommand.getSignal().equals(FTPCmd.DELE.getCommand())) {70            return deleteFile(FtpMessage.delete(ftpCommand.getArguments()).getPayload(DeleteCommand.class), context);71        } else if (ftpCommand.getSignal().equals(FTPCmd.STOR.getCommand())) {72            return storeFile(FtpMessage.put(ftpCommand.getArguments()).getPayload(PutCommand.class), context);73        } else if (ftpCommand.getSignal().equals(FTPCmd.RETR.getCommand())) {74            return retrieveFile(FtpMessage.get(ftpCommand.getArguments()).getPayload(GetCommand.class), context);75        } else {76            throw new CitrusRuntimeException(String.format("Unsupported ftp command '%s'", ftpCommand.getSignal()));77        }78    }79    /**80     * Execute mkDir command and create new directory.81     * @param ftpCommand82     * @return83     */84    protected FtpMessage createDir(CommandType ftpCommand) {85        try {86            sftp.mkdir(ftpCommand.getArguments());87            return FtpMessage.result(FTPReply.PATHNAME_CREATED, "Pathname created", true);88        } catch (SftpException e) {89            throw new CitrusRuntimeException("Failed to execute ftp command", e);90        }91    }92    @Override93    protected FtpMessage listFiles(ListCommand list, TestContext context) {94        String remoteFilePath = Optional.ofNullable(list.getTarget())95                                        .map(ListCommand.Target::getPath)96                                        .map(context::replaceDynamicContentInString)97                                        .orElse("");98        try {99            List<String> fileNames = new ArrayList<>();100            Vector<ChannelSftp.LsEntry> entries = sftp.ls(remoteFilePath);101            for (ChannelSftp.LsEntry entry : entries) {102                fileNames.add(entry.getFilename());103            }104            return FtpMessage.result(FTPReply.FILE_STATUS_OK, "List files complete", fileNames);105        } catch (SftpException e) {106            throw new CitrusRuntimeException(String.format("Failed to list files in path '%s'", remoteFilePath), e);107        }108    }109    @Override110    protected FtpMessage deleteFile(DeleteCommand delete, TestContext context) {111        String remoteFilePath = context.replaceDynamicContentInString(delete.getTarget().getPath());112        try {113            if (!StringUtils.hasText(remoteFilePath)) {114                return null;115            }116            if (isDirectory(remoteFilePath)) {117                sftp.cd(remoteFilePath);118                if (delete.isRecursive()) {119                    Vector<ChannelSftp.LsEntry> entries = sftp.ls(".");120                    List<String> excludedDirs = Arrays.asList(".", "..");121                    for (ChannelSftp.LsEntry entry : entries) {122                        if (!excludedDirs.contains(entry.getFilename())) {123                            DeleteCommand recursiveDelete = new DeleteCommand();124                            DeleteCommand.Target target = new DeleteCommand.Target();125                            target.setPath(remoteFilePath + "/" + entry.getFilename());126                            recursiveDelete.setTarget(target);127                            recursiveDelete.setIncludeCurrent(true);128                            deleteFile(recursiveDelete, context);129                        }130                    }131                }132                if (delete.isIncludeCurrent()) {133                    // we cannot delete the current working directory, so go to root directory and delete from there134                    sftp.cd("..");135                    sftp.rmdir(remoteFilePath);136                }137            } else {138                sftp.rm(remoteFilePath);139            }140        } catch (SftpException e) {141            throw new CitrusRuntimeException("Failed to delete file from FTP server", e);142        }143        return FtpMessage.deleteResult(FTPReply.FILE_ACTION_OK, "Delete file complete", true);144    }145    @Override146    protected boolean isDirectory(String remoteFilePath) {147        try {148            return !remoteFilePath.contains("*") && sftp.stat(remoteFilePath).isDir();149        } catch (SftpException e) {150            throw new CitrusRuntimeException("Failed to check file state", e);151        }152    }153    @Override154    protected FtpMessage storeFile(PutCommand command, TestContext context) {155        try {156            String localFilePath = context.replaceDynamicContentInString(command.getFile().getPath());157            String remoteFilePath = addFileNameToTargetPath(localFilePath, context.replaceDynamicContentInString(command.getTarget().getPath()));158            String dataType = context.replaceDynamicContentInString(Optional.ofNullable(command.getFile().getType()).orElse(DataType.BINARY.name()));159            try (InputStream localFileInputStream = getLocalFileInputStream(command.getFile().getPath(), dataType, context)) {160                sftp.put(localFileInputStream, remoteFilePath);161            }162        } catch (IOException | SftpException e) {163            throw new CitrusRuntimeException("Failed to put file to FTP server", e);164        }165        return FtpMessage.putResult(FTPReply.CLOSING_DATA_CONNECTION, "Transfer complete", true);166    }167    @Override168    protected FtpMessage retrieveFile(GetCommand command, TestContext context) {169        try {170            String remoteFilePath = context.replaceDynamicContentInString(command.getFile().getPath());171            String localFilePath = addFileNameToTargetPath(remoteFilePath, context.replaceDynamicContentInString(command.getTarget().getPath()));172            try (InputStream inputStream = sftp.get(remoteFilePath)) {173                byte[] bytes = FileCopyUtils.copyToByteArray(inputStream);174                // create intermediate directories if necessary175                Path localFilePathObj = Paths.get(localFilePath);176                Files.createDirectories(localFilePathObj.getParent());177                Files.write(localFilePathObj, bytes);178            } catch (SftpException e) {179                throw new CitrusRuntimeException(String.format("Failed to get file from FTP server. Remote path: %s. Local file path: %s. Error: %s",180                        remoteFilePath, localFilePath, e.getMessage()));181            }182            if (getEndpointConfiguration().isAutoReadFiles()) {183                String fileContent;184                if (command.getFile().getType().equals(DataType.BINARY.name())) {185                    fileContent = Base64.encodeBase64String(FileCopyUtils.copyToByteArray(FileUtils.getFileResource(localFilePath).getInputStream()));186                } else {187                    fileContent = FileUtils.readToString(FileUtils.getFileResource(localFilePath));188                }189                return FtpMessage.result(FTPReply.CLOSING_DATA_CONNECTION, "Transfer complete", localFilePath, fileContent);190            } else {191                return FtpMessage.result(FTPReply.CLOSING_DATA_CONNECTION, "Transfer complete", localFilePath, null);192            }193        } catch (IOException e) {194            throw new CitrusRuntimeException("Failed to get file from FTP server", e);195        }196    }197    @Override198    protected void connectAndLogin() {199        if (getEndpointConfiguration().isStrictHostChecking()) {200            setKnownHosts();201        }202        if (session == null || !session.isConnected()) {203            try {204                if (StringUtils.hasText(getEndpointConfiguration().getPrivateKeyPath())) {205                    ssh.addIdentity(getPrivateKeyPath(), getEndpointConfiguration().getPrivateKeyPassword());206                }207            } catch (JSchException e) {208                throw new CitrusRuntimeException("Cannot add private key " + getEndpointConfiguration().getPrivateKeyPath() + ": " + e,e);209            } catch (IOException e) {210                throw new CitrusRuntimeException("Cannot open private key file " + getEndpointConfiguration().getPrivateKeyPath() + ": " + e,e);211            }212            try {213                session = ssh.getSession(getEndpointConfiguration().getUser(), getEndpointConfiguration().getHost(), getEndpointConfiguration().getPort());214                if (StringUtils.hasText(getEndpointConfiguration().getPassword())) {215                    session.setUserInfo(new UserInfoWithPlainPassword(getEndpointConfiguration().getPassword()));216                    session.setPassword(getEndpointConfiguration().getPassword());217                }218                session.setConfig(KnownHostsServerKeyVerifier.STRICT_CHECKING_OPTION, getEndpointConfiguration().isStrictHostChecking() ? "yes" : "no");219                session.setConfig("PreferredAuthentications", getEndpointConfiguration().getPreferredAuthentications());220                getEndpointConfiguration().getSessionConfigs().entrySet()221                        .stream()222                        .peek(entry -> log.info(String.format("Setting session configuration: %s='%s'", entry.getKey(), entry.getValue())))223                        .forEach(entry -> session.setConfig(entry.getKey(), entry.getValue()));224                session.connect((int) getEndpointConfiguration().getTimeout());225                Channel channel = session.openChannel("sftp");226                channel.connect((int) getEndpointConfiguration().getTimeout());227                sftp = (ChannelSftp) channel;228                log.info("Opened secure connection to FTP server");229            } catch (JSchException e) {230                throw new CitrusRuntimeException(String.format("Failed to login to FTP server using credentials: %s:%s", getEndpointConfiguration().getUser(), getEndpointConfiguration().getPassword()), e);231            }232        }233    }234    private void setKnownHosts() {235        if (getEndpointConfiguration().getKnownHosts() == null) {236            throw new CitrusRuntimeException("Strict host checking is enabled but no knownHosts given");237        }238        try {239            ssh.setKnownHosts(FileUtils.getFileResource(getEndpointConfiguration().getKnownHosts()).getInputStream());240        } catch (JSchException e) {241            throw new CitrusRuntimeException("Cannot add known hosts from " + getEndpointConfiguration().getKnownHosts() + ": " + e,e);242        } catch (IOException e) {243            throw new CitrusRuntimeException("Cannot find known hosts file " + getEndpointConfiguration().getKnownHosts() + ": " + e,e);244        }245    }246    protected String getPrivateKeyPath() throws IOException {247        if (!StringUtils.hasText(getEndpointConfiguration().getPrivateKeyPath())) {248            return null;249        } else if (getEndpointConfiguration().getPrivateKeyPath().startsWith(ResourceUtils.CLASSPATH_URL_PREFIX)) {250            File priv = File.createTempFile("citrus-sftp","priv");251            InputStream is = getClass().getClassLoader().getResourceAsStream(getEndpointConfiguration().getPrivateKeyPath().substring(ResourceUtils.CLASSPATH_URL_PREFIX.length()));252            if (is == null) {253                throw new CitrusRuntimeException("No private key found at " + getEndpointConfiguration().getPrivateKeyPath());254            }255            FileCopyUtils.copy(is, new FileOutputStream(priv));256            return priv.getAbsolutePath();257        } else {258            return getEndpointConfiguration().getPrivateKeyPath();259        }260    }261    private static class UserInfoWithPlainPassword implements UserInfo {262        private String password;263        public UserInfoWithPlainPassword(String pPassword) {264            password = pPassword;265        }266        public String getPassphrase() {267            return null;...

Source:SftpEndpointComponent.java

...16package com.consol.citrus.ftp.client;17import com.consol.citrus.context.TestContext;18import com.consol.citrus.endpoint.AbstractEndpointComponent;19import com.consol.citrus.endpoint.Endpoint;20import com.consol.citrus.exceptions.CitrusRuntimeException;21import java.util.Map;22/**23 * @author Christoph Deppisch24 * @since 2.7.525 */26public class SftpEndpointComponent extends AbstractEndpointComponent {27    @Override28    protected Endpoint createEndpoint(String resourcePath, Map<String, String> parameters, TestContext context) {29        SftpClient ftpClient = new SftpClient();30        ftpClient.getEndpointConfiguration().setHost(getHost(resourcePath));31        ftpClient.getEndpointConfiguration().setPort(getPort(resourcePath, ftpClient.getEndpointConfiguration()));32        enrichEndpointConfiguration(ftpClient.getEndpointConfiguration(),33                getEndpointConfigurationParameters(parameters, FtpEndpointConfiguration.class), context);34        try {35            ftpClient.afterPropertiesSet();36        } catch (Exception e) {37            throw new CitrusRuntimeException("Failed to create dynamic endpoint", e);38        }39        return ftpClient;40    }41    /**42     * Extract port number from resource path. If not present use default port from endpoint configuration.43     * @param resourcePath44     * @param endpointConfiguration45     * @return46     */47    private Integer getPort(String resourcePath, FtpEndpointConfiguration endpointConfiguration) {48        if (resourcePath.contains(":")) {49            return Integer.valueOf(resourcePath.split(":")[1]);50        }51        return endpointConfiguration.getPort();...

CitrusRuntimeException

Using AI Code Generation

1package com.consol.citrus.ftp.client;2import com.consol.citrus.exceptions.CitrusRuntimeException;3import com.consol.citrus.testng.AbstractTestNGUnitTest;4import org.testng.annotations.Test;5import java.io.File;6import static org.testng.Assert.assertEquals;7import static org.testng.Assert.fail;8public class SftpClientTest extends AbstractTestNGUnitTest {9    public void testSftpClient() {10        SftpClient sftpClient = new SftpClient();11        try {12            sftpClient.connect("localhost", 22, "username", "password");13            sftpClient.send(new File("src/test/resources/testdata/test.txt"));14            sftpClient.disconnect();15        } catch (CitrusRuntimeException e) {16            fail("Unable to connect to SFTP server. Please check if SFTP server is running and credentials are correct.");17        }18    }19}

CitrusRuntimeException

Using AI Code Generation

1import com.consol.citrus.ftp.client.SftpClient;2import com.consol.citrus.exceptions.CitrusRuntimeException;3import org.apache.commons.net.ftp.FTPFile;4import org.testng.annotations.Test;5public class 3 {6    public void testSftpClient() {7        SftpClient sftpClient = new SftpClient();8        sftpClient.setHost("localhost");9        sftpClient.setPort(22);10        sftpClient.setUsername("user");11        sftpClient.setPassword("password");12        sftpClient.connect();13        FTPFile[] files = sftpClient.listFiles("/");14        for (FTPFile file : files) {15            System.out.println(file.getName());16        }17        sftpClient.disconnect();18    }19}20	at com.consol.citrus.ftp.client.SftpClient.connect(SftpClient.java:114)21	at 3.testSftpClient(3.java:19)22	at 3.main(3.java:23)23	at com.jcraft.jsch.Session.connect(Session.java:517)24	at com.jcraft.jsch.Session.connect(Session.java:183)25	at com.consol.citrus.ftp.client.SftpClient.connect(SftpClient.java:112)26	at com.consol.citrus.ftp.client.SftpClient.connect(SftpClient.java:114)27	at 3.testSftpClient(3.java:19)28	at 3.main(3.java:23)29	at com.jcraft.jsch.Session.connect(Session.java:517)30	at com.jcraft.jsch.Session.connect(Session.java:183)31	at com.consol.citrus.ftp.client.SftpClient.connect(SftpClient.java:112)32	at com.consol.citrus.ftp.client.SftpClient.connect(SftpClient.java:114)33	at 3.testSftpClient(3.java:19)

CitrusRuntimeException

Using AI Code Generation

1package com.consol.citrus.ftp.client;2import org.testng.Assert;3import org.testng.annotations.Test;4import com.consol.citrus.exceptions.CitrusRuntimeException;5public class CitrusRuntimeExceptionTest {6public void test() {7CitrusRuntimeException citrusRuntimeException = new CitrusRuntimeException("Test");8Assert.assertEquals(citrusRuntimeException.getMessage(), "Test");9}10}11package com.consol.citrus.ftp.client;12import org.testng.Assert;13import org.testng.annotations.Test;14import com.consol.citrus.exceptions.CitrusRuntimeException;15public class CitrusRuntimeExceptionTest {16public void test() {17CitrusRuntimeException citrusRuntimeException = new CitrusRuntimeException("Test");18Assert.assertEquals(citrusRuntimeException.getMessage(), "Test");19}20}21package com.consol.citrus.ftp.client;22import org.testng.Assert;23import org.testng.annotations.Test;24import com.consol.citrus.exceptions.CitrusRuntimeException;25public class CitrusRuntimeExceptionTest {26public void test() {27CitrusRuntimeException citrusRuntimeException = new CitrusRuntimeException("Test");28Assert.assertEquals(citrusRuntimeException.getMessage(), "Test");29}30}31package com.consol.citrus.ftp.client;32import org.testng.Assert;33import org.testng.annotations.Test;34import com.consol.citrus.exceptions.CitrusRuntimeException;35public class CitrusRuntimeExceptionTest {36public void test() {37CitrusRuntimeException citrusRuntimeException = new CitrusRuntimeException("Test");38Assert.assertEquals(citrusRuntimeException.getMessage(), "Test");39}40}41package com.consol.citrus.ftp.client;42import org.testng.Assert;43import org.testng.annotations.Test;44import com.consol.citrus.exceptions.CitrusRuntimeException;45public class CitrusRuntimeExceptionTest {46public void test() {47CitrusRuntimeException citrusRuntimeException = new CitrusRuntimeException("Test");48Assert.assertEquals(citrusRuntimeException.getMessage(), "Test");49}50}

CitrusRuntimeException

Using AI Code Generation

1package com.consol.citrus.ftp.client;2import com.consol.citrus.exceptions.CitrusRuntimeException;3import org.apache.sshd.client.SshClient;4import org.apache.sshd.client.session.ClientSession;5import org.apache.sshd.common.config.keys.FilePasswordProvider;6import org.apache.sshd.common.keyprovider.FileKeyPairProvider;7import org.apache.sshd.common.session.Session;8import org.apache.sshd.common.session.SessionListener;9import org.apache.sshd.common.util.io.IoUtils;10import org.apache.sshd.sftp.client.SftpClient;11import org.apache.sshd.sftp.client.SftpClientFactory;12import org.apache.sshd.sftp.client.SftpVersionSelector;13import org.slf4j.Logger;14import org.slf4j.LoggerFactory;15import org.springframework.beans.factory.DisposableBean;16import org.springframework.beans.factory.InitializingBean;17import org.springframework.util.Assert;18import org.springframework.util.StringUtils;19import java.io.File;20import java.io.IOException;21import java.nio.file.Path;22import java.nio.file.Paths;23import java.util.Collection;24import java.util.List;25public class SftpClient implements InitializingBean, DisposableBean {26    private static final Logger LOG = LoggerFactory.getLogger(SftpClient.class);27    private SshClient client;28    private ClientSession session;29    private SftpClient sftpClient;30    private String host;31    private int port = 22;32    private String username;33    private String password;34    private String privateKeyPath;35    private String privateKeyPassphrase;36    private String remoteDirectory;37    private long timeout = 5000L;38    public void afterPropertiesSet() throws Exception {39        Assert.notNull(host, "Missing host information");40        Assert.notNull(username, "Missing username information");41        client = SshClient.setUpDefaultClient();42        client.setVersionSelector(SftpVersionSelector.CURRENT);43        client.start();

CitrusRuntimeException

Using AI Code Generation

1import com.consol.citrus.ftp.client.SftpClient;2import com.consol.citrus.exceptions.CitrusRuntimeException;3import com.consol.citrus.context.TestContext;4import com.consol.citrus.context.TestContextFactory;5import com.consol.citrus.dsl.builder.ReceiveMessageActionBuilder;6import com.consol.citrus.dsl.builder.SendMessageActionBuilder;7import com.consol.citrus.dsl.builder.SendSoapMessageActionBuilder;8import com.consol.citrus.dsl.builder.SendSoapFaultActionBuilder;9import com.consol.citrus.dsl.builder.HttpActionBuilder;10import com.consol.citrus.dsl.builder.HttpServerActionBuilder;11import com.consol.citrus.dsl.builder.HttpClientActionBuilder;12import com.consol.citrus.dsl.builder.CreateVariablesActionBuilder;13import com.consol.citrus.dsl.builder.ExecutePLSQLActionBuilder;14import com.consol.citrus.dsl.builder.ExecuteSQLActionBuilder;15import com.consol.citrus.dsl.builder.ExecuteSQLQueryActionBuilder;16import com.consol.citrus.dsl.builder.PurgeJmsQueuesActionBuilder;17import com.consol.citrus.dsl.builder.PurgeJmsQueuesActionBuilder.PurgeJmsQueuesActionBuilderSupport;18import com.consol.citrus.dsl.builder.PurgeJmsQueuesActionBuilder.PurgeJmsQueuesActionBuilderSupport.PurgeJmsQueuesActionBuilderSupportOneArg;19import com.consol.citrus.dsl.builder.PurgeJmsQueuesActionBuilder.PurgeJmsQueuesActionBuilderSupport.PurgeJmsQueuesActionBuilderSupportTwoArgs;20import com.consol.citrus.dsl.builder.PurgeJmsQueuesActionBuilder.PurgeJmsQueuesActionBuilderSupport.PurgeJmsQueuesActionBuilderSupportThreeArgs;21import com.consol.citrus.dsl.builder.PurgeJmsQueuesActionBuilder.PurgeJmsQueuesActionBuilderSupport.PurgeJmsQueuesActionBuilderSupportFourArgs;22import com.consol.citrus.dsl.builder.PurgeJmsQueuesActionBuilder.PurgeJmsQueuesActionBuilderSupport.PurgeJmsQueuesActionBuilderSupportFiveArgs;23import com.consol.citrus.dsl.builder.PurgeJmsQueuesActionBuilder.PurgeJmsQueuesActionBuilderSupport.PurgeJmsQueuesActionBuilderSupportSixArgs;24import com.consol

CitrusRuntimeException

Using AI Code Generation

1package com.consol.citrus.ftp.client;2import com.consol.citrus.exceptions.CitrusRuntimeException;3public class SftpClient {4    public void setSftpClient(com.jcraft.jsch.ChannelSftp sftpClient) {5        if (sftpClient == null) {6            throw new CitrusRuntimeException("SFTP client is not initialized!");7        }8        this.sftpClient = sftpClient;9    }10}11package com.consol.citrus.ftp.client;12import com.consol.citrus.exceptions.CitrusRuntimeException;13public class SftpClient {14    public void setSftpClient(com.jcraft.jsch.ChannelSftp sftpClient) {15        if (sftpClient == null) {16            throw new CitrusRuntimeException("SFTP client is not initialized!");17        }18        this.sftpClient = sftpClient;19    }20}21package com.consol.citrus.ftp.client;22import com.consol.citrus.exceptions.CitrusRuntimeException;23public class SftpClient {24    public void setSftpClient(com.jcraft.jsch.ChannelSftp sftpClient) {25        if (sftpClient == null) {26            throw new CitrusRuntimeException("SFTP client is not initialized!");27        }28        this.sftpClient = sftpClient;29    }30}31package com.consol.citrus.ftp.client;32import com.consol.citrus.exceptions.CitrusRuntimeException;33public class SftpClient {34    public void setSftpClient(com.jcraft.jsch.ChannelSftp sftpClient) {35        if (sftpClient == null) {36            throw new CitrusRuntimeException("SFTP client is not initialized!");37        }38        this.sftpClient = sftpClient;39    }40}

CitrusRuntimeException

Using AI Code Generation

1package com.consol.citrus.ftp.client;2import com.consol.citrus.annotations.CitrusTest;3import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;4import com.consol.citrus.exceptions.CitrusRuntimeException;5import org.testng.annotations.Test;6public class SftpClientExceptionTest extends TestNGCitrusTestRunner {7    public void sftpClientExceptionTest() {8        variable("remoteFile", "notfound.txt");9        echo("SFTP Client exception test");10        try {11            sftp(action -> action.client("sftpClient")12                    .receive()13                    .get("${remoteFile}"));14        } catch (CitrusRuntimeException e) {15            echo("Caught expected exception: ${e}");16        }17    }18}19package com.consol.citrus.ftp.client;20import com.consol.citrus.annotations.CitrusTest;21import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;22import com.consol.citrus.exceptions.CitrusRuntimeException;23import org.testng.annotations.Test;24public class FtpClientExceptionTest extends TestNGCitrusTestRunner {25    public void ftpClientExceptionTest() {26        variable("remoteFile", "notfound.txt");27        echo("FTP Client exception test");28        try {29            ftp(action -> action.client("ftpClient")30                    .receive()31                    .get("${remoteFile}"));32        } catch (CitrusRuntimeException e) {33            echo("Caught expected exception: ${e}");34        }35    }36}37package com.consol.citrus.ftp.client;38import com.consol.citrus.annotations.CitrusTest;39import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;40import com.consol.citrus.exceptions.C

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.