ListSearchClientBean.java

package ru.brbpm.tnuzdo.ejb.client;

import ru.blogic20.gp.services.list.api.ListModelDefinition;
import ru.blogic20.gp.services.list.api.ListRecord;
import ru.blogic20.gp.services.list.api.ListResult;
import ru.blogic20.gp.services.list.api.ListSearchService;
import ru.blogic20.gp.services.list.api.PageMark;
import ru.blogic20.gp.services.list.api.SearchServiceException;
import ru.blogic20.gp.services.list.api.query.Query;
import ru.blogic20.gp.services.utils.streamquery.ListServiceServiceStreamAspect;
import ru.blogic20.gp.services.utils.streamquery.StreamResult;
import ru.blogic20.gp.services.utils.streamquery.api.QueryResultException;
import ru.blogic20.gp.services.utils.streamquery.impl.ListSearchServiceStreamAspectImpl;
import ru.brbpm.tnuzdo.client.ListSearchClient;

import javax.annotation.PostConstruct;
import javax.ejb.EJB;
import javax.ejb.Stateless;
import javax.ejb.TransactionAttribute;
import javax.ejb.TransactionAttributeType;
import java.io.Serializable;
import java.util.Date;
import java.util.Map;

/**
 * Бин-делегат для сервиса справочников ЕПП.
 */
@Stateless
@TransactionAttribute(TransactionAttributeType.NOT_SUPPORTED)
public class ListSearchClientBean implements ListSearchClient {

    @EJB(name = "ejb/gp-ListSearchService")
    private ListSearchService listSearchClient;
    
    private ListServiceServiceStreamAspect listServiceServiceStreamAspect;

    @PostConstruct
    public void postConstruct() {
        listServiceServiceStreamAspect = new ListSearchServiceStreamAspectImpl(listSearchClient);
    }

    @Override
    public ListResult find(String listId, Query query, Integer maxRecord) throws SearchServiceException {
        return listSearchClient.find(listId, query, maxRecord);
    }

    @Override
    public ListResult findChangedAfter(String listId, Date lastDate) throws SearchServiceException {
        return listSearchClient.findChangedAfter(listId, lastDate);
    }

    @Override
    public ListResult resume(String listId, PageMark page) throws SearchServiceException {
        return listSearchClient.resume(listId, page);
    }

    @Override
    public ListRecord get(String listId, Serializable objectId) throws SearchServiceException {
        return listSearchClient.get(listId, objectId);
    }

    @Override
    public Map<String, ListModelDefinition> getModelDefinitions(String sourceId) throws SearchServiceException {
        return listSearchClient.getModelDefinitions(sourceId);
    }

    @Override
    public ListModelDefinition getModelDefinition(String listId) throws SearchServiceException {
        return listSearchClient.getModelDefinition(listId);
    }

    @Override
    public Long getModuleVersion(String listId) throws SearchServiceException {
        return listSearchClient.getModuleVersion(listId);
    }

    @Override
    public String getModuleSystemId(String listId) throws SearchServiceException {
        return listSearchClient.getModuleSystemId(listId);
    }

    @Override
    public StreamResult<ListRecord> findAll(String listId, Query query) {
        return listServiceServiceStreamAspect.findAll(listId, query);
    }

    @Override
    public StreamResult<ListRecord> findAll(String listId, Query query, Integer maxRecord) {
        return listServiceServiceStreamAspect.findAll(listId, query, maxRecord);
    }

    @Override
    public ListRecord getFirstResult(String listId, Query query) throws QueryResultException {
        return listServiceServiceStreamAspect.getFirstResult(listId, query);
    }
}