@ApplicationScoped public class KafkaRegistryConfiguration extends Object
Constructor and Description |
---|
KafkaRegistryConfiguration() |
Modifier and Type | Method and Description |
---|---|
void |
destroy(io.quarkus.runtime.ShutdownEvent event,
ConsumerActions.DynamicAssignment<Cmmn.UUID,Str.StorageValue> container) |
void |
init(io.quarkus.runtime.StartupEvent event,
ConsumerActions.DynamicAssignment<Cmmn.UUID,Str.StorageValue> container) |
Properties |
properties(javax.enterprise.inject.spi.InjectionPoint ip) |
ConsumerActions.DynamicAssignment<Cmmn.UUID,Str.StorageValue> |
registryContainer(Properties registryProperties,
Properties snapshotProperties,
KafkaRegistryStorageHandle handle) |
ProducerActions<Long,StorageSnapshot> |
snapshotProducer(Properties properties) |
void |
stopSnapshotProducer(ProducerActions<Long,StorageSnapshot> producer) |
void |
stopStorageProducer(ProducerActions<Cmmn.UUID,Str.StorageValue> producer) |
ProducerActions<Cmmn.UUID,Str.StorageValue> |
storageProducer(Properties properties) |
@Produces public Properties properties(javax.enterprise.inject.spi.InjectionPoint ip)
@Produces @ApplicationScoped public ProducerActions<Long,StorageSnapshot> snapshotProducer(Properties properties)
public void stopSnapshotProducer(@Disposes ProducerActions<Long,StorageSnapshot> producer) throws Exception
Exception
@Produces @ApplicationScoped public ProducerActions<Cmmn.UUID,Str.StorageValue> storageProducer(Properties properties)
public void stopStorageProducer(@Disposes ProducerActions<Cmmn.UUID,Str.StorageValue> producer) throws Exception
Exception
@Produces @ApplicationScoped public ConsumerActions.DynamicAssignment<Cmmn.UUID,Str.StorageValue> registryContainer(Properties registryProperties, Properties snapshotProperties, KafkaRegistryStorageHandle handle)
public void init(@Observes io.quarkus.runtime.StartupEvent event, ConsumerActions.DynamicAssignment<Cmmn.UUID,Str.StorageValue> container)
public void destroy(@Observes io.quarkus.runtime.ShutdownEvent event, ConsumerActions.DynamicAssignment<Cmmn.UUID,Str.StorageValue> container)
Copyright © 2019 Red Hat. All rights reserved.