Package | Description |
---|---|
org.apache.flink.streaming.connectors.rabbitmq | |
org.apache.flink.streaming.connectors.rabbitmq.common |
Constructor and Description |
---|
RMQSink(RMQConnectionConfig rmqConnectionConfig,
SerializationSchema<IN> schema,
RMQSinkPublishOptions<IN> publishOptions) |
RMQSink(RMQConnectionConfig rmqConnectionConfig,
SerializationSchema<IN> schema,
RMQSinkPublishOptions<IN> publishOptions,
SerializableReturnListener returnListener) |
RMQSink(RMQConnectionConfig rmqConnectionConfig,
String queueName,
SerializationSchema<IN> schema) |
RMQSource(RMQConnectionConfig rmqConnectionConfig,
String queueName,
boolean usesCorrelationId,
DeserializationSchema<OUT> deserializationSchema)
Creates a new RabbitMQ source.
|
RMQSource(RMQConnectionConfig rmqConnectionConfig,
String queueName,
boolean usesCorrelationId,
RMQDeserializationSchema<OUT> deliveryDeserializer)
Creates a new RabbitMQ source.
|
RMQSource(RMQConnectionConfig rmqConnectionConfig,
String queueName,
DeserializationSchema<OUT> deserializationSchema)
Creates a new RabbitMQ source with at-least-once message processing guarantee when
checkpointing is enabled.
|
RMQSource(RMQConnectionConfig rmqConnectionConfig,
String queueName,
RMQDeserializationSchema<OUT> deliveryDeserializer)
Creates a new RabbitMQ source with at-least-once message processing guarantee when
checkpointing is enabled.
|
Modifier and Type | Method and Description |
---|---|
RMQConnectionConfig |
RMQConnectionConfig.Builder.build()
The Builder method.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.