Class KafkaTransport.Factory

java.lang.Object

com.codename1.backend.messaging.kafka.KafkaTransport.Factory

All Implemented Interfaces:

Messaging.TransportFactory

Enclosing class:

KafkaTransport

public static final class KafkaTransport.Factory
extends Object
implements Messaging.TransportFactory

Registers this transport with Messaging; the generated wiring does it.

Constructor Summary

Constructors

Constructor	Description
Factory()

Method Summary

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

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Factory

public Factory()

Method Details

open

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

Description copied from interface: Messaging.TransportFactory

Opens the transport url names; the caller closes it.

Specified by:

open in interface Messaging.TransportFactory

Throws:

IOException