Skip to content

Commit

Permalink
GH-1032: Fix typo in new interface name
Browse files Browse the repository at this point in the history
  • Loading branch information
garyrussell committed Jul 1, 2019
1 parent 5d73342 commit 280c2b1
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand All @@ -40,7 +40,7 @@
*
*/
public class BatchMessagingMessageListenerAdapter extends MessagingMessageListenerAdapter
implements ChannelAwareBatchMessagelistener {
implements ChannelAwareBatchMessageListener {

private final MessagingMessageConverterAdapter converterAdapter;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down

0 comments on commit 280c2b1

Please sign in to comment.