クラス AbstractPulsarMessageListenerContainer<T>

メソッドの詳細

• getPulsarConsumerFactory

  public PulsarConsumerFactory<T> getPulsarConsumerFactory()

• getContainerProperties

  public PulsarContainerProperties getContainerProperties()

  次で指定:

  インターフェース PulsarMessageListenerContainer の getContainerProperties 

• isRunning

  public boolean isRunning()

  次で指定:

  インターフェース Lifecycle の isRunning 

• setRunning

  protected void setRunning(boolean running)

• setupMessageListener

  public void setupMessageListener(ObjectSE messageListener)

  次で指定:

  インターフェース PulsarMessageListenerContainer の setupMessageListener 

• isAutoStartup

  public boolean isAutoStartup()

  次で指定:

  インターフェース SmartLifecycle の isAutoStartup 

• setAutoStartup

  public void setAutoStartup(boolean autoStartup)

  次で指定:

  インターフェース MessageListenerContainer の setAutoStartup 

• start

  public final void start()

  次で指定:

  インターフェース Lifecycle の start 

• stop

  public void stop()

  次で指定:

  インターフェース Lifecycle の stop 

• setNegativeAckRedeliveryBackoff

  public void setNegativeAckRedeliveryBackoff(org.apache.pulsar.client.api.RedeliveryBackoff redeliveryBackoff)

  次で指定:

  インターフェース PulsarMessageListenerContainer の setNegativeAckRedeliveryBackoff 

• setAckTimeoutRedeliveryBackoff

  public void setAckTimeoutRedeliveryBackoff(org.apache.pulsar.client.api.RedeliveryBackoff redeliveryBackoff)

  次で指定:

  インターフェース PulsarMessageListenerContainer の setAckTimeoutRedeliveryBackoff 

• getNegativeAckRedeliveryBackoff

  public org.apache.pulsar.client.api.RedeliveryBackoff getNegativeAckRedeliveryBackoff()

• getAckTimeoutkRedeliveryBackoff

  public org.apache.pulsar.client.api.RedeliveryBackoff getAckTimeoutkRedeliveryBackoff()

• setDeadLetterPolicy

  public void setDeadLetterPolicy(org.apache.pulsar.client.api.DeadLetterPolicy deadLetterPolicy)

  次で指定:

  インターフェース PulsarMessageListenerContainer の setDeadLetterPolicy 

• getDeadLetterPolicy

  public org.apache.pulsar.client.api.DeadLetterPolicy getDeadLetterPolicy()

• getPulsarConsumerErrorHandler

  public PulsarConsumerErrorHandler<T> getPulsarConsumerErrorHandler()

• setPulsarConsumerErrorHandler

  public void setPulsarConsumerErrorHandler(PulsarConsumerErrorHandler pulsarConsumerErrorHandler)

  次で指定:

  インターフェース PulsarMessageListenerContainer の setPulsarConsumerErrorHandler 

• setConsumerCustomizer

  public void setConsumerCustomizer(ConsumerBuilderCustomizer<?> consumerBuilderCustomizer)

  インターフェースからコピーされた説明: PulsarMessageListenerContainer

  このコンテナーにコンシューマーカスタマイザを設定します。

  次で指定:

  インターフェース PulsarMessageListenerContainer の setConsumerCustomizer 

  パラメーター:

  consumerBuilderCustomizer - ConsumerBuilderCustomizer

• getConsumerBuilderCustomizer

  public ConsumerBuilderCustomizer<T> getConsumerBuilderCustomizer()

• pause

  public void pause()

  インターフェースからコピーされた説明: PulsarMessageListenerContainer

  次の poll() の前にこのコンテナーを一時停止します。PulsarMessageListenerContainer.resume() が呼び出されない限り、コンテナーによる次のポーリングは無効になります。

  次で指定:

  インターフェース PulsarMessageListenerContainer の pause 

• resume

  public void resume()

  インターフェースからコピーされた説明: PulsarMessageListenerContainer

  このコンテナーが一時停止されている場合は再開します。

  次で指定:

  インターフェース PulsarMessageListenerContainer の resume 

• isPaused

  protected boolean isPaused()

• setPaused

  protected void setPaused(boolean paused)

• doPause

  protected abstract void doPause()

• doResume

  protected abstract void doResume()