com.maverick.ssh

Class SubsystemChannel

java.lang.Object

com.maverick.ssh.SubsystemChannel

Direct Known Subclasses:

PublicKeySubsystem, SftpSubsystemChannel

public class SubsystemChannel
extends Object

This class provides useful methods for implementing an SSH2 subsystem. Subsystems typically send messages in the following format.

 UINT           length
 byte           type
 byte[length-1] payload
 

Messages sent using the methods of this class will have the UINT length automatically added and messages received will be unwrapped with just the type and payload being returned. Although subsystems were defined within the SSH2 connection protocol this class takes a single SshChannel as an argument to its constructor which enables subsystems to run over both SSH1 and SSH2 channels.

Author:

Lee David Painter

Field Summary

Fields

Modifier and Type	Field and Description
protected SshChannel	channel

Constructor Summary

Constructors

Constructor and Description
SubsystemChannel(SshChannel channel, int timeout) Create a new subsystem channel.

Method Summary

Modifier and Type	Method and Description
void	close() Close the subsystem
protected Packet	createPacket() Get a packet from the available pool or create if non available
protected void	debug(org.slf4j.Logger log, String msg, Object... args)
protected void	debug(org.slf4j.Logger log, String msg, Throwable e, Object... args)
boolean	isClosed() Is the subsystem closed?
byte[]	nextMessage() Read a subsystem message from the channel inputstream.
protected void	sendMessage(Packet msg) Write a subsystem message to the channel outputstream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

channel

protected SshChannel channel

Constructor Detail

SubsystemChannel

public SubsystemChannel(SshChannel channel,
                        int timeout)
                 throws SshException

Create a new subsystem channel.

Parameters:

channel -

Throws:

SshException

Method Detail

debug

protected void debug(org.slf4j.Logger log,
                     String msg,
                     Object... args)

debug

protected void debug(org.slf4j.Logger log,
                     String msg,
                     Throwable e,
                     Object... args)

isClosed

public boolean isClosed()

Is the subsystem closed?

Returns:

boolean

close

public void close()
           throws IOException

Close the subsystem

Throws:

IOException

nextMessage

public byte[] nextMessage()
                   throws SshException

Read a subsystem message from the channel inputstream. Each

Returns:

byte[]

Throws:

SshException

sendMessage

protected void sendMessage(Packet msg)
                    throws SshException

Write a subsystem message to the channel outputstream.

Parameters:

msg -

Throws:

SshException

createPacket

protected Packet createPacket()
                       throws IOException

Get a packet from the available pool or create if non available

Returns:

Packet

Throws:

IOException