Subversion Repositories XServices

import javax.servlet.ServletContext;

import javax.servlet.ServletContext;

import javax.xml.bind.JAXBContext;

import javax.xml.bind.JAXBContext;

import javax.xml.bind.JAXBElement;

import javax.xml.bind.JAXBElement;

import javax.xml.bind.JAXBException;

import javax.xml.bind.JAXBException;

import javax.xml.bind.Marshaller;

import javax.xml.bind.Marshaller;

import javax.xml.ws.WebServiceContext;

import javax.xml.ws.WebServiceContext;

import javax.xml.ws.handler.MessageContext;

import javax.xml.ws.handler.MessageContext;

import java.io.StringReader;

import java.io.StringReader;

import java.io.StringWriter;

import java.io.StringWriter;

import java.math.BigInteger;

import java.math.BigInteger;

public class MiscServiceImpl

public class MiscServiceImpl

  implements MiscService {

        implements MiscService {

  @Resource

    @Resource

  private WebServiceContext context;

    public MiscServiceImpl() throws SchedulerException {

    public MiscServiceImpl() throws SchedulerException {

    }

    }

  @Override

    @Override

    public BigInteger lock(String id, String objectId) throws XServicesFault {

    final String conString = "jdbc:h2:mem:lockdb;DB_CLOSE_DELAY=10;" +

        final String conString = "jdbc:h2:mem:lockdb;DB_CLOSE_DELAY=10;" +

            "INIT=CREATE SCHEMA IF NOT EXISTS brutex\\;" +

                "INIT=CREATE SCHEMA IF NOT EXISTS brutex\\;" +

  @Override

    @Override

  public ALFEventResponseType mergeALFEvent(ALFEventType event) throws XServicesFault {

    public ALFEventResponseType mergeALFEvent(ALFEventType event) throws XServicesFault {

    final Instant d = Instant.now();

        final Instant d = Instant.now();

    final long ts = d.toEpochMilli();

        final long ts = d.toEpochMilli();

    //Get Parameters from the Servlet Context

        //Get Parameters from the Servlet Context

    final ServletContext servletContext =

        final ServletContext servletContext =

            (ServletContext) context.getMessageContext().get(MessageContext.SERVLET_CONTEXT);

                (ServletContext) context.getMessageContext().get(MessageContext.SERVLET_CONTEXT);

    final EventmanagerConfiguration conf = (EventmanagerConfiguration) servletContext

        final EventmanagerConfiguration conf = (EventmanagerConfiguration) servletContext

    final String objectType = event.getBase().getObjectType();

        final String objectType = event.getBase().getObjectType();

    final String eventType = event.getBase().getEventType();

        final String eventType = event.getBase().getEventType();

    log.debug("Event id '{}', type '{}' received for object '{}' with object_id '{}'.",

        log.debug("Event id '{}', type '{}' received for object '{}' with object_id '{}'.",

            eventId, eventType, objectType, objectId);

                eventId, eventType, objectType, objectId);

    final String mergeStatememt = "MERGE INTO brutex.tbl_events " +

        final String mergeStatememt = "SELECT btx_id FROM OLD TABLE (MERGE INTO brutex.tbl_events " +

    try {

        try (Connection con = pool.getConnection()) {

      m.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, Boolean.TRUE);

            m.setProperty(Marshaller.JAXB_FRAGMENT, Boolean.TRUE);

      m.setProperty(Marshaller.JAXB_FRAGMENT, Boolean.TRUE);

            m.setProperty(Marshaller.JAXB_ENCODING, "UTF-8");

      JAXBElement<ALFEventType> e = of.createEventNotice(event);

            JAXBElement<ALFEventType> e = of.createALFEventNoticeDoc(event);

      StringWriter sw = new StringWriter();

            m.marshal(e, sw);

      m.marshal(e, sw);

            StringBuilder sb = new StringBuilder();

      StringBuilder sb = new StringBuilder();

                "xmlns:ns=\"http://www.eclipse.org/alf/schema/EventBase/1\">\n");

                    "xmlns:ns=\"http://www.eclipse.org/alf/schema/EventBase/1\">\n");

      sb.append("<ns:EventNotice>\n");

      sb.append(sw);

            sb.append(sw);

      sb.append("</soapenv:Body>");

            sb.append("</soapenv:Body>");

      sb.append("</soapenv:Envelope>");

            sb.append("</soapenv:Envelope>");

      Connection con = pool.getConnection();

      PreparedStatement prep = con.prepareStatement(mergeStatememt);

            PreparedStatement prep = con.prepareStatement(mergeStatememt);

      prep.setString(1, eventType);

            prep.setString(1, eventType);

      prep.setString(2, eventId);

            prep.setString(2, eventId);

      prep.setString(3, objectType);

            prep.setString(4, objectId);

      prep.setString(4, objectId);

            prep.setString(6, supersed_id);

      prep.setLong(5, ts);

            prep.setClob(7, new StringReader(sb.toString()));

      prep.setClob(6, new StringReader(sb.toString()));

            prep.execute();

      prep.execute();

            con.commit();

      con.commit();

            con.close();

      con.close();

            ingres_counter.incrementAndGet();

      ingres_counter.incrementAndGet();

                    .build();

                                .build();

            scheduler.scheduleJob(job2, t);

                        scheduler.scheduleJob(job2, t);

          }

                    }

      }

            }

    } catch (JAXBException | SQLException | SchedulerException e) {

        } catch (JAXBException | SQLException | SchedulerException e) {

        log.error(e.getMessage());

            log.error(e.getMessage());

        throw new XServicesFault(e);

            throw new XServicesFault(e);

    }

        }