Interface PulsarContainerFactory<C,E>

Type Parameters:

C - message container

E - message listener endpoint

All Known Subinterfaces:

ListenerContainerFactory<C,E>, PulsarListenerContainerFactory, PulsarReaderContainerFactory, ReaderContainerFactory<C,E>

All Known Implementing Classes:

AbstractPulsarListenerContainerFactory, AbstractPulsarReaderContainerFactory, ConcurrentPulsarListenerContainerFactory, DefaultPulsarReaderContainerFactory

public interface PulsarContainerFactory<C,E>

Factory for Pulsar message listener containers.

Since:

1.2.0

Author:

Chris Bono

Method Summary

Modifier and Type	Method	Description
C	createContainer(String... topics)	Create and configure a container without a listener.
C	createRegisteredContainer(E endpoint)	Create a message listener container for the given endpoint.

Method Details

createRegisteredContainer

C createRegisteredContainer(E endpoint)

Create a message listener container for the given endpoint. Containers created using this method are added to the listener endpoint registry.

Parameters:

endpoint - the endpoint to configure

Returns:

the created container

createContainer

C createContainer(String... topics)

Create and configure a container without a listener. Containers created using this method are not added to the listener endpoint registry.

Parameters:

topics - the topics.

Returns:

the container.