Package io.smallrye.reactive.messaging.i18n

Interface ProviderLogging

  • All Superinterfaces:
    org.jboss.logging.BasicLogger
    All Known Implementing Classes:
    ProviderLogging_$logger
    @MessageLogger(projectCode="SRMSG",
               length=5)
public interface ProviderLogging
extends org.jboss.logging.BasicLogger

    • Method Detail

      • methodException

        @LogMessage(level=ERROR)
@Message(id=200,
         value="The method %s has thrown an exception")
void methodException​(String methodAsString,
                     @Cause
                     Throwable cause)

      • streamProcessingException

        @LogMessage(level=ERROR)
@Message(id=201,
         value="Error caught during the stream processing")
void streamProcessingException​(@Cause
                               Throwable cause)

      • vertXInstanceCreated

        @LogMessage(level=INFO)
@Message(id=202,
         value="Created new Vertx instance")
void vertXInstanceCreated()

      • workerPoolCreated

        @LogMessage(level=INFO)
@Message(id=203,
         value="Created worker pool named %s with concurrency of %d")
void workerPoolCreated​(String workerName,
                       Integer count)

      • multiplePublisherFound

        @LogMessage(level=WARN)
@Message(id=204,
         value="Multiple publisher found for %s, using the merge policy `ONE` takes the first found")
void multiplePublisherFound​(String source)

      • strictModeEnabled

        @LogMessage(level=DEBUG)
@Message(id=205,
         value="Strict mode enabled")
void strictModeEnabled()

      • scanningType

        @LogMessage(level=INFO)
@Message(id=206,
         value="Scanning Type: %s")
void scanningType​(Class javaClass)

      • cancelSubscriptions

        @LogMessage(level=INFO)
@Message(id=207,
         value="Cancel subscriptions")
void cancelSubscriptions()

      • deploymentDoneStartProcessing

        @LogMessage(level=INFO)
@Message(id=208,
         value="Deployment done... start processing")
void deploymentDoneStartProcessing()

      • initializingMediators

        @LogMessage(level=INFO)
@Message(id=209,
         value="Initializing mediators")
void initializingMediators()

      • initializingMethod

        @LogMessage(level=DEBUG)
@Message(id=210,
         value="Initializing %s")
void initializingMethod​(String methodAsString)

      • unableToCreateInvoker

        @LogMessage(level=ERROR)
@Message(id=211,
         value="Unable to create invoker instance of %s")
void unableToCreateInvoker​(Class invokerClass,
                           @Cause
                           Throwable t)

      • unableToInitializeMediator

        @LogMessage(level=ERROR)
@Message(id=212,
         value="Unable to initialize mediator: %s")
void unableToInitializeMediator​(String methodAsString,
                                @Cause
                                Throwable t)

      • registeringAsPublisher

        @LogMessage(level=DEBUG)
@Message(id=213,
         value="Registering %s as publisher %s")
void registeringAsPublisher​(String methodAsString,
                            String outgoing)

      • registeringAsSubscriber

        @LogMessage(level=DEBUG)
@Message(id=214,
         value="Registering %s as subscriber %s")
void registeringAsSubscriber​(String methodAsString,
                             List<String> list)

      • connectingMediators

        @LogMessage(level=INFO)
@Message(id=215,
         value="Connecting mediators")
void connectingMediators()

      • attemptToResolve

        @LogMessage(level=INFO)
@Message(id=216,
         value="Attempt to resolve %s")
void attemptToResolve​(String methodAsString)

      • connectingTo

        @LogMessage(level=INFO)
@Message(id=217,
         value="Connecting %s to `%s` (%s)")
void connectingTo​(String methodAsString,
                  List<String> list,
                  org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder publisher)

      • connectingTo

        @LogMessage(level=INFO)
@Message(id=218,
         value="Connecting %s to `%s`")
void connectingTo​(String methodAsString,
                  List<String> list)

      • impossibleToBindMediators

        @LogMessage(level=WARN)
@Message(id=219,
         value="Impossible to bind mediators, some mediators are not connected: %s \n Available publishers: %s \n Available emitters: %s")
void impossibleToBindMediators​(List<String> list,
                               Set<String> incomingNames,
                               Set<String> emitterNames)

      • connectingMethodToSink

        @LogMessage(level=INFO)
@Message(id=220,
         value="Connecting method %s to sink %s")
void connectingMethodToSink​(String methodAsString,
                            String name)

      • numberOfSubscribersConsumingStream

        @LogMessage(level=WARN)
@Message(id=221,
         value="%d subscribers consuming the stream %s")
void numberOfSubscribersConsumingStream​(int size,
                                        String name)

      • connectingEmitterToSink

        @LogMessage(level=INFO)
@Message(id=222,
         value="Connecting emitter to sink %s")
void connectingEmitterToSink​(String name)

      • mediatorCreated

        @LogMessage(level=DEBUG)
@Message(id=223,
         value="Mediator created for %s")
void mediatorCreated​(String methodAsString)

      • analyzingMediatorBean

        @LogMessage(level=INFO)
@Message(id=224,
         value="Analyzing mediator bean: %s")
void analyzingMediatorBean​(javax.enterprise.inject.spi.Bean<?> bean)

      • noSubscriberForChannelAttachedToEmitter

        @LogMessage(level=WARN)
@Message(id=225,
         value="No subscriber for channel %s  attached to the emitter %s.%s")
void noSubscriberForChannelAttachedToEmitter​(String name,
                                             String beanClassName,
                                             String memberName)

      • foundIncomingConnectors

        @LogMessage(level=INFO)
@Message(id=226,
         value="Found incoming connectors: %s")
void foundIncomingConnectors​(List<String> connectors)

      • foundOutgoingConnectors

        @LogMessage(level=INFO)
@Message(id=227,
         value="Found outgoing connectors: %s")
void foundOutgoingConnectors​(List<String> connectors)

      • skippingMPConfig

        @LogMessage(level=INFO)
@Message(id=228,
         value="No MicroProfile Config found, skipping")
void skippingMPConfig()

      • channelManagerInitializing

        @LogMessage(level=INFO)
@Message(id=229,
         value="Channel manager initializing...")
void channelManagerInitializing()

      • unableToCreatePublisherOrSubscriber

        @LogMessage(level=ERROR)
@Message(id=230,
         value="Unable to create the publisher or subscriber during initialization")
void unableToCreatePublisherOrSubscriber​(@Cause
                                         Throwable t)

      • incomingChannelDisabled

        @LogMessage(level=WARN)
@Message(id=231,
         value="Incoming channel `%s` disabled by configuration")
void incomingChannelDisabled​(String channel)

      • outgoingChannelDisabled

        @LogMessage(level=WARN)
@Message(id=232,
         value="Outgoing channel `%s` disabled by configuration")
void outgoingChannelDisabled​(String channel)

      • unableToExtractIngestedPayloadType

        @LogMessage(level=WARN)
@Message(id=233,
         value="Unable to extract the ingested payload type for method `%s`, the reason is: %s")
void unableToExtractIngestedPayloadType​(String method,
                                        String reason)

      • failureEmittingMessage

        @LogMessage(level=WARN)
@Message(id=234,
         value="Failed to emit a Message to the channel")
void failureEmittingMessage​(@Cause
                            Throwable t)