Class LegacyEmitterFactoryImpl

java.lang.Object
io.smallrye.reactive.messaging.providers.extension.LegacyEmitterFactoryImpl
All Implemented Interfaces:
io.smallrye.reactive.messaging.EmitterFactory<LegacyEmitterImpl<Object>>

@ApplicationScoped public class LegacyEmitterFactoryImpl extends Object implements io.smallrye.reactive.messaging.EmitterFactory<LegacyEmitterImpl<Object>>
  • Constructor Details

    • LegacyEmitterFactoryImpl

      public LegacyEmitterFactoryImpl()
  • Method Details

    • createEmitter

      public LegacyEmitterImpl<Object> createEmitter(io.smallrye.reactive.messaging.EmitterConfiguration configuration, long defaultBufferSize)
      Specified by:
      createEmitter in interface io.smallrye.reactive.messaging.EmitterFactory<LegacyEmitterImpl<Object>>