akka.persistence.multidc.internal

Class NotificationSettings

java.lang.Object

akka.persistence.multidc.internal.NotificationSettings

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product

public final class NotificationSettings
extends java.lang.Object
implements scala.Product, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description

NotificationSettings(scala.concurrent.duration.FiniteDuration readInterval, scala.concurrent.duration.FiniteDuration writeInterval, int writeAggregationSize, int maxBacktrackingBuckets, scala.concurrent.duration.FiniteDuration publishDelay, scala.concurrent.duration.FiniteDuration additionalRandomPublishDelay, scala.Option<java.lang.String> keyspace, scala.Option<java.lang.String> replicationStrategy, java.lang.String table, akka.persistence.cassandra.compaction.CassandraCompactionStrategy compactionStrategy, long gcGraceSeconds, long ttl, com.datastax.driver.core.ConsistencyLevel readConsistency, com.datastax.driver.core.ConsistencyLevel writeConsistency, int readRetries, int writeRetries, int fetchSize)

Method Summary

Modifier and Type	Method and Description
scala.concurrent.duration.FiniteDuration	additionalRandomPublishDelay()
static NotificationSettings	apply(scala.concurrent.duration.FiniteDuration readInterval, scala.concurrent.duration.FiniteDuration writeInterval, int writeAggregationSize, int maxBacktrackingBuckets, scala.concurrent.duration.FiniteDuration publishDelay, scala.concurrent.duration.FiniteDuration additionalRandomPublishDelay, scala.Option<java.lang.String> keyspace, scala.Option<java.lang.String> replicationStrategy, java.lang.String table, akka.persistence.cassandra.compaction.CassandraCompactionStrategy compactionStrategy, long gcGraceSeconds, long ttl, com.datastax.driver.core.ConsistencyLevel readConsistency, com.datastax.driver.core.ConsistencyLevel writeConsistency, int readRetries, int writeRetries, int fetchSize)
boolean	canEqual(java.lang.Object x$1)
akka.persistence.cassandra.compaction.CassandraCompactionStrategy	compactionStrategy()
NotificationSettings	copy(scala.concurrent.duration.FiniteDuration readInterval, scala.concurrent.duration.FiniteDuration writeInterval, int writeAggregationSize, int maxBacktrackingBuckets, scala.concurrent.duration.FiniteDuration publishDelay, scala.concurrent.duration.FiniteDuration additionalRandomPublishDelay, scala.Option<java.lang.String> keyspace, scala.Option<java.lang.String> replicationStrategy, java.lang.String table, akka.persistence.cassandra.compaction.CassandraCompactionStrategy compactionStrategy, long gcGraceSeconds, long ttl, com.datastax.driver.core.ConsistencyLevel readConsistency, com.datastax.driver.core.ConsistencyLevel writeConsistency, int readRetries, int writeRetries, int fetchSize)
scala.concurrent.duration.FiniteDuration	copy$default$1()
akka.persistence.cassandra.compaction.CassandraCompactionStrategy	copy$default$10()
long	copy$default$11()
long	copy$default$12()
com.datastax.driver.core.ConsistencyLevel	copy$default$13()
com.datastax.driver.core.ConsistencyLevel	copy$default$14()
int	copy$default$15()
int	copy$default$16()
int	copy$default$17()
scala.concurrent.duration.FiniteDuration	copy$default$2()
int	copy$default$3()
int	copy$default$4()
scala.concurrent.duration.FiniteDuration	copy$default$5()
scala.concurrent.duration.FiniteDuration	copy$default$6()
scala.Option<java.lang.String>	copy$default$7()
scala.Option<java.lang.String>	copy$default$8()
java.lang.String	copy$default$9()
boolean	equals(java.lang.Object x$1)
int	fetchSize()
long	gcGraceSeconds()
int	hashCode()
scala.Option<java.lang.String>	keyspace()
int	maxBacktrackingBuckets()
int	productArity()
java.lang.Object	productElement(int x$1)
scala.collection.Iterator<java.lang.Object>	productIterator()
java.lang.String	productPrefix()
scala.concurrent.duration.FiniteDuration	publishDelay()
com.datastax.driver.core.ConsistencyLevel	readConsistency()
scala.concurrent.duration.FiniteDuration	readInterval()
int	readRetries()
scala.Option<java.lang.String>	replicationStrategy()
java.lang.String	table()
java.lang.String	toString()
long	ttl()
static scala.Option<scala.Tuple17<scala.concurrent.duration.FiniteDuration,scala.concurrent.duration.FiniteDuration,java.lang.Object,java.lang.Object,scala.concurrent.duration.FiniteDuration,scala.concurrent.duration.FiniteDuration,scala.Option<java.lang.String>,scala.Option<java.lang.String>,java.lang.String,akka.persistence.cassandra.compaction.CassandraCompactionStrategy,java.lang.Object,java.lang.Object,com.datastax.driver.core.ConsistencyLevel,com.datastax.driver.core.ConsistencyLevel,java.lang.Object,java.lang.Object,java.lang.Object>>	unapply(NotificationSettings x$0)
int	writeAggregationSize()
com.datastax.driver.core.ConsistencyLevel	writeConsistency()
scala.concurrent.duration.FiniteDuration	writeInterval()
int	writeRetries()

