com.prosysopc.ua.pubsub

Class PubSubSystemOverrides

java.lang.Object

com.prosysopc.ua.pubsub.PubSubSystemOverrides

public final class PubSubSystemOverrides
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PubSubSystemOverrides.Builder Builder for PubSubSystemOverrides.

Method Summary

Modifier and Type	Method and Description
static PubSubSystemOverrides.Builder	builder() Returns a new PubSubSystemOverrides.Builder that can be used to construct instances of this class
boolean	equals(Object obj)
PubSubFunction<PubSubBrokerAuthConf,PubSubBrokerCredentials>	getAuthConfToCredentialsResolver() A function to resolve PubSubBrokerAuthConf to the actual credentials that can be used.
Integer	getMaxDataSetMetaDataCount() Maximum amount of DataSetMetaDatas to keep.
Supplier<PubSubMqttProviderConf>	getMqttProviderConf() A temporary solution to pass MQTT credentials and other relavant information.
PubSubBiFunction<PubSubBrokerConnectionConf<?,?>,PubSubBrokerCredentials,PubSubMqttProviderConf>	getMqttProviderConfProvider() A temporary solution to resolve MqttProviderConf.
Boolean	getStoreReceivedDataSetMetaDatasInConf() Configures (if Boolean.TRUE are received DataSetMetaDatas stored in the PubSubSystemConf or not.
PubSubBiFunction<PubSubUdpUadpConnectionConf,PubSubUDPSocketKind,PubSubDatagramChannelWrapper>	getUdpSocketProvider() Allows overriding DatagramChannel used in PubSub UDP via returning custom PubSubDatagramChannelWrapper.
int	hashCode()
PubSubSystemOverrides.Builder	toBuilder() Returns a new PubSubSystemOverrides.Builder that is initialized with the state of this object.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

getAuthConfToCredentialsResolver

public PubSubFunction<PubSubBrokerAuthConf,PubSubBrokerCredentials> getAuthConfToCredentialsResolver()

A function to resolve PubSubBrokerAuthConf to the actual credentials that can be used.

getMaxDataSetMetaDataCount

public Integer getMaxDataSetMetaDataCount()

Maximum amount of DataSetMetaDatas to keep. Depending on the value of getStoreReceivedDataSetMetaDatasInConf(), either the PubSubSystemConf.getDataSetMetaDatas() or internal storage is limited, i.e. only getMaxDataSetMetaDataCount() amount of metadatas are kept, any new received is skipped.

Note that if the PubSubSystemConf at startup contained more than getMaxDataSetMetaDataCount(), it is not truncated.

getMqttProviderConf

public Supplier<PubSubMqttProviderConf> getMqttProviderConf()

A temporary solution to pass MQTT credentials and other relavant information.

getMqttProviderConfProvider

public PubSubBiFunction<PubSubBrokerConnectionConf<?,?>,PubSubBrokerCredentials,PubSubMqttProviderConf> getMqttProviderConfProvider()

A temporary solution to resolve MqttProviderConf. The given PubSubBrokerConnectionConf is either PubSubMqttJsonConnectionConf or PubSubMqttUadpConnectionConf.

getStoreReceivedDataSetMetaDatasInConf

public Boolean getStoreReceivedDataSetMetaDatasInConf()

Configures (if Boolean.TRUE are received DataSetMetaDatas stored in the PubSubSystemConf or not. By default false and received metadatas are only stored in memory. Regardless of this configuration getMaxDataSetMetaDataCount() configures the total maximum (conf+received).

getUdpSocketProvider

public PubSubBiFunction<PubSubUdpUadpConnectionConf,PubSubUDPSocketKind,PubSubDatagramChannelWrapper> getUdpSocketProvider()

Allows overriding DatagramChannel used in PubSub UDP via returning custom PubSubDatagramChannelWrapper.

builder

public static PubSubSystemOverrides.Builder builder()

Returns a new PubSubSystemOverrides.Builder that can be used to construct instances of this class

toBuilder

public PubSubSystemOverrides.Builder toBuilder()

Returns a new PubSubSystemOverrides.Builder that is initialized with the state of this object.

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object