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, unwrap
public 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 ConnectionFactory
getConnection
in class MulticastConnectionFactory
uri
- 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.Exception
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception