Package com.avoka.fc.core.stream

Class StreamConsumerFactory

java.lang.Object

com.avoka.fc.core.stream.StreamConsumerFactory

public class StreamConsumerFactory
extends Object

Provides a stream consumer factory which creates consumer based on service connection.

Since:

24.4.0

Constructor Summary

Constructors

Constructor	Description
StreamConsumerFactory()

Method Summary

Modifier and Type	Method	Description
static IStreamConsumer<?>	getConsumer(ServiceConnection serviceConnection)	Returns a consumer based on the service connection type.

Methods inherited from class java.lang.Object

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

Constructor Details

StreamConsumerFactory

public StreamConsumerFactory()

Method Details

getConsumer

public static IStreamConsumer<?> getConsumer(ServiceConnection serviceConnection)

Returns a consumer based on the service connection type.

Parameters:

serviceConnection - the service connection

Returns:

an instance of IStreamProducer

Throws:

ApplicationException - if no suitable consumer is found for the service connection