Package io.smallrye.reactive.messaging.providers.impl

Class ConnectorFactories

java.lang.Object
io.smallrye.reactive.messaging.providers.impl.ConnectorFactories
@ApplicationScoped public class ConnectorFactories extends Object

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    ConnectorFactories()
     
     
    ConnectorFactories(jakarta.enterprise.inject.Instance<io.smallrye.reactive.messaging.connector.InboundConnector> inc, jakarta.enterprise.inject.Instance<org.eclipse.microprofile.reactive.messaging.spi.IncomingConnectorFactory> incFactories, jakarta.enterprise.inject.Instance<io.smallrye.reactive.messaging.connector.OutboundConnector> out, jakarta.enterprise.inject.Instance<org.eclipse.microprofile.reactive.messaging.spi.OutgoingConnectorFactory> outFactories, jakarta.enterprise.inject.spi.BeanManager beanManager)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    Map<String,io.smallrye.reactive.messaging.connector.InboundConnector>
    getInboundConnectors()
     
    Map<String,io.smallrye.reactive.messaging.connector.OutboundConnector>
    getOutboundConnectors()
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ConnectorFactories

      protected ConnectorFactories()

    • ConnectorFactories

      @Inject public ConnectorFactories(@Any jakarta.enterprise.inject.Instance<io.smallrye.reactive.messaging.connector.InboundConnector> inc, @Any jakarta.enterprise.inject.Instance<org.eclipse.microprofile.reactive.messaging.spi.IncomingConnectorFactory> incFactories, @Any jakarta.enterprise.inject.Instance<io.smallrye.reactive.messaging.connector.OutboundConnector> out, @Any jakarta.enterprise.inject.Instance<org.eclipse.microprofile.reactive.messaging.spi.OutgoingConnectorFactory> outFactories, jakarta.enterprise.inject.spi.BeanManager beanManager)

  • Method Details

    • getInboundConnectors

      public Map<String,io.smallrye.reactive.messaging.connector.InboundConnector> getInboundConnectors()

    • getOutboundConnectors

      public Map<String,io.smallrye.reactive.messaging.connector.OutboundConnector> getOutboundConnectors()