public class AMQPService extends Object
Modifier and Type | Field and Description |
---|---|
private static String |
address |
protected static AMQPService |
amqpService
The proxy reference (used to stop it).
|
static String |
BACKLOG_PROP
Name of the property that allow to fix the TCP BACKLOG property for the
client's connections.
|
static Vector<AMQPConnectionListener> |
connectionListeners
The thread listening to incoming
TCP connections.
|
static int |
DEFAULT_BACKLOG
Default value for the TCP BACKLOG property.
|
static String |
DEFAULT_BINDADDRESS |
static int |
DEFAULT_HEARTBEAT
Default value in seconds for the server heartbeat property.
|
static int |
DEFAULT_PORT
Default value for the TCP port of the listen socket.
|
static int |
heartbeat |
static String |
HEARTBEAT_PROP
Name of the property that allows to set the server requested heartbeat.
|
static org.objectweb.util.monolog.api.Logger |
logger |
static Naming |
naming |
private static int |
port |
private static ServerSocket |
serverSocket
The listening server socket
|
Constructor and Description |
---|
AMQPService() |
Modifier and Type | Method and Description |
---|---|
static void |
createConnectionListener() |
static String |
getListenAddress() |
static int |
getListenPort() |
static void |
init(String args,
boolean firstTime)
Initializes the TCP entry point by creating a server socket listening
to the specified port.
|
private static void |
loads() |
static void |
removeConnectionListener(AMQPConnectionListener cnxListener) |
protected void |
start() |
private void |
stop() |
static void |
stopService()
Stops the service.
|
public static org.objectweb.util.monolog.api.Logger logger
public static Naming naming
public static final int DEFAULT_HEARTBEAT
public static final String HEARTBEAT_PROP
public static final int DEFAULT_PORT
public static final String DEFAULT_BINDADDRESS
public static final int DEFAULT_BACKLOG
public static final String BACKLOG_PROP
public static int heartbeat
protected static AMQPService amqpService
private static int port
private static String address
private static ServerSocket serverSocket
public static Vector<AMQPConnectionListener> connectionListeners
public AMQPService() throws IOException
IOException
Exception
public static final int getListenPort()
public static final String getListenAddress()
public static void init(String args, boolean firstTime) throws Exception
args
- stringified listening portfirstTime
- true
when the agent server starts.Exception
private static void loads() throws TransactionException, IOException, ClassNotFoundException
public static void stopService()
protected void start()
private void stop()
public static void createConnectionListener() throws IOException
IOException
public static void removeConnectionListener(AMQPConnectionListener cnxListener)
Copyright © 2019 ScalAgent D.T.. All rights reserved.