Uses of Interface
org.acemq.amqp.api.MessageHandler
Packages that use MessageHandler
-
Uses of MessageHandler in org.acemq.amqp.core
Methods in org.acemq.amqp.core with parameters of type MessageHandlerModifier and TypeMethodDescription<T> MessageConsumerAceMq.consume(String queue, Class<T> payloadType, MessageHandler<T> handler) Starts consuming a queue.<T> MessageConsumerAceMq.consume(String queue, Class<T> payloadType, ConsumerOptions options, MessageHandler<T> handler) Starts consuming a queue with explicit options.OrderedQueue.consume(MessageHandler<T> handler) Starts one consumer per partition.StreamReader.consume(MessageHandler<T> handler) Starts reading.<T> ConsumerGroupBuilder<T> AceMq.consumeGroup(String queue, Class<T> payloadType, MessageHandler<T> handler) Consumes a queue with several consumers, resizable while the application runs.