// Path: rdfagents-core/src/main/java/net/fortytwo/rdfagents/messaging/ConsumerCallback.java
// public interface ConsumerCallback<A> {
//     /**
//      * Indicates success of the query request and provides the query answer.
//      *
//      * @param answer the answer to the submitted query
//      */
//     void success(A answer);
// 
//     /**
//      * Indicates that the remote participant has agreed to answer the query.
//      */
//     void agreed();
// 
//     /**
//      * Indicates that the remote participant has refused to answer the query.
//      *
//      * @param explanation an explanation of the refusal, provided by the remote participant
//      */
//     void refused(ErrorExplanation explanation);
// 
//     /**
//      * Indicates that the remote participant has failed to answer the query.
//      *
//      * @param explanation an explanation of failure, provided by the remote participant
//      */
//     void remoteFailure(ErrorExplanation explanation);
// 
//     /**
//      * Indicates that a local exception has caused this interaction to fail.
//      *
//      * @param e the local exception which has occurred
//      */
//     void localFailure(LocalFailure e);
// }
// 
// Path: rdfagents-core/src/main/java/net/fortytwo/rdfagents/messaging/LocalFailure.java
// public class LocalFailure extends Exception {
//     public LocalFailure(final Throwable cause) {
//         super(cause);
//     }
// 
//     public LocalFailure(final String message) {
//         super(message);
//     }
// }
// 
// Path: rdfagents-core/src/main/java/net/fortytwo/rdfagents/model/Dataset.java
// public class Dataset {
//     public static final String UUID_URN_PREFIX = "urn:uuid:";
// 
//     private final Collection<Statement> statements;
// 
//     public Dataset(Collection<Statement> statements) {
//         this.statements = statements;
//     }
// 
//     public Collection<Statement> getStatements() {
//         return statements;
//     }
// }
// 
// Path: rdfagents-core/src/main/java/net/fortytwo/rdfagents/model/ErrorExplanation.java
// public class ErrorExplanation {
//     private final Type type;
//     private final String message;
// 
//     public enum Type {
//         ExternalError("external-error"),
//         InteractionExplired("interaction-expired"),
//         InternalError("internal-error"),
//         InvalidMessage("invalid-message"),
//         NotImplemented("not-implemented"),
//         Unavailable("unavailable");
// 
//         private final String fipaName;
// 
//         private Type(final String fipaName) {
//             this.fipaName = fipaName;
//         }
// 
//         public String getFipaName() {
//             return fipaName;
//         }
// 
//         public static Type getByFipaName(final String fipaName) {
//             for (Type t : values()) {
//                 if (t.fipaName.equals(fipaName)) {
//                     return t;
//                 }
//             }
// 
//             return null;
//         }
//     }
// 
//     public ErrorExplanation(final Type type,
//                             final String message) {
//         this.type = type;
//         this.message = message;
// 
//         if (null == type) {
//             throw new IllegalArgumentException("null type");
//         }
// 
//         if (null == message) {
//             throw new IllegalArgumentException("null message");
//         }
// 
//         if (0 == message.length()) {
//             throw new IllegalArgumentException("empty message");
//         }
//     }
// 
//     public Type getType() {
//         return type;
//     }
// 
//     public String getMessage() {
//         return message;
//     }
// 
//     public String toString() {
//         return type + " (" + message + ")";
//     }
// }


import eu.larkc.csparql.cep.api.RdfQuadruple;
import eu.larkc.csparql.cep.api.RdfStream;
import net.fortytwo.rdfagents.messaging.ConsumerCallback;
import net.fortytwo.rdfagents.messaging.LocalFailure;
import net.fortytwo.rdfagents.model.Dataset;
import net.fortytwo.rdfagents.model.ErrorExplanation;
import org.openrdf.model.Statement;
package net.fortytwo.rdfagents;


/**
 * @author Joshua Shinavier (http://fortytwo.net)
 */
public class CSPARQLConsumer extends RdfStream implements ConsumerCallback<Dataset> {

    public CSPARQLConsumer(String iri) {
        super(iri);
        // TODO Auto-generated constructor stub
    }

    @Override
    public void agreed() {
        // TODO Auto-generated method stub

    }

