org.waarp.openr66.protocol.localhandler

Class LocalTransaction

java.lang.Object

org.waarp.openr66.protocol.localhandler.LocalTransaction

public class LocalTransaction
extends Object

This class handles Local Transaction connections

Constructor Summary

Constructors

Constructor and Description
LocalTransaction() Constructor

Method Summary

Modifier and Type	Method and Description
void	closeAll() Close All Local Channels
boolean	contained(int id)
boolean	contained(String key)
LocalChannelReference	createNewClient(NetworkChannelReference networkChannelReference, Integer remoteId, R66Future futureRequest, boolean fromSsl) Create a new Client
void	debugPrintActiveLocalChannels() Debug function (while shutdown for instance)
LocalChannelReference	getClient(Integer remoteId, Integer localId) Get the corresponding LocalChannelReference and set the remoteId if different
LocalChannelReference	getFromId(Integer id)
LocalChannelReference	getFromRequest(String key)
int	getNumberLocalChannel()
String	hashStatus()
protected void	remove(LocalChannelReference localChannelReference) Remove one local channel
void	setFromId(DbTaskRunner runner, LocalChannelReference lcr)
void	shutdownLocalChannels() Informs all remote client that the server is shutting down

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalTransaction

public LocalTransaction()

Constructor

Method Detail

hashStatus

public String hashStatus()

getClient

public LocalChannelReference getClient(Integer remoteId,
                                       Integer localId)
                                throws OpenR66ProtocolSystemException

Get the corresponding LocalChannelReference and set the remoteId if different

Parameters:

remoteId -

localId -

Returns:

the LocalChannelReference

Throws:

OpenR66ProtocolSystemException

createNewClient

public LocalChannelReference createNewClient(NetworkChannelReference networkChannelReference,
                                             Integer remoteId,
                                             R66Future futureRequest,
                                             boolean fromSsl)
                                      throws OpenR66ProtocolSystemException,
                                             OpenR66ProtocolRemoteShutdownException,
                                             OpenR66ProtocolNoConnectionException

Create a new Client

Parameters:

networkChannelReference -

remoteId - might be set to ChannelUtils.NOCHANNEL (real creation)

futureRequest - might be null (from NetworkChannel Startup)

Returns:

the LocalChannelReference

Throws:

OpenR66ProtocolSystemException

OpenR66ProtocolRemoteShutdownException

OpenR66ProtocolNoConnectionException

getFromId

public LocalChannelReference getFromId(Integer id)

Parameters:

id -

Returns:

the LocalChannelReference

remove

protected void remove(LocalChannelReference localChannelReference)

Remove one local channel

Parameters:

localChannelReference -

setFromId

public void setFromId(DbTaskRunner runner,
                      LocalChannelReference lcr)

Parameters:

runner -

lcr -

getFromRequest

public LocalChannelReference getFromRequest(String key)

Parameters:

key - as "requested requester specialId"

Returns:

the LocalChannelReference

contained

public boolean contained(String key)

Parameters:

key - as "requested requester specialId"

Returns:

True if the LocalChannelReference exists

contained

public boolean contained(int id)

Parameters:

id -

Returns:

True if the LocalChannelReference exists

getNumberLocalChannel

public int getNumberLocalChannel()

Returns:

the number of active local channels

debugPrintActiveLocalChannels

public void debugPrintActiveLocalChannels()

Debug function (while shutdown for instance)

shutdownLocalChannels

public void shutdownLocalChannels()

Informs all remote client that the server is shutting down

closeAll

public void closeAll()

Close All Local Channels