xuml.tools.model.compiler.runtime

Class Signaller

java.lang.Object

xuml.tools.model.compiler.runtime.Signaller

public class Signaller
extends Object

Constructor Summary

Constructors

Constructor and Description
Signaller(javax.persistence.EntityManagerFactory emf, int entityActorPoolSize, SignalProcessorListenerFactory listenerFactory)

Method Summary

Modifier and Type	Method and Description
<T> void	cancelSignal(String fromEntityUniqueId, Entity<T> entity, String eventSignatureKey)
void	close()
<T extends Entity<T>> T	create(Class<T> cls, CreationEvent<T> event) Returns a new instance of type T using the given CreationEvent.
javax.persistence.EntityManagerFactory	getEntityManagerFactory()
Info	getInfo()
<T extends Entity<T>> String	persistSignal(String fromEntityUniqueId, Object id, Class<T> cls, Event<T> event, long time, com.google.common.base.Optional<Long> repeatIntervalMs, String entityUniqueId)
List<QueuedSignal>	queuedSignals()
long	queueSize()
int	sendSignalsInQueue()
<T extends Entity<T>> void	signal(String fromEntityUniqueId, Entity<T> entity, Event<T> event, Long time, com.google.common.base.Optional<scala.concurrent.duration.FiniteDuration> repeatInterval)
<T extends Entity<T>> void	signal(String fromEntityUniqueId, Entity<T> entity, Event<T> event, com.google.common.base.Optional<scala.concurrent.duration.Duration> delay)
<T extends Entity<T>> void	signal(String fromEntityUniqueId, Entity<T> entity, Event<T> event, com.google.common.base.Optional<scala.concurrent.duration.Duration> delay, com.google.common.base.Optional<scala.concurrent.duration.FiniteDuration> repeatInterval)
scala.concurrent.Future<akka.actor.Terminated>	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

Signaller

public Signaller(javax.persistence.EntityManagerFactory emf,
                 int entityActorPoolSize,
                 SignalProcessorListenerFactory listenerFactory)

Method Detail

getEntityManagerFactory

public javax.persistence.EntityManagerFactory getEntityManagerFactory()

create

public <T extends Entity<T>> T create(Class<T> cls,
                                      CreationEvent<T> event)

Returns a new instance of type T using the given CreationEvent. This is a synchronous creation using a newly created then closed EntityManager for persisting the entity. If you need finer grained control of commits then open your own entity manager and do the the persist yourself.

Parameters:

cls -

event -

Returns:

signal

public <T extends Entity<T>> void signal(String fromEntityUniqueId,
                                         Entity<T> entity,
                                         Event<T> event,
                                         com.google.common.base.Optional<scala.concurrent.duration.Duration> delay)

signal

public <T extends Entity<T>> void signal(String fromEntityUniqueId,
                                         Entity<T> entity,
                                         Event<T> event,
                                         Long time,
                                         com.google.common.base.Optional<scala.concurrent.duration.FiniteDuration> repeatInterval)

signal

public <T extends Entity<T>> void signal(String fromEntityUniqueId,
                                         Entity<T> entity,
                                         Event<T> event,
                                         com.google.common.base.Optional<scala.concurrent.duration.Duration> delay,
                                         com.google.common.base.Optional<scala.concurrent.duration.FiniteDuration> repeatInterval)

cancelSignal

public <T> void cancelSignal(String fromEntityUniqueId,
                             Entity<T> entity,
                             String eventSignatureKey)

queuedSignals

public List<QueuedSignal> queuedSignals()

sendSignalsInQueue

public int sendSignalsInQueue()

queueSize

public long queueSize()

persistSignal

public <T extends Entity<T>> String persistSignal(String fromEntityUniqueId,
                                                  Object id,
                                                  Class<T> cls,
                                                  Event<T> event,
                                                  long time,
                                                  com.google.common.base.Optional<Long> repeatIntervalMs,
                                                  String entityUniqueId)

getInfo

public Info getInfo()

stop

public scala.concurrent.Future<akka.actor.Terminated> stop()

close

public void close()