Package-level declarations
Types
Link copied to clipboard
Link copied to clipboard
data class ActorsNetConfig(val implementation: String = ActorNetType.Kafka.name, val kafka: KafkaActorNetConfig? = null, val artemis: ArtemisActorNetConfig? = null)
Link copied to clipboard
data class ArtemisActorNetConfig(val brokerUrl: String, val user: String? = null, val password: String? = null, val queuePrefix: String, val malformedMessagesDir: String, val confirmationWindowSize: Int, val producerWindowSize: Int, val consumerWindowSize: Int, val clientFailureCheckPeriodMs: Long = ActiveMQClient.DEFAULT_CLIENT_FAILURE_CHECK_PERIOD, val connectionTtlMs: Long = ActiveMQClient.DEFAULT_CONNECTION_TTL, val callTimeoutMs: Long = ActiveMQClient.DEFAULT_CALL_TIMEOUT, val callFailoverTimeoutMs: Long = ActiveMQClient.DEFAULT_CALL_FAILOVER_TIMEOUT, val retryIntervalMs: Long = ActiveMQClient.DEFAULT_RETRY_INTERVAL, val retryIntervalMultiplier: Double = ActiveMQClient.DEFAULT_RETRY_INTERVAL_MULTIPLIER, val maxRetryIntervalMs: Long = ActiveMQClient.DEFAULT_MAX_RETRY_INTERVAL, val reconnectAttempts: Int = ActiveMQClient.DEFAULT_RECONNECT_ATTEMPTS, val initialConnectAttempts: Int = ActiveMQClient.INITIAL_CONNECT_ATTEMPTS, val failoverAttempts: Int = ActiveMQClient.DEFAULT_FAILOVER_ATTEMPTS, val blockOnDurableSend: Boolean = ActiveMQClient.DEFAULT_BLOCK_ON_DURABLE_SEND, val blockOnNonDurableSend: Boolean = ActiveMQClient.DEFAULT_BLOCK_ON_NON_DURABLE_SEND, val blockOnAcknowledge: Boolean = ActiveMQClient.DEFAULT_BLOCK_ON_ACKNOWLEDGE, val onMessageCloseTimeoutMs: Int = ActiveMQClient.DEFAULT_ONMESSAGE_CLOSE_TIMEOUT)
Link copied to clipboard
data class KafkaActorNetConfig(val properties: String, val topicPrefix: String, val consumerConfig: KafkaConsumerConfig = KafkaConsumerConfig())