org.apache.flink.statefun.flink.core.reqreply

Interface RequestReplyClientFactory

All Known Implementing Classes:

DefaultHttpRequestReplyClientFactory, NettyRequestReplyClientFactory

@PublicEvolving
public interface RequestReplyClientFactory

Method Summary

Modifier and Type	Method and Description
void	cleanup()
RequestReplyClient	createTransportClient(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ObjectNode transportProperties, java.net.URI endpointUrl)

Method Detail

createTransportClient

RequestReplyClient createTransportClient(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ObjectNode transportProperties,
                                         java.net.URI endpointUrl)

cleanup

void cleanup()