ontologyeventprovider.java

一个基于sensor的中间件

package Utopia;

//~--- JDK imports ------------------------------------------------------------
import java.io.*;

import java.net.*;

import java.util.*;

/**
 * This class is used for saving the data getting from the sensors.
 * the provider_port correspond to the port in the SaveData.java
 * @author Administrator
 * @version 06/16/08
 */
class OntologyEventProvider {

    public final static int provider_port = 3800;
    protected static Vector nameVector = new Vector();
    protected static Vector eventVector = new Vector();
    protected static Vector query = new Vector();
    protected static Vector classcount = new Vector();
    BufferedReader bufferedReader;
    ServerSocket serverSock;
    Socket sock;
    ServerThread_Sensor serverThreadSensor;

    public OntologyEventProvider() {
    }

    public void OntologyEventProvider(String classname, ConThread cs, String rvquery) {

        try {
            eventVector.addElement(classname);
            nameVector.addElement(cs);
            query.addElement(rvquery);
        } catch (ConcurrentModificationException exception) {
            System.err.println(exception);
        }

        for (int i = 0; i < eventVector.size(); i++) {
            if (i == eventVector.size() - 1) {
                System.out.println("霌彪