Skip to content
Permalink
Browse files

GH-1032: Fix typo in new interface name

  • Loading branch information
garyrussell committed Jul 1, 2019
1 parent 5d73342 commit 280c2b12be0d03e71676c7a6188631ba4c9530e9
@@ -48,7 +48,7 @@
import org.springframework.amqp.rabbit.connection.RabbitResourceHolder;
import org.springframework.amqp.rabbit.connection.RabbitUtils;
import org.springframework.amqp.rabbit.connection.SimpleResourceHolder;
import org.springframework.amqp.rabbit.listener.api.ChannelAwareBatchMessagelistener;
import org.springframework.amqp.rabbit.listener.api.ChannelAwareBatchMessageListener;
import org.springframework.amqp.rabbit.listener.exception.FatalListenerExecutionException;
import org.springframework.amqp.rabbit.listener.exception.FatalListenerStartupException;
import org.springframework.amqp.rabbit.support.ActiveObjectCounter;
@@ -516,7 +516,7 @@ protected final boolean sharedConnectionEnabled() {
@Override
protected void doInitialize() {
Assert.state(!this.consumerBatchEnabled || getMessageListener() instanceof BatchMessageListener
|| getMessageListener() instanceof ChannelAwareBatchMessagelistener,
|| getMessageListener() instanceof ChannelAwareBatchMessageListener,
"When setting 'consumerBatchEnabled' to true, the listener must support batching");
Assert.state(!this.consumerBatchEnabled || isDeBatchingEnabled(),
"When setting 'consumerBatchEnabled' to true, 'deBatchingEnabled' must also be true");
@@ -22,7 +22,7 @@

import org.springframework.amqp.rabbit.batch.BatchingStrategy;
import org.springframework.amqp.rabbit.batch.SimpleBatchingStrategy;
import org.springframework.amqp.rabbit.listener.api.ChannelAwareBatchMessagelistener;
import org.springframework.amqp.rabbit.listener.api.ChannelAwareBatchMessageListener;
import org.springframework.amqp.rabbit.listener.api.RabbitListenerErrorHandler;
import org.springframework.amqp.rabbit.support.RabbitExceptionTranslator;
import org.springframework.lang.Nullable;
@@ -40,7 +40,7 @@
*
*/
public class BatchMessagingMessageListenerAdapter extends MessagingMessageListenerAdapter
implements ChannelAwareBatchMessagelistener {
implements ChannelAwareBatchMessageListener {

private final MessagingMessageConverterAdapter converterAdapter;

@@ -29,7 +29,7 @@
* @since 2.2
*
*/
public interface ChannelAwareBatchMessagelistener extends ChannelAwareMessageListener {
public interface ChannelAwareBatchMessageListener extends ChannelAwareMessageListener {

@Override
default void onMessage(Message message, Channel channel) throws Exception {

0 comments on commit 280c2b1

Please sign in to comment.
You can’t perform that action at this time.