/* HOLY FUCK I SUCK AT JAVA. */

/*  DataCallback.java   */
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface DataCallback {}





/*  ClientHandler.java  */

public void LogIn(WebSocketConnection con, String username, String password) {
    /* ... */
    /* DO A BUNCH OF SHIT */
    /* ... */
    /* THEN DO THIS SHIT: */

    db.Query("SELECT query_shit FROM myasshole", con, loginDataCallback.class );
}

public class loginDataCallback {
    @DataCallback
    public void onDataReceive( ResultSet rs, WebSocketConnection con ) {
        /* DO A BUNCH MORE SHIT */
        /* LOL?!?! */
    }
}



/*  MySQLHandler.java   */

public synchronized void Query( String query, WebSocketConnection conn, Class cb ) {
    QueueObject queueObj = new QueueObject( query, conn, cb );
    queue.add(queueObj);

    /* RUN THAT SHIT IF NOT ALREADY RUNNING, YO */
}


@Override
public void run() {
    QueueObject queueObj = null;
    Statement stmt = null;
    while ((queueObj = NextJob()) != null) {
        try {
            stmt = con.createStatement();
            /* HERE'S MY FUCKING PROBLEM LOL */
            /* HOW DO I CALL THIS SHIT? */
            queueObj.cb.onDataReceive( stmt.executeQuery( queueObj.query ), queueObj.con );
        } catch (SQLException ex) {}
    }
    running = false;
}


/* /cruisecontrol */