Update of /cvsroot/bprocessor/model/src/net/sourceforge/bprocessor/model/sense/core
In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv20256/src/net/sourceforge/bprocessor/model/sense/core
Added Files:
History.java Target.java package.html Sensor.java
Provider.java Consumer.java Producer.java Measurement.java
Log Message:
--- NEW FILE: Producer.java ---
package net.sourceforge.bprocessor.model.sense.core;
import java.util.LinkedList;
import java.util.List;
public class Producer {
private List<Consumer> consumers;
public Producer() {
consumers = new LinkedList<Consumer>();
}
public void add(Consumer consumer) {
consumers.add(consumer);
}
public void remove(Consumer consumer) {
consumers.remove(consumer);
}
public void consume(Measurement value) {
for (Consumer current : consumers) {
current.consume(value);
}
}
}
--- NEW FILE: Measurement.java ---
package net.sourceforge.bprocessor.model.sense.core;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
public class Measurement {
private long time;
private String value;
public Measurement() {
}
public Measurement(long time, String value) {
this.time = time;
this.value = value;
}
public void setTime(long value) {
time = value;
}
public long getTime() {
return time;
}
public void setValue(String string) {
value = string;
}
public String getValue() {
return value;
}
public String toString() {
DateFormat format = new SimpleDateFormat("yyyy.MM.dd HH:mm:ss");
String str = format.format(new Date(time));
return "(" + str + " | " + value + ")";
}
}
--- NEW FILE: History.java ---
package net.sourceforge.bprocessor.model.sense.core;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public abstract class History {
public abstract List<Measurement> fetch(Target target, Sensor sensor, Date from);
public abstract List<Measurement> fetch(Target target, Sensor sensor, Date from, Date to);
public Map<Sensor, List<Measurement>> fetch(Target target, Date from) {
Map<Sensor, List<Measurement>> result = new HashMap<Sensor, List<Measurement>>();
for (Sensor current : target.getSensors()) {
result.put(current, fetch(target, current, from));
}
return result;
}
public Map<Sensor, List<Measurement>> fetch(Target target, Date from, Date to) {
Map<Sensor, List<Measurement>> result = new HashMap<Sensor, List<Measurement>>();
for (Sensor current : target.getSensors()) {
result.put(current, fetch(target, current, from, to));
}
return result;
}
}
--- NEW FILE: Sensor.java ---
package net.sourceforge.bprocessor.model.sense.core;
public class Sensor {
private String id;
private String type;
public Sensor() {
}
public Sensor(String id, String type) {
this.id = id;
this.type = type;
}
public void setId(String value) {
id = value;
}
public String getId() {
return id;
}
public void setType(String value) {
type = value;
}
public String getType() {
return type;
}
}
--- NEW FILE: Target.java ---
package net.sourceforge.bprocessor.model.sense.core;
import java.util.LinkedList;
import java.util.List;
public class Target {
private String id;
List<Sensor> sensors;
public Target() {
}
public Target(String id) {
this.id = id;
sensors = new LinkedList<Sensor>();
}
public void setId(String value) {
id = value;
}
public String getId() {
return id;
}
public void setSensors(List<Sensor> value) {
sensors = value;
}
public List<Sensor> getSensors() {
return sensors;
}
}
--- NEW FILE: package.html ---
<body>
Defines the package that contains the model
</body>
--- NEW FILE: Provider.java ---
package net.sourceforge.bprocessor.model.sense.core;
public class Provider {
}
--- NEW FILE: Consumer.java ---
package net.sourceforge.bprocessor.model.sense.core;
public abstract class Consumer {
public abstract void consume(Measurement value);
}
|
