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