org.pfsw.tools.beluga.ldap.server
Class CommunicationChannel

java.lang.Object
  extended by org.pfsw.tools.beluga.ldap.server.CommunicationChannel
All Implemented Interfaces:
Runnable, org.pf.bif.execution.IService, org.pf.net.RequestProcessor

public class CommunicationChannel
extends Object
implements org.pf.net.RequestProcessor, org.pf.bif.execution.IService

Each communication channel is opened in a separate thread. It holds a connection to the client. When the connection gets closed the thread is finished as well.
The communication channel is responsible to receive the raw request data and transfer it to request message objects. Then it creates a Transaction on itself and the request message and sends it to the LDAPEngine for processing.
Finally it converts response messages to raw protocol data and sends them back to the client over the connection.

Version:
1.1
Author:
Manfred Duchrow

Constructor Summary
CommunicationChannel(LDAPServerConfiguration config, org.pfsw.tools.beluga.ldap.server.LDAPEngine ldapEngine, org.pf.net.BinarySocketConnection conn)
           
 
Method Summary
 void run()
          Runs the processing of requests coming in from the underlying socket connection.
 void setStateChangeListener(org.pf.bif.execution.IServiceStateChangeListener newValue)
           
 void terminate()
          Stops listening to the open socket and end the loop in run which actually ends the thread which executed this channel.
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

CommunicationChannel

public CommunicationChannel(LDAPServerConfiguration config,
                            org.pfsw.tools.beluga.ldap.server.LDAPEngine ldapEngine,
                            org.pf.net.BinarySocketConnection conn)
Method Detail

setStateChangeListener

public void setStateChangeListener(org.pf.bif.execution.IServiceStateChangeListener newValue)

run

public void run()
Runs the processing of requests coming in from the underlying socket connection.

Specified by:
run in interface Runnable

terminate

public void terminate()
Stops listening to the open socket and end the loop in run which actually ends the thread which executed this channel.



Copyright © 2012 Manfred Duchrow Consulting & Software. All Rights Reserved.