pl.edu.agh.age.examples

Class SimpleWithQuery

java.lang.Object

pl.edu.agh.age.examples.SimpleWithQuery

All Implemented Interfaces:

java.lang.Runnable

public final class SimpleWithQuery
extends java.lang.Object
implements java.lang.Runnable

This example shows how the compute level can communicate between nodes using queries.

Query is a very general mechanism that simply makes it possible to schedule a callable to run every second and return any serializable data to be saved in a global cache.

Query is always performed on a current node but its results are available for all nodes (accessible using QueryProcessor.query() method).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	SimpleWithQuery.SampleCached

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	logger
private QueryProcessor<SimpleWithQuery.SampleCached>	queryProcessor

Constructor Summary

Constructors

Constructor and Description
SimpleWithQuery(QueryProcessor<SimpleWithQuery.SampleCached> queryProcessor)

Method Summary

Modifier and Type	Method and Description
void	run()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

logger

private static final org.slf4j.Logger logger

queryProcessor

private final QueryProcessor<SimpleWithQuery.SampleCached> queryProcessor

Constructor Detail

SimpleWithQuery

@Inject
public SimpleWithQuery(QueryProcessor<SimpleWithQuery.SampleCached> queryProcessor)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object