How to use SshMarshaller method of com.consol.citrus.ssh.client.SshEndpointConfiguration class

Best Citrus code snippet using com.consol.citrus.ssh.client.SshEndpointConfiguration.SshMarshaller

Source:SshClientTest.java

...16package com.consol.citrus.ssh.client;17import com.consol.citrus.exceptions.CitrusRuntimeException;18import com.consol.citrus.message.DefaultMessage;19import com.consol.citrus.message.Message;20import com.consol.citrus.ssh.model.SshMarshaller;21import com.consol.citrus.ssh.model.SshRequest;22import com.consol.citrus.testng.AbstractTestNGUnitTest;23import com.jcraft.jsch.*;24import org.apache.sshd.client.keyverifier.KnownHostsServerKeyVerifier;25import org.mockito.ArgumentMatcher;26import org.mockito.Mockito;27import org.springframework.test.util.ReflectionTestUtils;28import org.springframework.xml.transform.StringResult;29import org.testng.annotations.BeforeMethod;30import org.testng.annotations.Test;31import java.io.*;32import static org.mockito.Mockito.*;33import static org.testng.Assert.assertFalse;34import static org.testng.Assert.assertNull;35/**36 * @author Roland Huss37 * @since 12.09.1238 */39public class SshClientTest extends AbstractTestNGUnitTest {40    private static final String COMMAND = "ls";41    private static final String STDIN = "Hello world";42    private JSch jsch;43    private SshClient client;44    private ByteArrayOutputStream outStream;45    private Session session;46    private ChannelExec channel;47    private static final int CONNECTTION_TIMEOUT = 50;48    @BeforeMethod49    public void setup() throws JSchException {50        jsch = Mockito.mock(JSch.class);51        SshEndpointConfiguration endpointConfiguration = new SshEndpointConfiguration();52        client = new SshClient(endpointConfiguration);53        client.setJsch(jsch);54        endpointConfiguration.setHost("planck");55        endpointConfiguration.setUser("roland");56        endpointConfiguration.setPort(1968);57        endpointConfiguration.setConnectionTimeout(CONNECTTION_TIMEOUT);58        endpointConfiguration.setCommandTimeout(2 * 60 * 1000);59        session = Mockito.mock(Session.class);60        when(jsch.getSession("roland","planck",1968)).thenReturn(session);61        channel = Mockito.mock(ChannelExec.class);62        ReflectionTestUtils.setField(client, "jsch", jsch);63        outStream = new ByteArrayOutputStream();64    }65    @Test(expectedExceptions = CitrusRuntimeException.class,expectedExceptionsMessageRegExp = ".*user.*")66    public void noUser() {67        client.getEndpointConfiguration().setUser(null);68        send();69    }70    @Test(expectedExceptions = CitrusRuntimeException.class,expectedExceptionsMessageRegExp = ".*knownHosts.*")71    public void strictHostCheckingWithoutKnownHosts() throws JSchException {72        strictHostChecking(true, null);73        send();74    }75    @Test(expectedExceptions = CitrusRuntimeException.class,expectedExceptionsMessageRegExp = ".*blaHosts.*")76    public void strictHostCheckingWithFaultyKnownHosts() throws JSchException {77        strictHostChecking(true, "classpath:/com/consol/citrus/ssh/blaHosts");78        send();79    }80    @Test(expectedExceptions = CitrusRuntimeException.class,expectedExceptionsMessageRegExp = ".*/does/not/exist.*")81    public void strictHostCheckingWithFaultyKnownHosts2() throws JSchException {82        strictHostChecking(true, "/file/that/does/not/exist");83        send();84    }85    @Test86    public void strictHostCheckingWithKnownHosts() throws JSchException, IOException {87        strictHostChecking(true, "classpath:com/consol/citrus/ssh/knownHosts");88        jsch.setKnownHosts(isA(InputStream.class));89        standardChannelPrepAndSend();90    }91    private void standardChannelPrepAndSend() throws JSchException, IOException {92        session.connect();93        prepareChannel(COMMAND, 0);94        disconnect();95        send();96    }97    @Test(expectedExceptions = CitrusRuntimeException.class, expectedExceptionsMessageRegExp = ".*/that/does/not/exist.*")98    public void withUnknownPrivateKey() throws JSchException {99        strictHostChecking(false,null);100        client.getEndpointConfiguration().setPrivateKeyPath("/file/that/does/not/exist");101        doThrow(new JSchException("No such file")).when(jsch).addIdentity("/file/that/does/not/exist", (String) null);102        send();103    }104    @Test(expectedExceptions = CitrusRuntimeException.class,expectedExceptionsMessageRegExp = ".*/notthere\\.key.*")105    public void withUnknownPrivateKey2() throws JSchException {106        strictHostChecking(false,null);107        client.getEndpointConfiguration().setPrivateKeyPath("classpath:com/consol/citrus/ssh/notthere.key");108        jsch.addIdentity("classpath:com/consol/citrus/ssh/notthere.key",(String) null);109        send();110    }111    @Test112    public void withPrivateKey() throws JSchException, IOException {113        strictHostChecking(false,null);114        client.getEndpointConfiguration().setPrivateKeyPath("classpath:com/consol/citrus/ssh/private.key");115        jsch.addIdentity(isA(String.class), (String) isNull());116        strictHostChecking(false, null);117        standardChannelPrepAndSend();118    }119    @Test120    public void withPassword() throws JSchException, IOException {121        client.getEndpointConfiguration().setPassword("consol");122        session.setUserInfo(getUserInfo("consol"));123        session.setPassword("consol");124        strictHostChecking(false, null);125        standardChannelPrepAndSend();126    }127    @Test128    public void straight() throws JSchException, IOException {129        strictHostChecking(false, null);130        standardChannelPrepAndSend();131    }132    private void send() {133        client.send(createMessage(COMMAND, STDIN), context);134    }135    private void disconnect() throws JSchException {136        channel.disconnect();137        when(session.isConnected()).thenReturn(true);138        session.disconnect();139        when(session.openChannel("exec")).thenReturn(channel);140    }141    private void prepareChannel(String pCommand, int pExitStatus) throws JSchException, IOException {142        channel.setErrStream((OutputStream) any());143        channel.setOutputStream((OutputStream) any());144        channel.setInputStream((InputStream) any());145        channel.setCommand(pCommand);146        channel.connect(CONNECTTION_TIMEOUT);147        when(channel.getOutputStream()).thenReturn(outStream);148        when(channel.isClosed()).thenReturn(false);149        when(channel.isClosed()).thenReturn(true);150        when(channel.getExitStatus()).thenReturn(pExitStatus);151        when(channel.isConnected()).thenReturn(true);152    }153    private Message createMessage(String pCommand, String pInput) {154        SshRequest request = new SshRequest(pCommand,pInput);155        StringResult payload = new StringResult();156        new SshMarshaller().marshal(request, payload);157        return new DefaultMessage(payload.toString());158    }159    private void strictHostChecking(boolean flag,String knownHosts) {160        if (flag) {161            client.getEndpointConfiguration().setStrictHostChecking(true);162            session.setConfig(KnownHostsServerKeyVerifier.STRICT_CHECKING_OPTION,"yes");163            client.getEndpointConfiguration().setKnownHosts(knownHosts);164        } else {165            session.setConfig(KnownHostsServerKeyVerifier.STRICT_CHECKING_OPTION,"no");166        }167    }168    private UserInfo getUserInfo(final String arg) {169        argThat(new ArgumentMatcher() {170            public boolean matches(Object argument) {...

Source:SshEndpointConfiguration.java

...17import com.consol.citrus.endpoint.AbstractPollableEndpointConfiguration;18import com.consol.citrus.message.DefaultMessageCorrelator;19import com.consol.citrus.message.MessageCorrelator;20import com.consol.citrus.ssh.message.SshMessageConverter;21import com.consol.citrus.ssh.model.SshMarshaller;22/**23 * @author Roland Huss, Christoph Deppisch24 * @since 1.425 */26public class SshEndpointConfiguration extends AbstractPollableEndpointConfiguration {27    /** Host to connect to. Default: localhost */28    private String host = "localhost";29     /** SSH Port to connect to. Default: 2222 */30    private int port = 2222;31     /** User for doing the SSH communication */32    private String user;33     /** Password if no private key authentication is used */34    private String password;35     /** Path to private key of user */36    private String privateKeyPath;37     /** Password for private key */38    private String privateKeyPassword;39     /** Whether strict host checking should be performed */40    private boolean strictHostChecking = false;41     /** If strict host checking is used, path to the 'known_hosts' file */42    private String knownHosts;43     /** Timeout how long to wait for answering the request */44    private long commandTimeout = 1000 * 60 * 5; // 5 minutes45     /** Timeout how long to wait for a connection to connect */46    private int connectionTimeout = 1000 * 60 * 1; // 1 minute47    /** Reply message correlator */48    private MessageCorrelator correlator = new DefaultMessageCorrelator();49    /** Ssh message marshaller converts from XML to ssh message object */50    private SshMarshaller sshMarshaller = new SshMarshaller();51    /** Ssh message converter */52    private SshMessageConverter messageConverter = new SshMessageConverter();53    /**54     * Gets the ssh server host.55     * @return56     */57    public String getHost() {58        return host;59    }60    /**61     * Sets the ssh server host.62     * @param host63     */64    public void setHost(String host) {65        this.host = host;66    }67    /**68     * Gets the ssh server port.69     * @return70     */71    public int getPort() {72        return port;73    }74    /**75     * Sets the ssh server port.76     * @param port77     */78    public void setPort(int port) {79        this.port = port;80    }81    /**82     * Gets the ssh user.83     * @return84     */85    public String getUser() {86        return user;87    }88    /**89     * Sets the ssh user.90     * @param user91     */92    public void setUser(String user) {93        this.user = user;94    }95    /**96     * Gets the ssh user password.97     * @return98     */99    public String getPassword() {100        return password;101    }102    /**103     * Sets the ssh user password.104     * @param password105     */106    public void setPassword(String password) {107        this.password = password;108    }109    /**110     * Gets the private key store path.111     * @return112     */113    public String getPrivateKeyPath() {114        return privateKeyPath;115    }116    /**117     * Sets the private key store path.118     * @param privateKeyPath119     */120    public void setPrivateKeyPath(String privateKeyPath) {121        this.privateKeyPath = privateKeyPath;122    }123    /**124     * Gets the private keystore password.125     * @return126     */127    public String getPrivateKeyPassword() {128        return privateKeyPassword;129    }130    /**131     * Sets the private keystore password.132     * @param privateKeyPassword133     */134    public void setPrivateKeyPassword(String privateKeyPassword) {135        this.privateKeyPassword = privateKeyPassword;136    }137    /**138     * Is strict host checking enabled.139     * @return140     */141    public boolean isStrictHostChecking() {142        return strictHostChecking;143    }144    /**145     * Enables/disables strict host checking.146     * @param strictHostChecking147     */148    public void setStrictHostChecking(boolean strictHostChecking) {149        this.strictHostChecking = strictHostChecking;150    }151    /**152     * Gets known hosts.153     * @return154     */155    public String getKnownHosts() {156        return knownHosts;157    }158    /**159     * Sets known hosts.160     * @param knownHosts161     */162    public void setKnownHosts(String knownHosts) {163        this.knownHosts = knownHosts;164    }165    /**166     * Gets the command timeout.167     * @return168     */169    public long getCommandTimeout() {170        return commandTimeout;171    }172    /**173     * Sets the command timeout.174     * @param commandTimeout175     */176    public void setCommandTimeout(long commandTimeout) {177        this.commandTimeout = commandTimeout;178    }179    /**180     * Gets the connection timeout.181     * @return182     */183    public int getConnectionTimeout() {184        return connectionTimeout;185    }186    /**187     * Sets the connection timeout.188     * @param connectionTimeout189     */190    public void setConnectionTimeout(int connectionTimeout) {191        this.connectionTimeout = connectionTimeout;192    }193    /**194     * Gets the message correlator.195     * @return196     */197    public MessageCorrelator getCorrelator() {198        return correlator;199    }200    /**201     * Sets the message correlator.202     * @param correlator203     */204    public void setCorrelator(MessageCorrelator correlator) {205        this.correlator = correlator;206    }207    /**208     * Gets the message converter.209     * @return210     */211    public SshMessageConverter getMessageConverter() {212        return messageConverter;213    }214    /**215     * Sets the message converter.216     * @param messageConverter217     */218    public void setMessageConverter(SshMessageConverter messageConverter) {219        this.messageConverter = messageConverter;220    }221    /**222     * Gets the ssh oxm marshaller.223     * @return224     */225    public SshMarshaller getSshMarshaller() {226        return sshMarshaller;227    }228    /**229     * Sets the ssh oxm marshaller.230     * @param sshMarshaller231     */232    public void setSshMarshaller(SshMarshaller sshMarshaller) {233        this.sshMarshaller = sshMarshaller;234    }235}...

Source:SshCommandTest.java

...39    private ByteArrayOutputStream stdout, stderr;40    private SshCommand cmd;41    private EndpointAdapter adapter;42    private static String COMMAND = "shutdown";43    private SshMarshaller marshaller;44    private ExitCallback exitCallback;45    @BeforeMethod46    public void setup() {47        adapter = Mockito.mock(EndpointAdapter.class);48        cmd = new SshCommand(COMMAND, adapter, new SshEndpointConfiguration());49        stdout = new ByteArrayOutputStream();50        stderr = new ByteArrayOutputStream();51        cmd.setErrorStream(stderr);52        cmd.setOutputStream(stdout);53        exitCallback = Mockito.mock(ExitCallback.class);54        cmd.setExitCallback(exitCallback);55        marshaller = new SshMarshaller();56    }57    58    @Test59    public void base() throws IOException {60        String input = "Hello world";61        String output = "Think positive!";62        String error = "Error, Error";63        int exitCode = 12;64        assertEquals(cmd.getCommand(),COMMAND);65        prepare(input, output, error, exitCode);66        cmd.run();67        assertEquals(stdout.toByteArray(),output.getBytes());68        assertEquals(stderr.toByteArray(),error.getBytes());69    }...

SshMarshaller

Using AI Code Generation

1public class 3 extends TestCase {2    public void 3() {3        variable("sshHost", "localhost");4        variable("sshPort", "22");5        variable("sshUser", "user");6        variable("sshPassword", "password");7        variable("sshComm

SshMarshaller

Using AI Code Generation

1SshEndpointConfiguration sshEndpointConfiguration = new SshEndpointConfiguration();2SshMarshaller sshMarshaller = new SshMarshaller();3sshEndpointConfiguration.setSshMarshaller(sshMarshaller);4SshEndpointConfiguration sshEndpointConfiguration = new SshEndpointConfiguration();5SshMarshaller sshMarshaller = new SshMarshaller();6sshEndpointConfiguration.setSshMarshaller(sshMarshaller);7SshEndpointConfiguration sshEndpointConfiguration = new SshEndpointConfiguration();8SshMarshaller sshMarshaller = new SshMarshaller();9sshEndpointConfiguration.setSshMarshaller(sshMarshaller);10SshEndpointConfiguration sshEndpointConfiguration = new SshEndpointConfiguration();11SshMarshaller sshMarshaller = new SshMarshaller();12sshEndpointConfiguration.setSshMarshaller(sshMarshaller);

SshMarshaller

Using AI Code Generation

1package com.consol.citrus.ssh.client;2import com.consol.citrus.dsl.endpoint.CitrusEndpoints;3import com.consol.citrus.ssh.message.SshMessageConverter;4import org.springframework.context.annotation.Bean;5import org.springframework.context.annotation.Configuration;6import org.springframework.context.annotation.Import;7@Import(DefaultTestConfig.class)8public class SshMarshallerConfig {9    public SshEndpoint sshEndpoint() {10        return CitrusEndpoints.ssh()11                .client()12                .marshaller(new SshMessageConverter())13                .build();14    }15}16package com.consol.citrus.ssh.client;17import com.consol.citrus.dsl.endpoint.CitrusEndpoints;18import com.consol.citrus.ssh.message.SshMessageConverter;19import org.springframework.context.annotation.Bean;20import org.springframework.context.annotation.Configuration;21import org.springframework.context.annotation.Import;22@Import(DefaultTestConfig.class)23public class SshMarshallerConfig {24    public SshEndpoint sshEndpoint() {25        return CitrusEndpoints.ssh()26                .client()27                .marshaller(new SshMessageConverter())28                .build();29    }30}31package com.consol.citrus.ssh.client;32import com.consol.citrus.dsl.endpoint.CitrusEndpoints;33import com.con

SshMarshaller

Using AI Code Generation

1import com.consol.citrus.ssh.client.SshEndpointConfiguration;2import com.consol.citrus.ssh.client.SshClient;3import com.consol.citrus.ssh.client.SshMarshaller;4import com.consol.citrus.ssh.message.SshMessage;5import org.springframework.context.annotation.Bean;6import org.springframework.context.annotation.Configuration;7import org.springframework.context.annotation.Import;8import org.springframework.integration.annotation.ServiceActivator;9import org.springframework.integration.config.EnableIntegration;10import org.springframework.integration.ssh.config.SshOutboundChannelAdapterParser;11import org.springframework.integration.ssh.config.SshOutboundGatewayParser;12import org.springframework.integration.ssh.outbound.SshOutboundGateway;13import org.springframework.integration.ssh.outbound.SshOutboundGateway.CommandExecutorType;14import org.springframework.integration.ssh.outbound.SshOutboundGateway.GatewayType;15import org.springframework.integration.ssh.session.DefaultSshSessionFactory;16import org.springframework.integration.ssh.session.SshSession;17import org.springframework.integration.ssh.session.SshSessionFactory;18import org.springframework.integration.ssh.support.SshUtils;19import org.springframework.messaging.Message;20import org.springframework.messaging.MessageChannel;21import org.springframework.messaging.MessageHandler;22import org.springframework.messaging.MessagingException;23import java.util.Map;24@Import({SshOutboundChannelAdapterParser.class, SshOutboundGatewayParser.class})25public class SshOutboundGatewayConfig {26  public SshOutboundGateway sshOutboundGateway() {27    SshOutboundGateway sshOutboundGateway = new SshOutboundGateway();28    sshOutboundGateway.setCommand("ls -l");29    sshOutboundGateway.setCommandExecutorType(CommandExecutorType.SHELL);30    sshOutboundGateway.setGatewayType(GatewayType.SFTP);31    sshOutboundGateway.setSessionFactory(sshSessionFactory());32    sshOutboundGateway.setReplyChannelName("sshOutboundGatewayReplyChannel");33    sshOutboundGateway.setReplyTimeout(10000);34    return sshOutboundGateway;35  }36  public SshSessionFactory sshSessionFactory() {37    DefaultSshSessionFactory defaultSshSessionFactory = new DefaultSshSessionFactory();38    defaultSshSessionFactory.setHost("

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.