    @Override
// Path: rdfagents-core/src/main/java/net/fortytwo/rdfagents/messaging/ConsumerCallback.java
// public interface ConsumerCallback<A> {
//     /**
//      * Indicates success of the query request and provides the query answer.
//      *
//      * @param answer the answer to the submitted query
//      */
//     void success(A answer);
// 
//     /**
//      * Indicates that the remote participant has agreed to answer the query.
//      */
//     void agreed();
// 
//     /**
//      * Indicates that the remote participant has refused to answer the query.
//      *
//      * @param explanation an explanation of the refusal, provided by the remote participant
//      */
//     void refused(ErrorExplanation explanation);
// 
//     /**
//      * Indicates that the remote participant has failed to answer the query.
//      *
//      * @param explanation an explanation of failure, provided by the remote participant
//      */
//     void remoteFailure(ErrorExplanation explanation);
// 
//     /**
//      * Indicates that a local exception has caused this interaction to fail.
//      *
//      * @param e the local exception which has occurred
//      */
//     void localFailure(LocalFailure e);
// }
// 
// Path: rdfagents-core/src/main/java/net/fortytwo/rdfagents/messaging/LocalFailure.java
// public class LocalFailure extends Exception {
//     public LocalFailure(final Throwable cause) {
//         super(cause);
//     }
// 
//     public LocalFailure(final String message) {
//         super(message);
//     }
// }
// 
// Path: rdfagents-core/src/main/java/net/fortytwo/rdfagents/model/Dataset.java
// public class Dataset {
//     public static final String UUID_URN_PREFIX = "urn:uuid:";
// 
//     private final Collection<Statement> statements;
// 
//     public Dataset(Collection<Statement> statements) {
//         this.statements = statements;
//     }
// 
//     public Collection<Statement> getStatements() {
//         return statements;
//     }
// }
// 
// Path: rdfagents-core/src/main/java/net/fortytwo/rdfagents/model/ErrorExplanation.java
// public class ErrorExplanation {
//     private final Type type;
//     private final String message;
// 
//     public enum Type {
//         ExternalError("external-error"),
//         InteractionExplired("interaction-expired"),
//         InternalError("internal-error"),
//         InvalidMessage("invalid-message"),
//         NotImplemented("not-implemented"),
//         Unavailable("unavailable");
// 
//         private final String fipaName;
// 
//         private Type(final String fipaName) {
//             this.fipaName = fipaName;
//         }
// 
//         public String getFipaName() {
//             return fipaName;
//         }
// 
//         public static Type getByFipaName(final String fipaName) {
//             for (Type t : values()) {
//                 if (t.fipaName.equals(fipaName)) {
//                     return t;
//                 }
//             }
// 
//             return null;
//         }
//     }
// 
//     public ErrorExplanation(final Type type,
//                             final String message) {
//         this.type = type;
//         this.message = message;
// 
//         if (null == type) {
//             throw new IllegalArgumentException("null type");
//         }
// 
//         if (null == message) {
//             throw new IllegalArgumentException("null message");
//         }
// 
//         if (0 == message.length()) {
//             throw new IllegalArgumentException("empty message");
//         }
//     }
// 
//     public Type getType() {
//         return type;
//     }
// 
//     public String getMessage() {
//         return message;
//     }
// 
//     public String toString() {
//         return type + " (" + message + ")";
//     }
// }


// Path: rdfagents-csparql/src/main/java/net/fortytwo/rdfagents/CSPARQLConsumer.java
import eu.larkc.csparql.cep.api.RdfQuadruple;
import eu.larkc.csparql.cep.api.RdfStream;
import net.fortytwo.rdfagents.messaging.ConsumerCallback;
import net.fortytwo.rdfagents.messaging.LocalFailure;
import net.fortytwo.rdfagents.model.Dataset;
import net.fortytwo.rdfagents.model.ErrorExplanation;
import org.openrdf.model.Statement;

package net.fortytwo.rdfagents;


/**
 * @author Joshua Shinavier (http://fortytwo.net)
 */
public class CSPARQLConsumer extends RdfStream implements ConsumerCallback<Dataset> {

    public CSPARQLConsumer(String iri) {
        super(iri);
        // TODO Auto-generated constructor stub
    }

    @Override
    public void agreed() {
        // TODO Auto-generated method stub

    }

    @Override
    public void localFailure(LocalFailure arg0) {