ganeshs

public static class BulkHandler implements Handler, Runnable {
        
        private BlockingQueue<Record> queue = new LinkedBlockingQueue<>(1000);
        
        public BulkHandler() {
            new Thread(this).start();
        }

        @Override
        public Status process(Record record) {

ganeshs

/**
 * 
 */
package com.simplexlogistics.core.domain;

import java.sql.SQLException;

import org.eclipse.persistence.config.SessionCustomizer;
import org.eclipse.persistence.descriptors.ClassDescriptor;
import org.eclipse.persistence.internal.helper.DatabaseField;