Methods inherited from class java.lang.Object

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

Constructor Detail

NotificationSettings

public NotificationSettings(scala.concurrent.duration.FiniteDuration readInterval,
                            scala.concurrent.duration.FiniteDuration writeInterval,
                            int writeAggregationSize,
                            int maxBacktrackingBuckets,
                            scala.concurrent.duration.FiniteDuration publishDelay,
                            scala.concurrent.duration.FiniteDuration additionalRandomPublishDelay,
                            scala.Option<java.lang.String> keyspace,
                            scala.Option<java.lang.String> replicationStrategy,
                            java.lang.String table,
                            akka.persistence.cassandra.compaction.CassandraCompactionStrategy compactionStrategy,
                            long gcGraceSeconds,
                            long ttl,
                            com.datastax.driver.core.ConsistencyLevel readConsistency,
                            com.datastax.driver.core.ConsistencyLevel writeConsistency,
                            int readRetries,
                            int writeRetries,
                            int fetchSize)

Method Detail

apply

public static NotificationSettings apply(scala.concurrent.duration.FiniteDuration readInterval,
                                         scala.concurrent.duration.FiniteDuration writeInterval,
                                         int writeAggregationSize,
                                         int maxBacktrackingBuckets,
                                         scala.concurrent.duration.FiniteDuration publishDelay,
                                         scala.concurrent.duration.FiniteDuration additionalRandomPublishDelay,
                                         scala.Option<java.lang.String> keyspace,
                                         scala.Option<java.lang.String> replicationStrategy,
                                         java.lang.String table,
                                         akka.persistence.cassandra.compaction.CassandraCompactionStrategy compactionStrategy,
                                         long gcGraceSeconds,
                                         long ttl,
                                         com.datastax.driver.core.ConsistencyLevel readConsistency,
                                         com.datastax.driver.core.ConsistencyLevel writeConsistency,
                                         int readRetries,
                                         int writeRetries,
                                         int fetchSize)

unapply

public static scala.Option<scala.Tuple17<scala.concurrent.duration.FiniteDuration,scala.concurrent.duration.FiniteDuration,java.lang.Object,java.lang.Object,scala.concurrent.duration.FiniteDuration,scala.concurrent.duration.FiniteDuration,scala.Option<java.lang.String>,scala.Option<java.lang.String>,java.lang.String,akka.persistence.cassandra.compaction.CassandraCompactionStrategy,java.lang.Object,java.lang.Object,com.datastax.driver.core.ConsistencyLevel,com.datastax.driver.core.ConsistencyLevel,java.lang.Object,java.lang.Object,java.lang.Object>> unapply(NotificationSettings x$0)

