Package com.db4o.cs.internal

Class ServerMessageDispatcherImpl

java.lang.Object

com.db4o.cs.internal.ServerMessageDispatcherImpl

All Implemented Interfaces:

ClientConnection, MessageDispatcher, ServerMessageDispatcher, CommittedCallbackDispatcher, java.lang.Runnable

public final class ServerMessageDispatcherImpl
extends java.lang.Object
implements ServerMessageDispatcher, java.lang.Runnable

Method Summary

Modifier and Type	Method	Description
boolean	caresAboutCommitted()
void	caresAboutCommitted(boolean care)
ClassInfoHelper	classInfoHelper()
boolean	close()
boolean	close(ShutdownMode mode)
void	closeConnection()
CallbackObjectInfoCollections	committedInfo()
void	dispatchCommitted(CallbackObjectInfoCollections committedInfo)
int	dispatcherID()
boolean	isMessageDispatcherAlive()
void	join()
void	login()
void	mapQueryResultToID(LazyClientObjectSetStub stub, int queryResultID)
Event4<MessageEventArgs>	messageReceived()	EventArgs => MessageEventArgs
java.lang.String	name()
boolean	processMessage(Msg message)
void	queryResultFinalized(int queryResultID)
LazyClientObjectSetStub	queryResultForID(int queryResultID)
void	run()
ObjectServerImpl	server()
void	setDispatcherName(java.lang.String name)
Socket4Adapter	socket()
void	switchToFile(MSwitchToFile message)
void	switchToMainFile()
Transaction	transaction()
void	useTransaction(MUseTransaction message)
boolean	willDispatchCommitted()
boolean	write(Msg msg)

Methods inherited from class java.lang.Object

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

Method Detail

close

public boolean close()

Specified by:

close in interface MessageDispatcher

Specified by:

close in interface ServerMessageDispatcher

close

public boolean close(ShutdownMode mode)

Specified by:

close in interface ServerMessageDispatcher

closeConnection

public void closeConnection()

Specified by:

closeConnection in interface ServerMessageDispatcher

isMessageDispatcherAlive

public boolean isMessageDispatcherAlive()

Specified by:

isMessageDispatcherAlive in interface MessageDispatcher

transaction

public Transaction transaction()

Specified by:

transaction in interface ServerMessageDispatcher

run

public void run()

Specified by:

run in interface java.lang.Runnable

processMessage

public boolean processMessage(Msg message)

Specified by:

processMessage in interface ServerMessageDispatcher

server

public ObjectServerImpl server()

Specified by:

server in interface ServerMessageDispatcher

queryResultFinalized

public void queryResultFinalized(int queryResultID)

Specified by:

queryResultFinalized in interface ServerMessageDispatcher

mapQueryResultToID

public void mapQueryResultToID(LazyClientObjectSetStub stub,
                               int queryResultID)

Specified by:

mapQueryResultToID in interface ServerMessageDispatcher

queryResultForID

public LazyClientObjectSetStub queryResultForID(int queryResultID)

Specified by:

queryResultForID in interface ServerMessageDispatcher

switchToFile

public void switchToFile(MSwitchToFile message)

Specified by:

switchToFile in interface ServerMessageDispatcher

switchToMainFile

public void switchToMainFile()

Specified by:

switchToMainFile in interface ServerMessageDispatcher

useTransaction

public void useTransaction(MUseTransaction message)

Specified by:

useTransaction in interface ServerMessageDispatcher

write

public boolean write(Msg msg)

Specified by:

write in interface MessageDispatcher

Specified by:

write in interface ServerMessageDispatcher

socket

public Socket4Adapter socket()

Specified by:

socket in interface ServerMessageDispatcher

name

public java.lang.String name()

Specified by:

name in interface ClientConnection

setDispatcherName

public void setDispatcherName(java.lang.String name)

Specified by:

setDispatcherName in interface ServerMessageDispatcher

dispatcherID

public int dispatcherID()

Specified by:

dispatcherID in interface ServerMessageDispatcher

login

public void login()

Specified by:

login in interface ServerMessageDispatcher

caresAboutCommitted

public boolean caresAboutCommitted()

Specified by:

caresAboutCommitted in interface ServerMessageDispatcher

caresAboutCommitted

public void caresAboutCommitted(boolean care)

Specified by:

caresAboutCommitted in interface ServerMessageDispatcher

committedInfo

public CallbackObjectInfoCollections committedInfo()

Specified by:

committedInfo in interface ServerMessageDispatcher

dispatchCommitted

public void dispatchCommitted(CallbackObjectInfoCollections committedInfo)

Specified by:

dispatchCommitted in interface CommittedCallbackDispatcher

willDispatchCommitted

public boolean willDispatchCommitted()

Specified by:

willDispatchCommitted in interface CommittedCallbackDispatcher

classInfoHelper

public ClassInfoHelper classInfoHelper()

Specified by:

classInfoHelper in interface ServerMessageDispatcher

messageReceived

public Event4<MessageEventArgs> messageReceived()

EventArgs => MessageEventArgs

Specified by:

messageReceived in interface ClientConnection

join

public void join()
          throws java.lang.InterruptedException

Specified by:

join in interface ServerMessageDispatcher

Throws:

java.lang.InterruptedException