pl.edu.agh.age.services.worker.internal

Class DefaultQueryProcessor<T extends java.io.Serializable>

java.lang.Object

pl.edu.agh.age.services.worker.internal.DefaultQueryProcessor<T>

All Implemented Interfaces:

QueryProcessor<T>, CommunicationFacility

@Named
public final class DefaultQueryProcessor<T extends java.io.Serializable>
extends java.lang.Object
implements QueryProcessor<T>, CommunicationFacility

Field Summary

Fields

Modifier and Type	Field and Description
private NodeIdentityService	identityService
private static org.slf4j.Logger	log
private ReplicatedMap<java.lang.String,T>	replicatedMap
private WorkerCommunication	workerCommunication

Constructor Summary

Constructors

Constructor and Description
DefaultQueryProcessor(NodeIdentityService identityService, HazelcastInstance hazelcastInstance, WorkerCommunication workerCommunication)

Method Summary

Modifier and Type	Method and Description
private void	destroy()
<V extends java.io.Serializable> boolean	onMessage(WorkerMessage<V> workerMessage) Handles a message.
java.util.stream.Stream<T>	query() Create a stream of objects to query.
void	reset()
void	schedule(java.util.concurrent.Callable<T> callable) Schedule a cache generator.
void	start()
java.util.Set<WorkerMessage.Type>	subscribedTypes() Returns a set of message types that this listener wants to subscribe to.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

log

private static final org.slf4j.Logger log

workerCommunication

private final WorkerCommunication workerCommunication

identityService

private final NodeIdentityService identityService

replicatedMap

private final ReplicatedMap<java.lang.String,T extends java.io.Serializable> replicatedMap

Constructor Detail

DefaultQueryProcessor

@Inject
public DefaultQueryProcessor(NodeIdentityService identityService,
                                     HazelcastInstance hazelcastInstance,
                                     WorkerCommunication workerCommunication)

Method Detail

destroy

@PreDestroy
private void destroy()
                          throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

query

public java.util.stream.Stream<T> query()

Description copied from interface: QueryProcessor

Create a stream of objects to query.

Specified by:

query in interface QueryProcessor<T extends java.io.Serializable>

Returns:

a stream.

schedule

public void schedule(java.util.concurrent.Callable<T> callable)

Description copied from interface: QueryProcessor

Schedule a cache generator.

Specified by:

schedule in interface QueryProcessor<T extends java.io.Serializable>

Parameters:

callable - callable that creates objects for future queries.

onMessage

public <V extends java.io.Serializable> boolean onMessage(WorkerMessage<V> workerMessage)

Description copied from interface: CommunicationFacility

Handles a message.

Only messages directed to this node will be passed with this method, so implementers do not need to check whether they are recipients.

Specified by:

onMessage in interface CommunicationFacility

Type Parameters:

V - a type of the payload.

Parameters:

workerMessage - a received message (for the current node).

Returns:

true if the message should be not processed anymore, false otherwise.

subscribedTypes

public java.util.Set<WorkerMessage.Type> subscribedTypes()

Description copied from interface: CommunicationFacility

Returns a set of message types that this listener wants to subscribe to.

Specified by:

subscribedTypes in interface CommunicationFacility

start

public void start()

Specified by:

start in interface CommunicationFacility

reset

public void reset()

Specified by:

reset in interface CommunicationFacility

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object