Package io.smallrye.reactive.messaging.kafka.i18n

Class KafkaLogging_$logger

java.lang.Object

org.jboss.logging.DelegatingBasicLogger

io.smallrye.reactive.messaging.kafka.i18n.KafkaLogging_$logger

All Implemented Interfaces:

KafkaLogging, Serializable, org.jboss.logging.BasicLogger

@Generated(value="org.jboss.logging.processor.generator.model.MessageLoggerImplementor",
           date="2020-07-23T10:41:19+0200")
public class KafkaLogging_$logger
extends org.jboss.logging.DelegatingBasicLogger
implements KafkaLogging, org.jboss.logging.BasicLogger, Serializable

Warning this class consists of generated code.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.jboss.logging.DelegatingBasicLogger

log

Fields inherited from interface io.smallrye.reactive.messaging.kafka.i18n.KafkaLogging

log

Constructor Summary

Constructors

Constructor	Description
KafkaLogging_$logger(org.jboss.logging.Logger log)

Method Summary

Modifier and Type	Method	Description
void	configServers(String serverConfig, String servers)
protected String	configServers$str()
void	configuredPattern(String channel, String pattern)
protected String	configuredPattern$str()
void	configuredTopics(String channel, Set<String> topics)
protected String	configuredTopics$str()
void	deadLetterConfig(String deadQueueTopic, String keySerializer, String valueSerializer)
protected String	deadLetterConfig$str()
void	errorWhileClosingWriteStream(Throwable t)
protected String	errorWhileClosingWriteStream$str()
void	exceptionOnClose(Throwable t)
protected String	exceptionOnClose$str()
void	executedConsumerAssignedRebalanceListener(String consumerGroup)
protected String	executedConsumerAssignedRebalanceListener$str()
void	executedConsumerRevokedRebalanceListener(String consumerGroup)
protected String	executedConsumerRevokedRebalanceListener$str()
void	executingConsumerAssignedRebalanceListener(String consumerGroup)
protected String	executingConsumerAssignedRebalanceListener$str()
void	executingConsumerRevokedRebalanceListener(String consumerGroup)
protected String	executingConsumerRevokedRebalanceListener$str()
void	failureReported(Set<String> topics, Throwable t)
protected String	failureReported$str()
protected Locale	getLoggingLocale()
void	ignoringNoTopicSet()
protected String	ignoringNoTopicSet$str()
void	keyDeserializerOmitted()
protected String	keyDeserializerOmitted$str()
void	loadingConsumerRebalanceListenerFromConfiguredName(String configuredName)
protected String	loadingConsumerRebalanceListenerFromConfiguredName$str()
void	loadingConsumerRebalanceListenerFromGroupId(String consumerGroup)
protected String	loadingConsumerRebalanceListenerFromGroupId$str()
void	mergingConfigWith(Map<String,Object> defaultKafkaCfg)
protected String	mergingConfigWith$str()
void	messageNackedDeadLetter(String channel, String topic)
protected String	messageNackedDeadLetter$str()
void	messageNackedFailStop(String channel)
protected String	messageNackedFailStop$str()
void	messageNackedFullIgnored(Throwable t)
protected String	messageNackedFullIgnored$str()
void	messageNackedIgnore(String channel, String reason)
protected String	messageNackedIgnore$str()
void	nackingMessage(Message message, String topic, Throwable t)
protected String	nackingMessage$str()
void	noGroupId(String randomId)
protected String	noGroupId$str()
void	reEnablingConsumerforGroup(String consumerGroup)
protected String	reEnablingConsumerforGroup$str()
void	sendingMessageToTopic(Message message, String topic)
protected String	sendingMessageToTopic$str()
void	successfullyToTopic(Message message, String topic)
protected String	successfullyToTopic$str()
void	unableToDispatch(Throwable t)
protected String	unableToDispatch$str()
void	unableToExecuteConsumerAssignedRebalanceListener(String consumerGroup, Throwable t)
protected String	unableToExecuteConsumerAssignedRebalanceListener$str()
void	unableToExecuteConsumerRevokedRebalanceListener(String consumerGroup, Throwable t)
protected String	unableToExecuteConsumerRevokedRebalanceListener$str()
void	unableToReadRecord(Set<String> topics, Throwable t)
protected String	unableToReadRecord$str()
void	unableToSendRecord(Throwable t)
protected String	unableToSendRecord$str()
void	unableToWrite(Throwable t)
protected String	unableToWrite$str()

Methods inherited from class org.jboss.logging.DelegatingBasicLogger

