org.jboss.jms.client.remoting
Class CallbackServerFactory

java.lang.Object
  org.jboss.jms.client.remoting.CallbackServerFactory

public class CallbackServerFactory

extends java.lang.Object

A CallbackServerFactory. We maintain only one callbackserver per transport per client VM. This is to avoid having too many resources e.g. server sockets in use on the client E.g. in the case of a socket transport, if we had one callbackserver per connection then we would have one server socket listening per connection, so we could run out of available ports with a lot of connections.

Version:

$Revision: 1573 $ $Id: CallbackServerFactory.java 1573 2006-11-17 04:17:38Z ron_sigal $

Author:

Tim Fox

Field Summary

static java.lang.String	CLIENT_HOST
static int	CLIENT_PORT
static CallbackServerFactory	instance
static java.lang.String	JMS_CALLBACK_SUBSYSTEM

Method Summary

boolean	containsCallbackServer(java.lang.String protocol)
Connector	getCallbackServer(InvokerLocator serverLocator)
protected Connector	startCallbackServer(InvokerLocator serverLocator)
void	stopCallbackServer(java.lang.String protocol)

Methods inherited from class java.lang.Object

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

Field Detail

JMS_CALLBACK_SUBSYSTEM

public static final java.lang.String JMS_CALLBACK_SUBSYSTEM

See Also:

Constant Field Values

CLIENT_HOST

public static final java.lang.String CLIENT_HOST

CLIENT_PORT

public static final int CLIENT_PORT

instance

public static CallbackServerFactory instance

Method Detail

containsCallbackServer

public boolean containsCallbackServer(java.lang.String protocol)

getCallbackServer

public Connector getCallbackServer(InvokerLocator serverLocator)
                            throws java.lang.Exception

Throws:

java.lang.Exception

stopCallbackServer

public void stopCallbackServer(java.lang.String protocol)

startCallbackServer

protected Connector startCallbackServer(InvokerLocator serverLocator)
                                 throws java.lang.Exception

Throws:

java.lang.Exception