readInterval

public scala.concurrent.duration.FiniteDuration readInterval()

writeInterval

public scala.concurrent.duration.FiniteDuration writeInterval()

writeAggregationSize

public int writeAggregationSize()

maxBacktrackingBuckets

public int maxBacktrackingBuckets()

publishDelay

public scala.concurrent.duration.FiniteDuration publishDelay()

additionalRandomPublishDelay

public scala.concurrent.duration.FiniteDuration additionalRandomPublishDelay()

keyspace

public scala.Option<java.lang.String> keyspace()

replicationStrategy

public scala.Option<java.lang.String> replicationStrategy()

table

public java.lang.String table()

compactionStrategy

public akka.persistence.cassandra.compaction.CassandraCompactionStrategy compactionStrategy()

gcGraceSeconds

public long gcGraceSeconds()

ttl

public long ttl()

readConsistency

public com.datastax.driver.core.ConsistencyLevel readConsistency()

writeConsistency

public com.datastax.driver.core.ConsistencyLevel writeConsistency()

readRetries

public int readRetries()

writeRetries

public int writeRetries()

fetchSize

public int fetchSize()

copy

public NotificationSettings copy(scala.concurrent.duration.FiniteDuration readInterval,
                                 scala.concurrent.duration.FiniteDuration writeInterval,
                                 int writeAggregationSize,
                                 int maxBacktrackingBuckets,
                                 scala.concurrent.duration.FiniteDuration publishDelay,
                                 scala.concurrent.duration.FiniteDuration additionalRandomPublishDelay,
                                 scala.Option<java.lang.String> keyspace,
                                 scala.Option<java.lang.String> replicationStrategy,
                                 java.lang.String table,
                                 akka.persistence.cassandra.compaction.CassandraCompactionStrategy compactionStrategy,
                                 long gcGraceSeconds,
                                 long ttl,
                                 com.datastax.driver.core.ConsistencyLevel readConsistency,
                                 com.datastax.driver.core.ConsistencyLevel writeConsistency,
                                 int readRetries,
                                 int writeRetries,
                                 int fetchSize)

copy$default$1

public scala.concurrent.duration.FiniteDuration copy$default$1()

copy$default$2

public scala.concurrent.duration.FiniteDuration copy$default$2()

copy$default$3

public int copy$default$3()

copy$default$4

public int copy$default$4()

copy$default$5

public scala.concurrent.duration.FiniteDuration copy$default$5()

copy$default$6

public scala.concurrent.duration.FiniteDuration copy$default$6()

copy$default$7

public scala.Option<java.lang.String> copy$default$7()

copy$default$8

public scala.Option<java.lang.String> copy$default$8()

copy$default$9

public java.lang.String copy$default$9()

copy$default$10

public akka.persistence.cassandra.compaction.CassandraCompactionStrategy copy$default$10()

copy$default$11

public long copy$default$11()

copy$default$12

public long copy$default$12()

copy$default$13

public com.datastax.driver.core.ConsistencyLevel copy$default$13()

copy$default$14

public com.datastax.driver.core.ConsistencyLevel copy$default$14()

copy$default$15

public int copy$default$15()

copy$default$16

public int copy$default$16()

copy$default$17

public int copy$default$17()

productPrefix

public java.lang.String productPrefix()

Specified by:

productPrefix in interface scala.Product

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

productElement

public java.lang.Object productElement(int x$1)

Specified by:

productElement in interface scala.Product

productIterator

public scala.collection.Iterator<java.lang.Object> productIterator()

Specified by:

productIterator in interface scala.Product

canEqual

public boolean canEqual(java.lang.Object x$1)

Specified by:

canEqual in interface scala.Equals

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object x$1)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class java.lang.Object