debug, debug, debug, debug, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugv, debugv, debugv, debugv, debugv, debugv, debugv, debugv, error, error, error, error, errorf, errorf, errorf, errorf, errorf, errorf, errorf, errorf, errorv, errorv, errorv, errorv, errorv, errorv, errorv, errorv, fatal, fatal, fatal, fatal, fatalf, fatalf, fatalf, fatalf, fatalf, fatalf, fatalf, fatalf, fatalv, fatalv, fatalv, fatalv, fatalv, fatalv, fatalv, fatalv, info, info, info, info, infof, infof, infof, infof, infof, infof, infof, infof, infov, infov, infov, infov, infov, infov, infov, infov, isDebugEnabled, isEnabled, isInfoEnabled, isTraceEnabled, log, log, log, log, logf, logf, logf, logf, logf, logf, logf, logf, logf, logf, logf, logf, logv, logv, logv, logv, logv, logv, logv, logv, logv, logv, logv, logv, trace, trace, trace, trace, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracev, tracev, tracev, tracev, tracev, tracev, tracev, tracev, warn, warn, warn, warn, warnf, warnf, warnf, warnf, warnf, warnf, warnf, warnf, warnv, warnv, warnv, warnv, warnv, warnv, warnv, warnv

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jboss.logging.BasicLogger

debug, debug, debug, debug, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugv, debugv, debugv, debugv, debugv, debugv, debugv, debugv, error, error, error, error, errorf, errorf, errorf, errorf, errorf, errorf, errorf, errorf, errorv, errorv, errorv, errorv, errorv, errorv, errorv, errorv, fatal, fatal, fatal, fatal, fatalf, fatalf, fatalf, fatalf, fatalf, fatalf, fatalf, fatalf, fatalv, fatalv, fatalv, fatalv, fatalv, fatalv, fatalv, fatalv, info, info, info, info, infof, infof, infof, infof, infof, infof, infof, infof, infov, infov, infov, infov, infov, infov, infov, infov, isDebugEnabled, isEnabled, isInfoEnabled, isTraceEnabled, log, log, log, log, logf, logf, logf, logf, logf, logf, logf, logf, logf, logf, logf, logf, logv, logv, logv, logv, logv, logv, logv, logv, logv, logv, logv, logv, trace, trace, trace, trace, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracev, tracev, tracev, tracev, tracev, tracev, tracev, tracev, warn, warn, warn, warn, warnf, warnf, warnf, warnf, warnf, warnf, warnf, warnf, warnv, warnv, warnv, warnv, warnv, warnv, warnv, warnv

Constructor Detail

KafkaLogging_$logger

public KafkaLogging_$logger(org.jboss.logging.Logger log)

Method Detail

getLoggingLocale

protected Locale getLoggingLocale()

mergingConfigWith

public final void mergingConfigWith(Map<String,Object> defaultKafkaCfg)

Specified by:

mergingConfigWith in interface KafkaLogging

mergingConfigWith$str

protected String mergingConfigWith$str()

deadLetterConfig

public final void deadLetterConfig(String deadQueueTopic,
                                   String keySerializer,
                                   String valueSerializer)

Specified by:

deadLetterConfig in interface KafkaLogging

deadLetterConfig$str

protected String deadLetterConfig$str()

messageNackedDeadLetter

public final void messageNackedDeadLetter(String channel,
                                          String topic)

Specified by:

messageNackedDeadLetter in interface KafkaLogging

messageNackedDeadLetter$str

protected String messageNackedDeadLetter$str()

messageNackedFailStop

public final void messageNackedFailStop(String channel)

Specified by:

messageNackedFailStop in interface KafkaLogging

messageNackedFailStop$str

protected String messageNackedFailStop$str()

messageNackedIgnore

public final void messageNackedIgnore(String channel,
                                      String reason)

Specified by:

messageNackedIgnore in interface KafkaLogging

messageNackedIgnore$str

protected String messageNackedIgnore$str()

messageNackedFullIgnored

public final void messageNackedFullIgnored(Throwable t)

Specified by:

messageNackedFullIgnored in interface KafkaLogging

messageNackedFullIgnored$str

protected String messageNackedFullIgnored$str()

unableToWrite

public final void unableToWrite(Throwable t)

Specified by:

unableToWrite in interface KafkaLogging

unableToWrite$str

protected String unableToWrite$str()

unableToDispatch

public final void unableToDispatch(Throwable t)

Specified by:

unableToDispatch in interface KafkaLogging

unableToDispatch$str

protected String unableToDispatch$str()

ignoringNoTopicSet

public final void ignoringNoTopicSet()

Specified by:

ignoringNoTopicSet in interface KafkaLogging

ignoringNoTopicSet$str

protected String ignoringNoTopicSet$str()

sendingMessageToTopic

public final void sendingMessageToTopic(Message message,
                                        String topic)

Specified by:

sendingMessageToTopic in interface KafkaLogging

sendingMessageToTopic$str

protected String sendingMessageToTopic$str()

unableToSendRecord

public final void unableToSendRecord(Throwable t)

Specified by:

unableToSendRecord in interface KafkaLogging

unableToSendRecord$str

protected String unableToSendRecord$str()

successfullyToTopic

public final void successfullyToTopic(Message message,
                                      String topic)

Specified by:

successfullyToTopic in interface KafkaLogging

successfullyToTopic$str

protected String successfullyToTopic$str()

nackingMessage

public final void nackingMessage(Message message,
                                 String topic,
                                 Throwable t)

