pl.edu.agh.age.services.worker

Class WorkerMessage<T extends java.io.Serializable>

java.lang.Object

pl.edu.agh.age.services.worker.WorkerMessage<T>

Type Parameters:

T - the payload type.

All Implemented Interfaces:

java.io.Serializable

public final class WorkerMessage<T extends java.io.Serializable>
extends java.lang.Object
implements java.io.Serializable

Message exchanged between WorkerServices.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WorkerMessage.Type

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	broadcast
private T	payload
private ImmutableSet<java.lang.String>	recipients
private static long	serialVersionUID
private WorkerMessage.Type	type

Constructor Summary

Constructors

Constructor and Description
WorkerMessage(WorkerMessage.Type type, java.util.Set<java.lang.String> recipients, T payload)
WorkerMessage(WorkerMessage.Type type, T payload)

Method Summary

Modifier and Type	Method and Description
static WorkerMessage<java.io.Serializable>	createBroadcastWithoutPayload(WorkerMessage.Type type)
static <T extends java.io.Serializable> WorkerMessage<T>	createBroadcastWithPayload(WorkerMessage.Type type, T payload)
static WorkerMessage<java.io.Serializable>	createWithoutPayload(WorkerMessage.Type type, java.util.Set<java.lang.String> recipients)
static <T extends java.io.Serializable> WorkerMessage<T>	createWithPayload(WorkerMessage.Type type, java.util.Set<java.lang.String> recipients, T payload)
boolean	hasType(WorkerMessage.Type typeToCheck)
boolean	isBroadcast()
boolean	isRecipient(java.lang.String id)
<X extends T> java.util.Optional<X>	payload()
java.util.Set<java.lang.String>	recipients()
java.io.Serializable	requiredPayload()
java.lang.String	toString()
WorkerMessage.Type	type()

Methods inherited from class java.lang.Object

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

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

type

private final WorkerMessage.Type type

broadcast

private final boolean broadcast

recipients

private final ImmutableSet<java.lang.String> recipients

payload

private final T extends java.io.Serializable payload

Constructor Detail

WorkerMessage

WorkerMessage(WorkerMessage.Type type,
              T payload)

WorkerMessage

WorkerMessage(WorkerMessage.Type type,
              java.util.Set<java.lang.String> recipients,
              T payload)

Method Detail

createBroadcastWithoutPayload

public static WorkerMessage<java.io.Serializable> createBroadcastWithoutPayload(WorkerMessage.Type type)

createWithoutPayload

public static WorkerMessage<java.io.Serializable> createWithoutPayload(WorkerMessage.Type type,
                                                                       java.util.Set<java.lang.String> recipients)

createBroadcastWithPayload

public static <T extends java.io.Serializable> WorkerMessage<T> createBroadcastWithPayload(WorkerMessage.Type type,
                                                                                           T payload)

createWithPayload

public static <T extends java.io.Serializable> WorkerMessage<T> createWithPayload(WorkerMessage.Type type,
                                                                                  java.util.Set<java.lang.String> recipients,
                                                                                  T payload)

type

public WorkerMessage.Type type()

hasType

public boolean hasType(WorkerMessage.Type typeToCheck)

payload

public <X extends T> java.util.Optional<X> payload()

requiredPayload

public java.io.Serializable requiredPayload()

recipients

public java.util.Set<java.lang.String> recipients()

isRecipient

public boolean isRecipient(java.lang.String id)

isBroadcast

public boolean isBroadcast()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object