public class MulticastPulseClient extends MulticastConnectionFactory
MulticastConnectionFactory.Filter, MulticastConnectionFactory.URIs| Modifier and Type | Field and Description | 
|---|---|
static java.lang.String | 
ORG_APACHE_OPENEJB_MULTIPULSE_TTL  | 
static java.lang.String | 
ORG_APACHE_OPENEJB_MULTIPULSE_URI_LIMIT  | 
| Constructor and Description | 
|---|
MulticastPulseClient()  | 
| Modifier and Type | Method and Description | 
|---|---|
static java.util.Set<java.net.URI> | 
discoverURIs(java.lang.String forGroup,
            java.util.Set<java.lang.String> schemes,
            java.lang.String host,
            int port,
            long timeout)
Get a list of URIs discovered for the provided request. 
 | 
Connection | 
getConnection(java.net.URI uri)  | 
static java.net.MulticastSocket[] | 
getSockets(java.net.InetAddress ia,
          int port)  | 
static boolean | 
isLocalAddress(java.lang.String host,
              boolean wildcardIsLocal)
Is the provided host a local host 
 | 
static void | 
main(java.lang.String[] args)  | 
getDefaultSchemes, getLong, getSet, getString, unwrappublic static final java.lang.String ORG_APACHE_OPENEJB_MULTIPULSE_TTL
public static final java.lang.String ORG_APACHE_OPENEJB_MULTIPULSE_URI_LIMIT
public Connection getConnection(java.net.URI uri) throws java.io.IOException
getConnection in interface ConnectionFactorygetConnection in class MulticastConnectionFactoryuri - Connection URIjava.io.IOException - or errorjava.lang.IllegalArgumentException - On undefined errorpublic static java.util.Set<java.net.URI> discoverURIs(java.lang.String forGroup,
                                                       java.util.Set<java.lang.String> schemes,
                                                       java.lang.String host,
                                                       int port,
                                                       long timeout)
                                                throws java.lang.Exception
forGroup - Specific case sensitive group name or * for allschemes - Acceptable scheme listhost - Multicast host addressport - Multicast porttimeout - Time to wait for a server response, at least 50msjava.lang.Exception - On errorpublic static boolean isLocalAddress(java.lang.String host,
                                     boolean wildcardIsLocal)
host - The host to testwildcardIsLocal - Should 0.0.0.0 or [::] be deemed as localpublic static java.net.MulticastSocket[] getSockets(java.net.InetAddress ia,
                                                    int port)
                                             throws java.lang.Exception
java.lang.Exceptionpublic static void main(java.lang.String[] args)
                 throws java.lang.Exception
java.lang.Exception