Specified by:

nackingMessage in interface KafkaLogging

nackingMessage$str

protected String nackingMessage$str()

configServers

public final void configServers(String serverConfig,
                                String servers)

Specified by:

configServers in interface KafkaLogging

configServers$str

protected String configServers$str()

keyDeserializerOmitted

public final void keyDeserializerOmitted()

Specified by:

keyDeserializerOmitted in interface KafkaLogging

keyDeserializerOmitted$str

protected String keyDeserializerOmitted$str()

errorWhileClosingWriteStream

public final void errorWhileClosingWriteStream(Throwable t)

Specified by:

errorWhileClosingWriteStream in interface KafkaLogging

errorWhileClosingWriteStream$str

protected String errorWhileClosingWriteStream$str()

noGroupId

public final void noGroupId(String randomId)

Specified by:

noGroupId in interface KafkaLogging

noGroupId$str

protected String noGroupId$str()

unableToReadRecord

public final void unableToReadRecord(Set<String> topics,
                                     Throwable t)

Specified by:

unableToReadRecord in interface KafkaLogging

unableToReadRecord$str

protected String unableToReadRecord$str()

exceptionOnClose

public final void exceptionOnClose(Throwable t)

Specified by:

exceptionOnClose in interface KafkaLogging

exceptionOnClose$str

protected String exceptionOnClose$str()

loadingConsumerRebalanceListenerFromConfiguredName

public final void loadingConsumerRebalanceListenerFromConfiguredName(String configuredName)

Specified by:

loadingConsumerRebalanceListenerFromConfiguredName in interface KafkaLogging

loadingConsumerRebalanceListenerFromConfiguredName$str

protected String loadingConsumerRebalanceListenerFromConfiguredName$str()

loadingConsumerRebalanceListenerFromGroupId

public final void loadingConsumerRebalanceListenerFromGroupId(String consumerGroup)

Specified by:

loadingConsumerRebalanceListenerFromGroupId in interface KafkaLogging

loadingConsumerRebalanceListenerFromGroupId$str

protected String loadingConsumerRebalanceListenerFromGroupId$str()

unableToExecuteConsumerAssignedRebalanceListener

public final void unableToExecuteConsumerAssignedRebalanceListener(String consumerGroup,
                                                                   Throwable t)

Specified by:

unableToExecuteConsumerAssignedRebalanceListener in interface KafkaLogging

unableToExecuteConsumerAssignedRebalanceListener$str

protected String unableToExecuteConsumerAssignedRebalanceListener$str()

unableToExecuteConsumerRevokedRebalanceListener

public final void unableToExecuteConsumerRevokedRebalanceListener(String consumerGroup,
                                                                  Throwable t)

Specified by:

unableToExecuteConsumerRevokedRebalanceListener in interface KafkaLogging

unableToExecuteConsumerRevokedRebalanceListener$str

protected String unableToExecuteConsumerRevokedRebalanceListener$str()

executingConsumerAssignedRebalanceListener

public final void executingConsumerAssignedRebalanceListener(String consumerGroup)

Specified by:

executingConsumerAssignedRebalanceListener in interface KafkaLogging

executingConsumerAssignedRebalanceListener$str

protected String executingConsumerAssignedRebalanceListener$str()

executingConsumerRevokedRebalanceListener

public final void executingConsumerRevokedRebalanceListener(String consumerGroup)

Specified by:

executingConsumerRevokedRebalanceListener in interface KafkaLogging

executingConsumerRevokedRebalanceListener$str

protected String executingConsumerRevokedRebalanceListener$str()

executedConsumerAssignedRebalanceListener

public final void executedConsumerAssignedRebalanceListener(String consumerGroup)

Specified by:

executedConsumerAssignedRebalanceListener in interface KafkaLogging

executedConsumerAssignedRebalanceListener$str

protected String executedConsumerAssignedRebalanceListener$str()

executedConsumerRevokedRebalanceListener

public final void executedConsumerRevokedRebalanceListener(String consumerGroup)

Specified by:

executedConsumerRevokedRebalanceListener in interface KafkaLogging

executedConsumerRevokedRebalanceListener$str

protected String executedConsumerRevokedRebalanceListener$str()

reEnablingConsumerforGroup

public final void reEnablingConsumerforGroup(String consumerGroup)

Specified by:

reEnablingConsumerforGroup in interface KafkaLogging

reEnablingConsumerforGroup$str

protected String reEnablingConsumerforGroup$str()

failureReported

public final void failureReported(Set<String> topics,
                                  Throwable t)

Specified by:

failureReported in interface KafkaLogging

failureReported$str

protected String failureReported$str()

configuredTopics

public final void configuredTopics(String channel,
                                   Set<String> topics)

Specified by:

configuredTopics in interface KafkaLogging

configuredTopics$str

protected String configuredTopics$str()

configuredPattern

public final void configuredPattern(String channel,
                                    String pattern)

Specified by:

configuredPattern in interface KafkaLogging

configuredPattern$str

protected String configuredPattern$str()