org.teiid.transport

Class SocketClientInstance

java.lang.Object

org.teiid.transport.SocketClientInstance

All Implemented Interfaces:

ChannelListener, ClientInstance

public class SocketClientInstance
extends Object
implements ChannelListener, ClientInstance

Sockets implementation of the communication framework class representing the server's view of a client connection. Implements the server-side of the sockets messaging protocol. The client side of the protocol is implemented in SocketServerInstance. Users of this class are expected to provide a WorkerPool for processing incoming messages. Users must also call read(). Users also provide a ServerListener implementation. The ServerListener is the application level object processing the application level messages.

Nested Class Summary

Nested classes/interfaces inherited from interface org.teiid.transport.ChannelListener

ChannelListener.ChannelListenerFactory

Constructor Summary

Constructors

Constructor and Description
SocketClientInstance(ObjectChannel objectSocket, ClientServiceRegistryImpl csr, boolean isClientEncryptionEnabled)

Method Summary

Modifier and Type	Method and Description
void	disconnected()
void	exceptionOccurred(Throwable t)
Cryptor	getCryptor()
DQPWorkContext	getWorkContext()
void	onConnection()
void	receivedMessage(Object msg)
void	send(Message message, Serializable messageKey) Send a message to this particular client using the asynch message key.
void	shutdown() Shutdown the server's connection to the client.

Methods inherited from class java.lang.Object

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

Constructor Detail

SocketClientInstance

public SocketClientInstance(ObjectChannel objectSocket,
                            ClientServiceRegistryImpl csr,
                            boolean isClientEncryptionEnabled)

Method Detail

send

public void send(Message message,
                 Serializable messageKey)

Description copied from interface: ClientInstance

Send a message to this particular client using the asynch message key.

Specified by:

send in interface ClientInstance

Parameters:

message - The message to send

messageKey - The key sent with the asynch query

getCryptor

public Cryptor getCryptor()

Specified by:

getCryptor in interface ClientInstance

Returns:

Returns the cryptor.

exceptionOccurred

public void exceptionOccurred(Throwable t)

Specified by:

exceptionOccurred in interface ChannelListener

onConnection

public void onConnection()
                  throws CommunicationException

Specified by:

onConnection in interface ChannelListener

Throws:

CommunicationException

disconnected

public void disconnected()

Specified by:

disconnected in interface ChannelListener

receivedMessage

public void receivedMessage(Object msg)
                     throws CommunicationException

Specified by:

receivedMessage in interface ChannelListener

Throws:

CommunicationException

shutdown

public void shutdown()
              throws CommunicationException

Description copied from interface: ClientInstance

Shutdown the server's connection to the client.

Specified by:

shutdown in interface ClientInstance

Throws:

CommunicationException - If an error occurs during the shutdown

getWorkContext

public DQPWorkContext getWorkContext()

Specified by:

getWorkContext in interface ClientInstance