Class BatchMessagingMessageListenerAdapter

Namespace

Steeltoe.Messaging.RabbitMQ.Listener.Adapters

Assembly

Steeltoe.Messaging.RabbitMQ.dll

public class BatchMessagingMessageListenerAdapter : MessagingMessageListenerAdapter, IChannelAwareBatchMessageListener, IChannelAwareMessageListener, IMessageListener

Inheritance

object

AbstractMessageListenerAdapter

MessagingMessageListenerAdapter

BatchMessagingMessageListenerAdapter

Implements

IChannelAwareBatchMessageListener

IChannelAwareMessageListener

IMessageListener

Inherited Members

MessagingMessageListenerAdapter.Instance

MessagingMessageListenerAdapter.Method

MessagingMessageListenerAdapter.IsBatch

MessagingMessageListenerAdapter.IsMessageList

MessagingMessageListenerAdapter.IsMessageByteArrayList

MessagingMessageListenerAdapter.InferredArgumentType

MessagingMessageListenerAdapter.ReturnExceptions

MessagingMessageListenerAdapter.ErrorHandler

MessagingMessageListenerAdapter.HandlerAdapter

MessagingMessageListenerAdapter.OnMessage(IMessage, IModel)

MessagingMessageListenerAdapter.BuildMessage(IModel, object, Type)

MessagingMessageListenerAdapter.InvokeHandlerAndProcessResult(IMessage, IModel, IMessage)

MessagingMessageListenerAdapter.PreprocesMessage(IMessage)

AbstractMessageListenerAdapter._logger

AbstractMessageListenerAdapter.ApplicationContext

AbstractMessageListenerAdapter.Encoding

AbstractMessageListenerAdapter.ResponseRoutingKey

AbstractMessageListenerAdapter.ResponseExchange

AbstractMessageListenerAdapter.ResponseAddress

AbstractMessageListenerAdapter.MandatoryPublish

AbstractMessageListenerAdapter.MessageConverter

AbstractMessageListenerAdapter.BeforeSendReplyPostProcessors

AbstractMessageListenerAdapter.RetryTemplate

AbstractMessageListenerAdapter.RecoveryCallback

AbstractMessageListenerAdapter.DefaultRequeueRejected

AbstractMessageListenerAdapter.ContainerAckMode

AbstractMessageListenerAdapter.IsManualAck

AbstractMessageListenerAdapter.EvalContext

AbstractMessageListenerAdapter.MessagePropertiesConverter

AbstractMessageListenerAdapter.ResponseExpression

AbstractMessageListenerAdapter.ReplyPostProcessor

AbstractMessageListenerAdapter.SetResponseAddress(string)

AbstractMessageListenerAdapter.SetServiceResolver(IServiceResolver)

AbstractMessageListenerAdapter.SetBeforeSendReplyPostProcessors(params IMessagePostProcessor[])

AbstractMessageListenerAdapter.OnMessage(IMessage)

AbstractMessageListenerAdapter.OnMessageBatch(List<IMessage>)

AbstractMessageListenerAdapter.HandleListenerException(Exception)

AbstractMessageListenerAdapter.ExtractMessage(IMessage)

AbstractMessageListenerAdapter.HandleResult(InvocationResult, IMessage, IModel)

AbstractMessageListenerAdapter.HandleResult(InvocationResult, IMessage, IModel, object)

AbstractMessageListenerAdapter.DoHandleResult(InvocationResult, IMessage, IModel, object)

AbstractMessageListenerAdapter.GetReceivedExchange(IMessage)

AbstractMessageListenerAdapter.PostProcessResponse(IMessage, IMessage)

AbstractMessageListenerAdapter.GetReplyToAddress(IMessage, object, InvocationResult)

AbstractMessageListenerAdapter.SendResponse(IModel, Address, IMessage<byte[]>)

AbstractMessageListenerAdapter.DoPublish(IModel, Address, IMessage<byte[]>)

AbstractMessageListenerAdapter.PostProcessChannel(IModel, IMessage)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

BatchMessagingMessageListenerAdapter(IApplicationContext, object, MethodInfo, bool, IRabbitListenerErrorHandler, IBatchingStrategy, ILogger)

public BatchMessagingMessageListenerAdapter(IApplicationContext context, object bean, MethodInfo method, bool returnExceptions, IRabbitListenerErrorHandler errorHandler, IBatchingStrategy batchingStrategy, ILogger logger = null)

Parameters

context IApplicationContext

bean object

method MethodInfo

returnExceptions bool

errorHandler IRabbitListenerErrorHandler

batchingStrategy IBatchingStrategy

logger ILogger

Methods

CreateList(Type)

protected IList CreateList(Type type)

Parameters

type Type

Returns

IList

CreateMessageList(Type)

protected IList CreateMessageList(Type type)

Parameters

type Type

Returns

IList

OnMessageBatch(List<IMessage>, IModel)

public override void OnMessageBatch(List<IMessage> messages, IModel channel)

Parameters

messages List<IMessage>

channel IModel

ToMessagingMessage(IMessage)

protected IMessage ToMessagingMessage(IMessage amqpMessage)

Parameters

amqpMessage IMessage

Returns

IMessage