com.adventnet.nms.startnms
Class MainSocketClientFE

java.lang.Object
  com.adventnet.nms.startnms.MainSocketClientFE

All Implemented Interfaces:

RMICallbackInterface, SocketConnectionBE, java.lang.Runnable, java.rmi.Remote

public class MainSocketClientFE
extends java.lang.Object
implements java.lang.Runnable, RMICallbackInterface, SocketConnectionBE

Field Summary

boolean

connected

Constructor Summary

MainSocketClientFE()

MainSocketClientFE(boolean singleJVM)

MainSocketClientFE(java.lang.String rmi)

MainSocketClientFE(java.lang.String hostname, int port)

Method Summary

boolean	addWebClientDetails(java.util.Properties props)
void	broadcastMessage(java.lang.String id, byte[] data)
void	broadcastToAllClients(java.lang.String id, java.lang.String uniqueID, byte[] data)
boolean	cleanUpUser(java.util.Vector user, java.lang.String type) cleanUpUser is called to close user session for those users who have been disabled,removed or user time has expired
void	decrementClientCount()
boolean	deRegisterBEFailOverListener(BEFailOverListener belistener) This method is used to deregister to the BEFailOverListener.
boolean	deRegisterFailOverObserver(BEFailOverObserver observer) Deprecated. - Use BEFailOverListener instead of BEFailOverObserver.
void	deRegisterForResponses(java.lang.String portAndIP)
void	deRegisterForResponses(java.lang.String portAndIP, java.lang.String cleanUp_info)
java.util.Properties	getNewPrimaryBEProps(java.lang.String currentBEHost)
java.lang.Integer	getPort(java.lang.String key)
UpdateClient	getUpdateClient(java.lang.String updateID)
boolean	isClientsUnlimited()
boolean	isInitialized()
void	processNotification(byte[] data)
void	receive(java.lang.String id, java.lang.String uniqueID, byte[] data)
void	receiveServerData(byte[] barr)
void	registerBEFailOverListener(BEFailOverListener belistener) This method is used to register to the BEFailOverListener.
void	registerFailOverObserver(BEFailOverObserver observer) Deprecated. - Use BEFailOverListener instead of BEFailOverObserver.
void	registerForResponses(java.lang.String portAndIP, MainSocketSessionFE sockSession)
void	registerForUpdates(java.lang.String updateID, UpdateClient updateClient)
boolean	removeWebClientDetails(java.lang.String key, java.lang.String id)
void	run()
boolean	send(java.lang.String id, byte[] data)
boolean	send(java.lang.String id, java.lang.String uniqueID, byte[] data)
void	sendClientInformationToBE(boolean clientConnected)
void	sendReady() Sends the READY signal to the BE server.
void	setHasRMIClients(boolean boo)

Methods inherited from class java.lang.Object

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

Field Detail

connected

public boolean connected

Constructor Detail

MainSocketClientFE

public MainSocketClientFE()

MainSocketClientFE

public MainSocketClientFE(java.lang.String hostname,
                          int port)

MainSocketClientFE

public MainSocketClientFE(boolean singleJVM)

MainSocketClientFE

public MainSocketClientFE(java.lang.String rmi)

Method Detail

sendReady

public void sendReady()

Sends the READY signal to the BE server. Only then, the Sessions for this particular FE will be created on the BE side.

run

public void run()

Specified by:

run in interface java.lang.Runnable

cleanUpUser

public boolean cleanUpUser(java.util.Vector user,
                           java.lang.String type)

cleanUpUser is called to close user session for those users who have been disabled,removed or user time has expired

Parameters:

userName -

type - can be disabled,removed or userexpired

Returns:

true if successful else false

getNewPrimaryBEProps

public java.util.Properties getNewPrimaryBEProps(java.lang.String currentBEHost)

registerFailOverObserver

public void registerFailOverObserver(BEFailOverObserver observer)

Deprecated. - Use BEFailOverListener instead of BEFailOverObserver.

This method is used to register to the BEFailOverObserver.

Parameters:

- - BEFailOverObserver.

deRegisterFailOverObserver

public boolean deRegisterFailOverObserver(BEFailOverObserver observer)

Deprecated. - Use BEFailOverListener instead of BEFailOverObserver.

This method is used to deregister to the BEFailOverObserver.

Parameters:

- - BEFailOverObserver.

Returns:

true successfully deregister. Otherwise return false.

registerBEFailOverListener

public void registerBEFailOverListener(BEFailOverListener belistener)

This method is used to register to the BEFailOverListener.

Parameters:

- - BEFailOverListener.

deRegisterBEFailOverListener

public boolean deRegisterBEFailOverListener(BEFailOverListener belistener)

This method is used to deregister to the BEFailOverListener.

Parameters:

- - BEFailOverListener.

Returns:

true successfully deregister. Otherwise return false.

isInitialized

public boolean isInitialized()

Specified by:

isInitialized in interface SocketConnectionBE

receive

public void receive(java.lang.String id,
                    java.lang.String uniqueID,
                    byte[] data)

Specified by:

receive in interface SocketConnectionBE

getPort

public java.lang.Integer getPort(java.lang.String key)

broadcastMessage

public void broadcastMessage(java.lang.String id,
                             byte[] data)

broadcastToAllClients

public void broadcastToAllClients(java.lang.String id,
                                  java.lang.String uniqueID,
                                  byte[] data)

registerForResponses

public void registerForResponses(java.lang.String portAndIP,
                                 MainSocketSessionFE sockSession)

setHasRMIClients

public void setHasRMIClients(boolean boo)

deRegisterForResponses

public void deRegisterForResponses(java.lang.String portAndIP)

deRegisterForResponses

public void deRegisterForResponses(java.lang.String portAndIP,
                                   java.lang.String cleanUp_info)

sendClientInformationToBE

public void sendClientInformationToBE(boolean clientConnected)

decrementClientCount

public void decrementClientCount()

registerForUpdates

public void registerForUpdates(java.lang.String updateID,
                               UpdateClient updateClient)

getUpdateClient

public UpdateClient getUpdateClient(java.lang.String updateID)

send

public boolean send(java.lang.String id,
                    byte[] data)

addWebClientDetails

public boolean addWebClientDetails(java.util.Properties props)

removeWebClientDetails

public boolean removeWebClientDetails(java.lang.String key,
                                      java.lang.String id)

send

public boolean send(java.lang.String id,
                    java.lang.String uniqueID,
                    byte[] data)

receiveServerData

public void receiveServerData(byte[] barr)

Specified by:

receiveServerData in interface RMICallbackInterface

processNotification

public void processNotification(byte[] data)

isClientsUnlimited

public boolean isClientsUnlimited()