org.apache.geronimo.gshell.whisper.transport
Class TransportAdapter

java.lang.Object
  org.apache.geronimo.gshell.whisper.transport.TransportAdapter

All Implemented Interfaces:

Closeable, Transport

public class TransportAdapter
extends Object
implements Transport

???

Version:

$Rev: 579828 $ $Date: 2007-09-26 15:15:42 -0700 (Wed, 26 Sep 2007) $

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.geronimo.gshell.whisper.transport.Transport

Transport.Configuration, Transport.Listener

Constructor Summary

TransportAdapter(org.apache.mina.common.IoSession session)

Method Summary

void	addListener(Transport.Listener listener)
void	close()
protected void	ensureOpened()
Transport.Configuration	getConfiguration()
org.apache.mina.common.IoConnector	getConnector()
OutputStream	getErrorStream()
InputStream	getInputStream()
URI	getLocal()
OutputStream	getOutputStream()
URI	getRemote()
org.apache.mina.common.IoSession	getSession()
boolean	isClosed()
void	removeListener(Transport.Listener listener)
Message	request(Message msg)
Message	request(Message msg, Duration timeout)
org.apache.mina.common.WriteFuture	send(Object msg)
void	setConfiguration(Transport.Configuration config)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TransportAdapter

public TransportAdapter(org.apache.mina.common.IoSession session)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getRemote

public URI getRemote()

Specified by:

getRemote in interface Transport

getLocal

public URI getLocal()

Specified by:

getLocal in interface Transport

getConnector

public org.apache.mina.common.IoConnector getConnector()

Specified by:

getConnector in interface Transport

getSession

public org.apache.mina.common.IoSession getSession()

Specified by:

getSession in interface Transport

getInputStream

public InputStream getInputStream()

Specified by:

getInputStream in interface Transport

getOutputStream

public OutputStream getOutputStream()

Specified by:

getOutputStream in interface Transport

getErrorStream

public OutputStream getErrorStream()

Specified by:

getErrorStream in interface Transport

send

public org.apache.mina.common.WriteFuture send(Object msg)
                                        throws Exception

Specified by:

send in interface Transport

Throws:

Exception

request

public Message request(Message msg)
                throws Exception

Specified by:

request in interface Transport

Throws:

Exception

request

public Message request(Message msg,
                       Duration timeout)
                throws Exception

Specified by:

request in interface Transport

Throws:

Exception

isClosed

public boolean isClosed()

ensureOpened

protected void ensureOpened()

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface Transport

addListener

public void addListener(Transport.Listener listener)

Specified by:

addListener in interface Transport

removeListener

public void removeListener(Transport.Listener listener)

Specified by:

removeListener in interface Transport

setConfiguration

public void setConfiguration(Transport.Configuration config)

Specified by:

setConfiguration in interface Transport

getConfiguration

public Transport.Configuration getConfiguration()

Specified by:

getConfiguration in interface Transport