|
| |
|
| java.lang.Object
 org.objectweb.jonas.discovery.DiscoveryComm
All known Subclasses: org.objectweb.jonas.discovery.DiscoveryGreetingResponder,
| RECEIVE_BUFFER_SIZE | | final public static int RECEIVE_BUFFER_SIZE(Code) | | Size of buffer to read incoming packets into.
|
| domainName | | protected String domainName(Code) | | Domain name that this instance belongs to.
|
| jonasName | | protected String jonasName(Code) | | Name for this jonas instance.
|
| multicastSocket | | protected MulticastSocket multicastSocket(Code) | | Used to multicast a discovery event on run() execution
|
| notStopped | | protected boolean notStopped(Code) | | Set to false if the thread is stopped
|
| serverId | | protected String serverId(Code) | | The server ID of the jonas instance.
|
| unicastSocket | | protected DatagramSocket unicastSocket(Code) | | Uset to send a discovery event as response to a discovey message
|
| urls | | protected String[] urls(Code) | | MBean server connection URLs for this server.
|
| DiscoveryComm | | public DiscoveryComm(DiscoveryManager dm)(Code) | | Constructs a DiscoveryComm associated to the DiscoveryManager
Parameters:
dm - DiscoveryManager to which this thread is associated |
| createNotifMessage | | public DiscEvent createNotifMessage(String state) throws Exception(Code) | | Create a discovery event to notify about a state change of the
event sender
Parameters:
state - - RUNNING if the sender notifies that it gets running- STOPPING if the sender notifies that it stops running a Discovery event (notification)
throws:
Exception - is thrown if the jmx service is not reached. |
| getDatagram | | protected DatagramPacket getDatagram(int length)(Code) | | Construct a new datagram.
Parameters:
length - packets length to be received the created datagram |
| join | | protected void join()(Code) | | Creates a MulticastSocket and joins the group of multicas host
identified by the InetAddress destAddress
|
| sendNotif | | public void sendNotif(DiscMessage msg)(Code) | | sends (multicasts) a Discovery Message to the group.
Parameters:
msg - The message to send. |
| sendResponse | | protected void sendResponse(DiscMessage msg, InetAddress destAddress, int port)(Code) | | Send response to a DiscoveryMessage
Parameters:
msg - Containes a DiscoveryMessage allowing to inform about the responder(name, state, URLs)
Parameters:
destAddress - the destination address picked up from the request
Parameters:
port - the destination port picked up from the request |
| setDomainName | | protected void setDomainName(String domainName)(Code) | |
Parameters:
domainName - The domainName to set. |
| setJonasName | | protected void setJonasName(String jonasName)(Code) | |
Parameters:
jonasName - The jonasName to set. |
| setUrls | | protected void setUrls(String[] urls)(Code) | |
Parameters:
urls - The urls to set. |
| stop | | public void stop()(Code) | | sends a notification message to notify that the server is stopping.
|
|
|
|