Package akka.discovery
Class Lookup
- java.lang.Object
-
- akka.discovery.Lookup
-
- All Implemented Interfaces:
NoSerializationVerificationNeeded
public final class Lookup extends java.lang.Object implements NoSerializationVerificationNeeded
A service lookup. It is up to each method to decide what to do with the optional portName and protocol fields. For exampleportName
could be used to distinguish between Akka remoting ports and HTTP ports.param: serviceName must not be 'null' or an empty String param: discardCache Ask the discovery implementation to drop any cached result and do a new resolution. Optionally supported by implementations.
-
-
Constructor Summary
Constructors Constructor Description Lookup(java.lang.String serviceName, scala.Option<java.lang.String> portName, scala.Option<java.lang.String> protocol)
Lookup(java.lang.String serviceName, scala.Option<java.lang.String> portName, scala.Option<java.lang.String> protocol, boolean discardCache)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static Lookup
apply(java.lang.String serviceName)
Create a service Lookup with only a serviceName.static Lookup
apply(java.lang.String serviceName, scala.Option<java.lang.String> portName, scala.Option<java.lang.String> protocol)
Create a service Lookup withserviceName
, optionalportName
and optionalprotocol
.static boolean
canEqual(java.lang.Object x$1)
static Lookup
create(java.lang.String serviceName)
Java APIboolean
discardCache()
boolean
equals(java.lang.Object obj)
java.util.Optional<java.lang.String>
getPortName()
Java APIjava.util.Optional<java.lang.String>
getProtocol()
Java APIint
hashCode()
static boolean
isValidSrv(java.lang.String srv)
Returns true if passed string conforms with SRV format.static Lookup
parseSrv(java.lang.String str)
Create a service Lookup from a string with format: _portName._protocol.serviceName.scala.Option<java.lang.String>
portName()
static int
productArity()
static java.lang.Object
productElement(int x$1)
static java.lang.String
productElementName(int n)
static scala.collection.Iterator<java.lang.String>
productElementNames()
static scala.collection.Iterator<java.lang.Object>
productIterator()
static java.lang.String
productPrefix()
scala.Option<java.lang.String>
protocol()
java.lang.String
serviceName()
java.lang.String
toString()
Lookup
withDiscardCache()
Ask the discovery implementation to drop any cached result and do a new resolution.Lookup
withPortName(java.lang.String value)
Which port for a service e.g.Lookup
withProtocol(java.lang.String value)
Which protocol e.g.
-
-
-
Constructor Detail
-
Lookup
public Lookup(java.lang.String serviceName, scala.Option<java.lang.String> portName, scala.Option<java.lang.String> protocol, boolean discardCache)
-
Lookup
public Lookup(java.lang.String serviceName, scala.Option<java.lang.String> portName, scala.Option<java.lang.String> protocol)
-
-
Method Detail
-
apply
public static Lookup apply(java.lang.String serviceName)
Create a service Lookup with only a serviceName. Use withPortName and withProtocol to provide optional portName and protocol
-
apply
public static Lookup apply(java.lang.String serviceName, scala.Option<java.lang.String> portName, scala.Option<java.lang.String> protocol)
Create a service Lookup withserviceName
, optionalportName
and optionalprotocol
.
-
create
public static Lookup create(java.lang.String serviceName)
Java APICreate a service Lookup with only a serviceName. Use withPortName and withProtocol to provide optional portName and protocol
-
parseSrv
public static Lookup parseSrv(java.lang.String str)
Create a service Lookup from a string with format: _portName._protocol.serviceName. (as specified by https://www.ietf.org/rfc/rfc2782.txt)If the passed string conforms with this format, a SRV Lookup is returned. The serviceName part must be a valid domain name. (as defined in https://tools.ietf.org/html/rfc1034)
The string is parsed and dismembered to build a Lookup as following: Lookup(serviceName).withPortName(portName).withProtocol(protocol)
- Throws:
java.lang.NullPointerException
- If the passed string is nulljava.lang.IllegalArgumentException
- If the string doesn't not conform with the SRV format
-
isValidSrv
public static boolean isValidSrv(java.lang.String srv)
Returns true if passed string conforms with SRV format. Otherwise returns false.
-
productPrefix
public static java.lang.String productPrefix()
-
productArity
public static int productArity()
-
productElement
public static java.lang.Object productElement(int x$1)
-
productIterator
public static scala.collection.Iterator<java.lang.Object> productIterator()
-
canEqual
public static boolean canEqual(java.lang.Object x$1)
-
productElementName
public static java.lang.String productElementName(int n)
-
productElementNames
public static scala.collection.Iterator<java.lang.String> productElementNames()
-
serviceName
public java.lang.String serviceName()
-
portName
public scala.Option<java.lang.String> portName()
-
protocol
public scala.Option<java.lang.String> protocol()
-
discardCache
public boolean discardCache()
-
withPortName
public Lookup withPortName(java.lang.String value)
Which port for a service e.g. Akka remoting or HTTP. Maps to "service" for an SRV records.
-
withProtocol
public Lookup withProtocol(java.lang.String value)
Which protocol e.g. TCP or UDP. Maps to "protocol" for SRV records.
-
withDiscardCache
public Lookup withDiscardCache()
Ask the discovery implementation to drop any cached result and do a new resolution. Optionally supported by implementations.
-
getPortName
public java.util.Optional<java.lang.String> getPortName()
Java API
-
getProtocol
public java.util.Optional<java.lang.String> getProtocol()
Java API
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object obj)
- Overrides:
equals
in classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
-