|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.remoting.AbstractInvoker
org.jboss.remoting.ServerInvoker
ServerInvoker is the server-side part of a remote Invoker. The ServerInvoker implementation is responsible for calling transport, depending on how the protocol receives the incoming data.
Field Summary | |
protected java.util.Map |
callbackHandlers
|
static java.lang.String |
CLIENT_CONNECT_ADDRESS_KEY
|
static java.lang.String |
CLIENT_CONNECT_PORT_KEY
|
static java.lang.String |
CLIENT_LEASE_PERIOD
|
protected java.util.Map |
clientCallbackListener
|
static int |
DEFAULT_CLIENT_LEASE_PERIOD
The default lease period for clients. |
protected java.util.Map |
handlers
|
static int |
MAX_NUM_ONEWAY_THREADS
The max number of worker threads to be used in the pool for processing one way calls on the server side. |
static java.lang.String |
MAX_NUM_ONEWAY_THREADS_KEY
|
static java.lang.String |
ONEWAY_THREAD_POOL_CLASS_KEY
|
static java.lang.String |
SERVER_BIND_ADDRESS_KEY
|
static java.lang.String |
SERVER_BIND_PORT_KEY
|
static java.lang.String |
SERVER_SOCKET_FACTORY
|
static java.lang.String |
TIMEOUT
|
Fields inherited from class org.jboss.remoting.AbstractInvoker |
classbyteloader, configuration, localServerLocators, locator, log, serializationType |
Constructor Summary | |
ServerInvoker(InvokerLocator locator)
|
|
ServerInvoker(InvokerLocator locator,
java.util.Map configuration)
|
Method Summary | |
void |
addConnectionListener(ConnectionListener listener)
|
ServerInvocationHandler |
addInvocationHandler(java.lang.String subsystem,
ServerInvocationHandler handler)
add a server invocation handler for a particular subsystem. |
void |
create()
|
protected javax.net.ServerSocketFactory |
createServerSocketFactory()
|
void |
destroy()
destory the invoker permanently |
java.lang.String |
getClientConnectAddress()
|
int |
getClientConnectPort()
|
java.util.Map |
getConfiguration()
Gets teh server invoker's transport specific configuration. |
java.lang.String |
getDataType()
Will get the data type for the marshaller factory so know which marshaller to get to marshal the data. |
protected abstract java.lang.String |
getDefaultDataType()
|
protected javax.net.ServerSocketFactory |
getDefaultServerSocketFactory()
Gets the default server socket factory to use for the server invoker. |
ServerInvocationHandler |
getInvocationHandler(java.lang.String subsystem)
get a ServerInvocationHandler for a given subsystem type |
ServerInvocationHandler[] |
getInvocationHandlers()
return an array of the server invocation handlers |
long |
getLeasePeriod()
|
int |
getMaxNumberOfOnewayThreads()
|
java.lang.String |
getMBeanObjectName()
Returns the String for the object name to be used for the invoker. |
javax.management.MBeanServer |
getMBeanServer()
|
org.jboss.util.threadpool.ThreadPool |
getOnewayThreadPool()
|
java.lang.String |
getServerBindAddress()
|
int |
getServerBindPort()
|
javax.net.ServerSocketFactory |
getServerSocketFactory()
|
java.lang.String[] |
getSupportedSubsystems()
return array of keys for each subsystem this invoker can handle |
int |
getTimeout()
|
boolean |
hasInvocationHandler(java.lang.String subsystem)
return true if a server invocation handler has been registered for this subsystem |
java.lang.Object |
invoke(InvocationRequest invocation)
Processes invocation request depending on the invocation type (internal, name based, oneway, etc). |
java.lang.Object |
invoke(java.lang.Object invoke)
|
boolean |
isStarted()
return true if the server invoker is started, false if not |
protected void |
postProcess(java.lang.String sessionId,
java.lang.Object param,
java.util.Map payload,
InvokerLocator locator)
called after an invocation |
protected void |
preProcess(java.lang.String sessionId,
ClassBytes arg,
java.util.Map payload,
InvokerLocator locator)
called prior to an invocation |
void |
removeCallbackListener(java.lang.String subsystem,
InvokerCallbackHandler callbackHandler)
|
void |
removeConnectionListener(ConnectionListener listener)
|
ServerInvocationHandler |
removeInvocationHandler(java.lang.String subsystem)
remove a subsystem invocation handler |
void |
setClientConnectAddress(java.lang.String clientConnectAddress)
This method should only be called by the service controller when this invoker is specified within the Connector configuration of a service xml. |
void |
setClientConnectPort(int clientConnectPort)
|
void |
setConfiguration(java.util.Map configuration)
Sets the server invoker's transport specific configuration. |
void |
setLeasePeriod(long leasePeriodValue)
|
void |
setMaxNumberOfOnewayThreads(int numOfThreads)
|
void |
setMBeanServer(javax.management.MBeanServer server)
|
void |
setOnewayThreadPool(org.jboss.util.threadpool.ThreadPool pool)
|
void |
setServerSocketFactory(javax.net.ServerSocketFactory serverSocketFactory)
|
void |
setTimeout(int timeout)
|
protected void |
setup()
|
void |
start()
subclasses should override to provide any specific start logic |
void |
stop()
subclasses should override to provide any specific stop logic |
Methods inherited from class org.jboss.remoting.AbstractInvoker |
addClientLocator, getClassLoader, getClientLocator, getLocator, getSerializationType, setClassLoader, setSerializationType |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.jboss.remoting.ServerInvokerMBean |
isTransportBiDirectional |
Field Detail |
public static final java.lang.String MAX_NUM_ONEWAY_THREADS_KEY
public static final java.lang.String ONEWAY_THREAD_POOL_CLASS_KEY
public static final java.lang.String SERVER_BIND_ADDRESS_KEY
public static final java.lang.String CLIENT_CONNECT_ADDRESS_KEY
public static final java.lang.String SERVER_BIND_PORT_KEY
public static final java.lang.String CLIENT_CONNECT_PORT_KEY
public static final java.lang.String CLIENT_LEASE_PERIOD
public static final java.lang.String TIMEOUT
public static final java.lang.String SERVER_SOCKET_FACTORY
public static final int MAX_NUM_ONEWAY_THREADS
public static final int DEFAULT_CLIENT_LEASE_PERIOD
protected java.util.Map handlers
protected java.util.Map callbackHandlers
protected java.util.Map clientCallbackListener
Constructor Detail |
public ServerInvoker(InvokerLocator locator)
public ServerInvoker(InvokerLocator locator, java.util.Map configuration)
Method Detail |
protected void setup() throws java.lang.Exception
java.lang.Exception
public void setServerSocketFactory(javax.net.ServerSocketFactory serverSocketFactory)
public javax.net.ServerSocketFactory getServerSocketFactory()
protected javax.net.ServerSocketFactory createServerSocketFactory() throws java.io.IOException
java.io.IOException
protected javax.net.ServerSocketFactory getDefaultServerSocketFactory()
public void setTimeout(int timeout)
setTimeout
in interface ServerInvokerMBean
public int getTimeout()
getTimeout
in interface ServerInvokerMBean
public void addConnectionListener(ConnectionListener listener)
public void removeConnectionListener(ConnectionListener listener)
public void setLeasePeriod(long leasePeriodValue)
public long getLeasePeriod()
public java.lang.String getClientConnectAddress()
getClientConnectAddress
in interface ServerInvokerMBean
public int getClientConnectPort()
getClientConnectPort
in interface ServerInvokerMBean
public void setClientConnectPort(int clientConnectPort)
setClientConnectPort
in interface ServerInvokerMBean
public void setClientConnectAddress(java.lang.String clientConnectAddress)
setClientConnectAddress
in interface ServerInvokerMBean
public java.lang.String getServerBindAddress()
getServerBindAddress
in interface ServerInvokerMBean
public int getServerBindPort()
getServerBindPort
in interface ServerInvokerMBean
public void setMaxNumberOfOnewayThreads(int numOfThreads)
public int getMaxNumberOfOnewayThreads()
public org.jboss.util.threadpool.ThreadPool getOnewayThreadPool()
public void setOnewayThreadPool(org.jboss.util.threadpool.ThreadPool pool)
public javax.management.MBeanServer getMBeanServer()
public void setMBeanServer(javax.management.MBeanServer server)
public boolean hasInvocationHandler(java.lang.String subsystem)
subsystem
-
public java.lang.String[] getSupportedSubsystems()
public ServerInvocationHandler[] getInvocationHandlers()
public ServerInvocationHandler addInvocationHandler(java.lang.String subsystem, ServerInvocationHandler handler)
subsystem
- handler
-
public ServerInvocationHandler removeInvocationHandler(java.lang.String subsystem)
subsystem
- public ServerInvocationHandler getInvocationHandler(java.lang.String subsystem)
subsystem
-
public java.lang.Object invoke(java.lang.Object invoke) throws java.io.IOException
java.io.IOException
public java.lang.String getDataType()
getDataType
in interface ServerInvokerMBean
protected abstract java.lang.String getDefaultDataType()
public java.lang.Object invoke(InvocationRequest invocation) throws java.lang.Throwable
invocation
-
java.lang.Throwable
protected void preProcess(java.lang.String sessionId, ClassBytes arg, java.util.Map payload, InvokerLocator locator)
sessionId
- payload
- locator
- protected void postProcess(java.lang.String sessionId, java.lang.Object param, java.util.Map payload, InvokerLocator locator)
sessionId
- payload
- locator
- public void create()
create
in interface ServerInvokerMBean
public void start() throws java.io.IOException
start
in interface ServerInvokerMBean
java.io.IOException
public boolean isStarted()
isStarted
in interface ServerInvokerMBean
public void stop()
stop
in interface ServerInvokerMBean
public void destroy()
destroy
in interface ServerInvokerMBean
public void setConfiguration(java.util.Map configuration)
setConfiguration
in interface ServerInvokerMBean
configuration
- public java.util.Map getConfiguration()
getConfiguration
in interface ServerInvokerMBean
public java.lang.String getMBeanObjectName()
public void removeCallbackListener(java.lang.String subsystem, InvokerCallbackHandler callbackHandler)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |