|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.joram.mom.proxies.ConnectionManager
public class ConnectionManager
A ConnectionManager
is started as a service in each
MOM agent server for allowing connections with external clients.
Field Summary | |
---|---|
private boolean |
activated
true if new connections are accepted. |
private static ConnectionManager |
currentInstance
Unique ConnectionManager instance. |
static int |
inFlow
Limit of incoming messages flow (msgs/s) requested if any, default value is -1 (no limitation). |
static org.objectweb.util.monolog.api.Logger |
logger
logger |
private java.util.List |
managers
List of registered managers (tcp, ssl, local, ...) |
private static java.lang.String |
MBEAN_NAME
|
static java.lang.String |
MULTI_CNX_SYNC
|
static java.lang.String |
MULTI_CNX_SYNC_DELAY
|
private static boolean |
multiCnxSync
|
private static java.util.Hashtable |
multiCnxSyncTable
|
private static long |
multiThreadSyncDelay
|
Constructor Summary | |
---|---|
ConnectionManager()
|
Method Summary | |
---|---|
void |
activate()
Activates the connection manager. |
void |
addManager(ConnectionManagerMBean manager)
Registers a new manager. |
void |
closeAllConnections()
Closes all opened connections. |
private static Identity |
createIdentity(java.lang.String adminName,
java.lang.String adminPassword,
java.lang.String identityClassName)
Create an admin Identity. |
void |
deactivate()
Deactivates the connection manager. |
static ConnectionManager |
getCurrentInstance()
|
int |
getFailedLoginCount()
Gets the number of connections rejected due to a failed authentication. |
int |
getInitiatedConnectionCount()
Gets the number of initiated connections since server start. |
java.lang.String |
getMBeanName()
Gets the name of the MBean. |
static MultiCnxSync |
getMultiCnxSync(AgentId proxyId)
|
static long |
getMultiThreadSyncDelay()
|
int |
getRunningConnectionsCount()
Gets the number of living connections. |
static void |
init(java.lang.String args,
boolean firstTime)
Initializes the connection manager as a service. |
boolean |
isActivated()
Tells if the ConnectionManager is active. |
private void |
removeAllManagers()
|
void |
removeManager(ConnectionManagerMBean manager)
Removes a registered manager. |
static void |
sendToProxy(AgentId proxyId,
int cnxKey,
AbstractJmsRequest req,
java.lang.Object msg)
|
static void |
stopService()
Stops the ConnectionManager service. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static org.objectweb.util.monolog.api.Logger logger
public static final java.lang.String MULTI_CNX_SYNC
public static final java.lang.String MULTI_CNX_SYNC_DELAY
private static boolean multiCnxSync
private static long multiThreadSyncDelay
private static final java.lang.String MBEAN_NAME
private boolean activated
true
if new connections are accepted.
private java.util.List managers
private static ConnectionManager currentInstance
private static java.util.Hashtable multiCnxSyncTable
public static int inFlow
java
launching command, or in a3servers.xml
configuration file.
Constructor Detail |
---|
public ConnectionManager()
Method Detail |
---|
public static final void sendToProxy(AgentId proxyId, int cnxKey, AbstractJmsRequest req, java.lang.Object msg)
public static final long getMultiThreadSyncDelay()
public static MultiCnxSync getMultiCnxSync(AgentId proxyId)
public static void init(java.lang.String args, boolean firstTime) throws java.lang.Exception
args
- name and password of the administrator (optional).firstTime
- true
when the agent server starts.
java.lang.Exception
- Thrown when processing the String argument
or in case of a problem when deploying the ConnectionFactory.private static Identity createIdentity(java.lang.String adminName, java.lang.String adminPassword, java.lang.String identityClassName) throws java.lang.Exception
adminName
- Name of the admin.adminPassword
- Password of the admin.identityClassName
- identity class name.
java.lang.Exception
public static void stopService()
ConnectionManager
service.
public void activate()
ConnectionManagerMBean
activate
in interface ConnectionManagerMBean
public void closeAllConnections()
ConnectionManagerMBean
closeAllConnections
in interface ConnectionManagerMBean
public void deactivate()
ConnectionManagerMBean
deactivate
in interface ConnectionManagerMBean
public int getRunningConnectionsCount()
ConnectionManagerMBean
getRunningConnectionsCount
in interface ConnectionManagerMBean
public boolean isActivated()
ConnectionManagerMBean
isActivated
in interface ConnectionManagerMBean
public static ConnectionManager getCurrentInstance()
public void addManager(ConnectionManagerMBean manager)
public void removeManager(ConnectionManagerMBean manager)
private void removeAllManagers()
public java.lang.String getMBeanName()
ConnectionManagerMBean
getMBeanName
in interface ConnectionManagerMBean
public int getFailedLoginCount()
ConnectionManagerMBean
getFailedLoginCount
in interface ConnectionManagerMBean
public int getInitiatedConnectionCount()
ConnectionManagerMBean
getInitiatedConnectionCount
in interface ConnectionManagerMBean
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |