Interface Messaging.TransportFactory

All Known Implementing Classes:

AmqpTransport.Factory, KafkaTransport.Factory, PubSubTransport.Factory, RedisStreamTransport.Factory, SqsTransport.Factory

Enclosing class:

Messaging

public static interface Messaging.TransportFactory

Opens a broker transport for a URL of its scheme.

Method Summary

Modifier and Type	Method	Description
MessageTransport	open(String url, Config config, RetryPolicy retry)	Opens the transport url names; the caller closes it.

Method Details

open

MessageTransport open(String url,
 Config config,
 RetryPolicy retry)
               throws IOException

Opens the transport url names; the caller closes it.

Throws:

IOException