metricapp.service.repository

Class BusRepository

java.lang.Object

metricapp.service.repository.BusRepository

All Implemented Interfaces:

BusInterface

@Service
public class BusRepository
extends java.lang.Object
implements BusInterface

This repository is the lowest level before the connection with Bus Rest Interface. Method in this class are almost the same described in Bus Team Documentation on their Bus.

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.String	createBus
private java.lang.String	deleteFromBus
private java.lang.String	idBus
private JacksonMapper	mapper
private java.lang.String	originAdressBus
private java.lang.String	phaseBus
private java.lang.String	readFromBus
private java.lang.String	resolvedAdressBus
private java.lang.String	rollbackBus
private java.lang.String	tagBus
private java.lang.String	updateToBus
private java.lang.String	urlBus

Constructor Summary

Constructors

Constructor and Description
BusRepository()

Method Summary

Methods

Modifier and Type	Method and Description
java.util.ArrayList<java.lang.String>	create(RichPointerBus pointerBus) this method permits to interact with the bus through a create request.
java.util.ArrayList<java.lang.String>	delete(PointerBus pointerBus) this method permits to interact with the bus through a delete request.
private java.util.ArrayList<java.lang.String>	fillContent(java.lang.String field1, PointerBus field2) Simple function to create and fill the content array.
private java.lang.String	phaseOfPointerPayload(PointerBus pointerBus) this method is used to grab the phase of the requested or sended element.
private java.util.ArrayList<java.lang.String>	rawPost(java.util.ArrayList<java.lang.String> content) lowest level method to interact with bus, it requires only the type of request and the content. there's no "null check"
java.util.ArrayList<java.lang.String>	read(PointerBus pointerBus) this method permits to interact with the bus through a read request.
java.util.ArrayList<java.lang.String>	rollback(PointerBus pointerBus) this method permits to interact with the bus through a rollback request.
java.util.ArrayList<java.lang.String>	update(RichPointerBus pointerBus) this method permits to interact with the bus through a update request.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

urlBus

@Value(value="${bus.url}")
private java.lang.String urlBus

tagBus

@Value(value="${bus.tag}")
private java.lang.String tagBus

originAdressBus

@Value(value="${bus.originAdress}")
private java.lang.String originAdressBus

resolvedAdressBus

@Value(value="${bus.resolvedAdress}")
private java.lang.String resolvedAdressBus

idBus

@Value(value="${bus.id}")
private java.lang.String idBus

phaseBus

@Value(value="${bus.phase}")
private java.lang.String phaseBus

readFromBus

@Value(value="${bus.readFromBus}")
private java.lang.String readFromBus

updateToBus

@Value(value="${bus.updateToBus}")
private java.lang.String updateToBus

createBus

@Value(value="${bus.createBus}")
private java.lang.String createBus

deleteFromBus

@Value(value="${bus.deleteFromBus}")
private java.lang.String deleteFromBus

rollbackBus

@Value(value="${bus.rollbackBus}")
private java.lang.String rollbackBus

mapper

@Autowired
private JacksonMapper mapper

Constructor Detail

BusRepository

public BusRepository()

Method Detail

rawPost

private java.util.ArrayList<java.lang.String> rawPost(java.util.ArrayList<java.lang.String> content)
                                               throws BusException

lowest level method to interact with bus, it requires only the type of request and the content. there's no "null check"

Parameters:

content - Array with 3 elements, it contains the phase number, the request (read, update, delete, rollback) and the content string

Returns:

the String content sended by the Bus. Tipically it is in JSON syntax, but it can contain Error String

Throws:

BusException

fillContent

private java.util.ArrayList<java.lang.String> fillContent(java.lang.String field1,
                                                PointerBus field2)
                                                   throws com.fasterxml.jackson.core.JsonProcessingException

Simple function to create and fill the content array. field2 is converted to string with JacksonMapper

Parameters:

field1 - identifies the kind of the request

field2 - identifies the request

Returns:

the filled array of elements

Throws:

com.fasterxml.jackson.core.JsonProcessingException

See Also:

JacksonMapper

read

public java.util.ArrayList<java.lang.String> read(PointerBus pointerBus)
                                           throws BusException,
                                                  com.fasterxml.jackson.core.JsonProcessingException

this method permits to interact with the bus through a read request. There's no null parameters check.

Specified by:

read in interface BusInterface

Parameters:

pointerBus -

Returns:

the content of the response, it's a String in Json Syntax typically and needs to be converted

Throws:

BusException - if available append the previous exception to the last one

com.fasterxml.jackson.core.JsonProcessingException - if the dto is not printable like json

update

public java.util.ArrayList<java.lang.String> update(RichPointerBus pointerBus)
                                             throws BusException,
                                                    com.fasterxml.jackson.core.JsonProcessingException

this method permits to interact with the bus through a update request. There's no null parameters check.

Specified by:

update in interface BusInterface

Parameters:

pointerBus -

Returns:

the content of the response, it's a String in Json Syntax typically and needs to be converted

Throws:

BusException - if available append the previous exception to the last one

com.fasterxml.jackson.core.JsonProcessingException - if the dto is not printable like json

create

public java.util.ArrayList<java.lang.String> create(RichPointerBus pointerBus)
                                             throws BusException,
                                                    com.fasterxml.jackson.core.JsonProcessingException

this method permits to interact with the bus through a create request. There's no null parameters check.

Specified by:

create in interface BusInterface

Parameters:

pointerBus, - of type RichPointerBus, it contains the payload too

Returns:

the content of the response, it's a String in Json Syntax typically and needs to be converted

Throws:

BusException - if available append the previous exception to the last one

com.fasterxml.jackson.core.JsonProcessingException - if the dto is not printable like json

rollback

public java.util.ArrayList<java.lang.String> rollback(PointerBus pointerBus)
                                               throws BusException,
                                                      com.fasterxml.jackson.core.JsonProcessingException

this method permits to interact with the bus through a rollback request. There's no null parameters check.

Specified by:

rollback in interface BusInterface

Parameters:

pointerBus, - of type RichPointerBus, it contains the payload too

Returns:

the content of the response, it's a String in Json Syntax typically and needs to be converted

Throws:

BusException - if available append the previous exception to the last one

com.fasterxml.jackson.core.JsonProcessingException - if the dto is not printable like json

delete

public java.util.ArrayList<java.lang.String> delete(PointerBus pointerBus)
                                             throws BusException,
                                                    com.fasterxml.jackson.core.JsonProcessingException

this method permits to interact with the bus through a delete request. There's no null parameters check.

Specified by:

delete in interface BusInterface

Parameters:

pointerBus -

Returns:

the content of the response, it's a String.

Throws:

BusException - if available append the previous exception to the last one

com.fasterxml.jackson.core.JsonProcessingException - if the dto is not printable like json

phaseOfPointerPayload

private java.lang.String phaseOfPointerPayload(PointerBus pointerBus)

this method is used to grab the phase of the requested or sended element. e.g. : A metric is sended to bus, the correct phase value is "phase2", otherwise a context factor is grabbed the correct phase value is "phase1". Phase values are in a field of enumeration Entity. phase value identifies the owner of the element.

Parameters:

pointerBus -

Returns:

string phasex, where x is in {1,2,3,4,5,6}