Index

A C D E F I J M O P Q R S T V
All Classes and Interfaces|All Packages|Constant Field Values

A

AbstractAmqpController<T extends es.kukenan.smartfi.events.common.AbstractEvent> - Class in es.kukenan.smartfi.amqp.controller

On charge of receiving the event and publish it.

AbstractAmqpController() - Constructor for class es.kukenan.smartfi.amqp.controller.AbstractAmqpController

afterPropertiesSet() - Method in class es.kukenan.smartfi.amqp.repository.EventIdRepository

AmqpAutoConfiguration - Class in es.kukenan.smartfi.amqp.config

Create the configuration needed to exchange requests and responses through the mail channel.

AmqpAutoConfiguration() - Constructor for class es.kukenan.smartfi.amqp.config.AmqpAutoConfiguration

AmqpControllerMessageListenerAdapter - Class in es.kukenan.smartfi.amqp.config

AmqpController to Message listener adapter.

AmqpControllerMessageListenerAdapter(AbstractAmqpController<? extends AbstractEvent<?>>, AmqpMessageConverter, EventIdRepository) - Constructor for class es.kukenan.smartfi.amqp.config.AmqpControllerMessageListenerAdapter

AmqpControllerMessageListenerAdapter constructor.

AmqpControllerMessageListenerAdapter.EventAlreadyProcessedException - Exception Class in es.kukenan.smartfi.amqp.config

Internal exception thrown when detected that an event has been already processed.

AmqpFilter - Class in es.kukenan.smartfi.amqp.filter

Filter to extract Amqp headers that carry context information (requestId and companyId) and propagate them to the request context (RequestContextManager) and to the response.

AmqpFilter() - Constructor for class es.kukenan.smartfi.amqp.filter.AmqpFilter

AmqpMessageConverter - Class in es.kukenan.smartfi.amqp.config

Amqp message converter for the request queue.

AmqpMessageConverter(EventParserManager, AmqpFilter, CustomObjectMapper) - Constructor for class es.kukenan.smartfi.amqp.config.AmqpMessageConverter

State constructor.

AmqpProperties - Class in es.kukenan.smartfi.amqp.config

Properties to configure AMPQ.

AmqpProperties() - Constructor for class es.kukenan.smartfi.amqp.config.AmqpProperties

C

charset(byte[]) - Method in class es.kukenan.smartfi.amqp.config.AmqpMessageConverter

checkAlreadyProcessed(AbstractEvent<?>) - Method in class es.kukenan.smartfi.amqp.config.AmqpControllerMessageListenerAdapter

Checks if the event has been already processed.

collectionName - Variable in class es.kukenan.smartfi.amqp.repository.EventIdRepository

The name of the eventId collection.

CONSUME_METHOD - Static variable in class es.kukenan.smartfi.amqp.config.AmqpControllerMessageListenerAdapter

The name of the event consumer method in the controller.

consumerExchangeAutodelete - Variable in class es.kukenan.smartfi.amqp.config.AmqpProperties

Topic exchange to publish, autodelete property.

consumerExchangeDurable - Variable in class es.kukenan.smartfi.amqp.config.AmqpProperties

Topic exchange to publish, durable property.

consumerExchangeName - Variable in class es.kukenan.smartfi.amqp.config.AmqpProperties

Topic exchange to bind the queue to.

consumerRoutingKey - Variable in class es.kukenan.smartfi.amqp.config.AmqpProperties

Topic exchange to bind the queue to.

contextPropagationFilter - Variable in class es.kukenan.smartfi.amqp.config.AmqpMessageConverter

A filter which only function is propagate request contest (requestId and companyId).

controller - Variable in class es.kukenan.smartfi.amqp.config.AmqpControllerMessageListenerAdapter

The wrapped controller.

createWalletContext(AbstractEvent<?>) - Method in class es.kukenan.smartfi.amqp.filter.AmqpFilter

Create wallet context from event data.

customObjectMapper - Variable in class es.kukenan.smartfi.amqp.config.AmqpMessageConverter

Jackson object mapper to read/write json.

D

deadletterExchangeAutodelete - Variable in class es.kukenan.smartfi.amqp.config.AmqpProperties

Exchange to publish, autodelete property.

deadletterExchangeDurable - Variable in class es.kukenan.smartfi.amqp.config.AmqpProperties

Exchange to publish, durable property.

deadletterExchangeName - Variable in class es.kukenan.smartfi.amqp.config.AmqpProperties

Exchange to bind the deadletter queue to.

deadletterRoutingKey - Variable in class es.kukenan.smartfi.amqp.config.AmqpProperties

Name of routing keys defined to bind the deadletter queue.

defaultRequeueRejected - Variable in class es.kukenan.smartfi.amqp.config.AmqpProperties

If false do not requeue messages that are rejected (they must be sent to the dead-letter exchange).

deleteAll() - Method in class es.kukenan.smartfi.amqp.repository.EventIdRepository

Remove all the eventIds in the collection.

E

es.kukenan.smartfi.amqp - package es.kukenan.smartfi.amqp

