Package | Description |
---|---|
org.apache.flink.streaming.connectors.rabbitmq.common |
Modifier and Type | Method and Description |
---|---|
RMQConnectionConfig.Builder |
RMQConnectionConfig.Builder.setAutomaticRecovery(boolean automaticRecovery)
Enables or disables automatic connection recovery.
|
RMQConnectionConfig.Builder |
RMQConnectionConfig.Builder.setConnectionTimeout(int connectionTimeout)
Set the connection timeout.
|
RMQConnectionConfig.Builder |
RMQConnectionConfig.Builder.setHost(String host) |
RMQConnectionConfig.Builder |
RMQConnectionConfig.Builder.setNetworkRecoveryInterval(int networkRecoveryInterval)
Sets connection recovery interval.
|
RMQConnectionConfig.Builder |
RMQConnectionConfig.Builder.setPassword(String password)
Set the password.
|
RMQConnectionConfig.Builder |
RMQConnectionConfig.Builder.setPort(int port)
Set the target port.
|
RMQConnectionConfig.Builder |
RMQConnectionConfig.Builder.setRequestedChannelMax(int requestedChannelMax)
Set the requested maximum channel number.
|
RMQConnectionConfig.Builder |
RMQConnectionConfig.Builder.setRequestedFrameMax(int requestedFrameMax)
Set the requested maximum frame size.
|
RMQConnectionConfig.Builder |
RMQConnectionConfig.Builder.setRequestedHeartbeat(int requestedHeartbeat)
Set the requested heartbeat.
|
RMQConnectionConfig.Builder |
RMQConnectionConfig.Builder.setTopologyRecoveryEnabled(boolean topologyRecovery)
Enables or disables topology recovery.
|
RMQConnectionConfig.Builder |
RMQConnectionConfig.Builder.setUri(String uri)
Convenience method for setting the fields in an AMQP URI: host,
port, username, password and virtual host.
|
RMQConnectionConfig.Builder |
RMQConnectionConfig.Builder.setUserName(String username)
Set the user name.
|
RMQConnectionConfig.Builder |
RMQConnectionConfig.Builder.setVirtualHost(String virtualHost)
Set the virtual host.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.