public class ImcTcpTransport
extends java.lang.Object
Constructor and Description |
---|
ImcTcpTransport(int bindPort,
pt.lsts.imc.IMCDefinition imcDefinition) |
Modifier and Type | Method and Description |
---|---|
boolean |
addListener(pt.lsts.neptus.messages.listener.MessageListener<pt.lsts.neptus.messages.listener.MessageInfo,pt.lsts.imc.IMCMessage> listener) |
long |
getActiveNumberOfConnections() |
int |
getBindPort() |
TCPTransport |
getTcpTransport() |
boolean |
isConnectionEstablished(java.lang.String host,
int port) |
boolean |
isOnBindError() |
boolean |
isRunning() |
boolean |
isRunningNormally() |
static void |
main(java.lang.String[] args) |
void |
purge() |
boolean |
removeListener(pt.lsts.neptus.messages.listener.MessageListener<pt.lsts.neptus.messages.listener.MessageInfo,pt.lsts.imc.IMCMessage> listener) |
void |
reStart() |
boolean |
sendMessage(java.lang.String destination,
int port,
pt.lsts.imc.IMCMessage message) |
boolean |
sendMessage(java.lang.String destination,
int port,
pt.lsts.imc.IMCMessage message,
MessageDeliveryListener deliveryListener) |
void |
setBindPort(int bindPort) |
void |
stop() |
public ImcTcpTransport(int bindPort, pt.lsts.imc.IMCDefinition imcDefinition)
public int getBindPort()
public void setBindPort(int bindPort)
bindPort
- the bindPort to setpublic boolean isRunning()
public boolean isRunningNormally()
public TCPTransport getTcpTransport()
public boolean addListener(pt.lsts.neptus.messages.listener.MessageListener<pt.lsts.neptus.messages.listener.MessageInfo,pt.lsts.imc.IMCMessage> listener)
listener
- public boolean removeListener(pt.lsts.neptus.messages.listener.MessageListener<pt.lsts.neptus.messages.listener.MessageInfo,pt.lsts.imc.IMCMessage> listener)
listener
- public boolean sendMessage(java.lang.String destination, int port, pt.lsts.imc.IMCMessage message)
destination
- port
- message
- public boolean sendMessage(java.lang.String destination, int port, pt.lsts.imc.IMCMessage message, MessageDeliveryListener deliveryListener)
destination
- port
- message
- deliveryListener
- public void stop()
public void purge()
public void reStart()
public boolean isOnBindError()
public long getActiveNumberOfConnections()
public boolean isConnectionEstablished(java.lang.String host, int port)
public static void main(java.lang.String[] args) throws java.lang.Exception
args
- MiddlewareException
java.lang.Exception
Copyright © 2004-2014 FEUP-LSTS and Neptus developers. All Rights Reserved.