Root application package.

es.kukenan.smartfi.amqp.config - package es.kukenan.smartfi.amqp.config

Root application package.

es.kukenan.smartfi.amqp.controller - package es.kukenan.smartfi.amqp.controller

Package where common and abstract controller modules will be placed.

es.kukenan.smartfi.amqp.filter - package es.kukenan.smartfi.amqp.filter

Root application package.

es.kukenan.smartfi.amqp.repository - package es.kukenan.smartfi.amqp.repository

Events repository package.

es.kukenan.smartfi.amqp.repository.model - package es.kukenan.smartfi.amqp.repository.model

Event model package.

EventAlreadyProcessedException(String, Throwable) - Constructor for exception class es.kukenan.smartfi.amqp.config.AmqpControllerMessageListenerAdapter.EventAlreadyProcessedException

Constructor.

EventId - Class in es.kukenan.smartfi.amqp.repository.model

EventId entity, represents the objects stored in the EventId collection.

EventId() - Constructor for class es.kukenan.smartfi.amqp.repository.model.EventId

eventIdCollection - Variable in class es.kukenan.smartfi.amqp.repository.EventIdRepository

The eventId collection in the Mongo database.

eventIdRepository - Variable in class es.kukenan.smartfi.amqp.config.AmqpControllerMessageListenerAdapter

Event identifiers repository.

EventIdRepository - Class in es.kukenan.smartfi.amqp.repository

EventId repository, use to register the processed events and avoid duplicated execution.

EventIdRepository() - Constructor for class es.kukenan.smartfi.amqp.repository.EventIdRepository

eventParserManager - Variable in class es.kukenan.smartfi.amqp.config.AmqpMessageConverter

smartfi business event managers.

F

fromMessage(Message) - Method in class es.kukenan.smartfi.amqp.config.AmqpMessageConverter

I

id - Variable in class es.kukenan.smartfi.amqp.repository.model.EventId

The event identifier.

indexName - Variable in class es.kukenan.smartfi.amqp.repository.EventIdRepository

The collection index required to implement the TTL.

inFilter(AbstractEvent<?>) - Method in class es.kukenan.smartfi.amqp.filter.AmqpFilter

Inbound message filter, propagate inbound message headers into the request contest.

initialize() - Method in class es.kukenan.smartfi.amqp.config.AmqpControllerMessageListenerAdapter

Initialize the adapter.

J

jsonFromBytesWithEncodingDetection(byte[]) - Method in class es.kukenan.smartfi.amqp.config.AmqpMessageConverter

Converts bytes to a JsonNode trying to detect string encoding first.

jsonMessageContent(Message) - Method in class es.kukenan.smartfi.amqp.config.AmqpMessageConverter

Converts message content to a JsonNode.

M

messageConsumerMethods - Variable in class es.kukenan.smartfi.amqp.config.AmqpControllerMessageListenerAdapter

The consume methods that were found in the controller.

messageConverter - Variable in class es.kukenan.smartfi.amqp.config.AmqpControllerMessageListenerAdapter

The message converter used to serialize and deserialize events.

mongo - Variable in class es.kukenan.smartfi.amqp.repository.EventIdRepository

Mongo database connection factory.

O

onMessage(Message) - Method in class es.kukenan.smartfi.amqp.config.AmqpControllerMessageListenerAdapter

outFilter(AbstractEvent<?>) - Method in class es.kukenan.smartfi.amqp.filter.AmqpFilter

Outbound message filter, propagate request context into the outbound message.

P

producerExchangeName - Variable in class es.kukenan.smartfi.amqp.config.AmqpProperties

Topic exchange to publish to.

PUBLISH_METHOD - Static variable in class es.kukenan.smartfi.amqp.config.AmqpControllerMessageListenerAdapter

The name of the publish method in the controller.

Q

queueName - Variable in class es.kukenan.smartfi.amqp.config.AmqpProperties

The name of the queue this service binds to the exchange.

R

requestContextManager - Variable in class es.kukenan.smartfi.amqp.filter.AmqpFilter

Request context metadata manager.

S

save(EventId) - Method in class es.kukenan.smartfi.amqp.repository.EventIdRepository

Store the eventId, fails if is already exists.

T

toMessage(Object, MessageProperties) - Method in class es.kukenan.smartfi.amqp.config.AmqpMessageConverter

ttl - Variable in class es.kukenan.smartfi.amqp.repository.EventIdRepository

The time to live for collection entries.

ttlUnit - Variable in class es.kukenan.smartfi.amqp.repository.EventIdRepository

The time to live unit for collection entries.

V

verifyAndRegisterConsumeMethod(Method) - Method in class es.kukenan.smartfi.amqp.config.AmqpControllerMessageListenerAdapter

Register a new consume method.

verifyPublishMethod(Method) - Method in class es.kukenan.smartfi.amqp.config.AmqpControllerMessageListenerAdapter

Verify the given publish method that should be the one at AbstractAmqpController.

A C D E F I J M O P Q R S T V
All Classes and Interfaces|All Packages|Constant Field Values