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 exampleportNamecould 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 Lookupapply(java.lang.String serviceName)Create a service Lookup with only a serviceName.static Lookupapply(java.lang.String serviceName, scala.Option<java.lang.String> portName, scala.Option<java.lang.String> protocol)Create a service Lookup withserviceName, optionalportNameand optionalprotocol.static booleancanEqual(java.lang.Object x$1)static Lookupcreate(java.lang.String serviceName)Java APIbooleandiscardCache()booleanequals(java.lang.Object obj)java.util.Optional<java.lang.String>getPortName()Java APIjava.util.Optional<java.lang.String>getProtocol()Java APIinthashCode()static booleanisValidSrv(java.lang.String srv)Returns true if passed string conforms with SRV format.static LookupparseSrv(java.lang.String str)Create a service Lookup from a string with format: _portName._protocol.serviceName.scala.Option<java.lang.String>portName()static intproductArity()static java.lang.ObjectproductElement(int x$1)static java.lang.StringproductElementName(int n)static scala.collection.Iterator<java.lang.String>productElementNames()static scala.collection.Iterator<java.lang.Object>productIterator()static java.lang.StringproductPrefix()scala.Option<java.lang.String>protocol()java.lang.StringserviceName()java.lang.StringtoString()LookupwithDiscardCache()Ask the discovery implementation to drop any cached result and do a new resolution.LookupwithPortName(java.lang.String value)Which port for a service e.g.LookupwithProtocol(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, optionalportNameand 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:
toStringin classjava.lang.Object
-
equals
public boolean equals(java.lang.Object obj)
- Overrides:
equalsin classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCodein classjava.lang.Object
-
-