Package net.engio.mbassy.bus

Class MessagePublication

java.lang.Object

net.engio.mbassy.bus.MessagePublication

All Implemented Interfaces:

IMessagePublication

public class MessagePublication
extends Object
implements IMessagePublication

A message publication is created for each asynchronous message dispatch. It reflects the state of the corresponding message publication process, i.e. provides information whether the publication was successfully scheduled, is currently running etc.

A message publication lives within a single thread. It is not designed in a thread-safe manner -> not eligible to be used in multiple threads simultaneously .

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MessagePublication.Factory
private static enum	MessagePublication.State

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	dispatched
private PublicationError	error
private final Object	message
private final BusRuntime	runtime
private MessagePublication.State	state
private final Collection<Subscription>	subscriptions

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	MessagePublication(BusRuntime runtime, Collection<Subscription> subscriptions, Object message, MessagePublication.State initialState)

Method Summary

Modifier and Type	Method	Description
boolean	add(Subscription subscription)
void	execute()
PublicationError	getError()
Object	getMessage()
boolean	hasError()
boolean	isDeadMessage()
boolean	isFilteredMessage()
boolean	isFinished()
boolean	isRunning()
boolean	isScheduled()
void	markDispatched()
void	markError(PublicationError error)
MessagePublication	markScheduled()

Methods inherited from class java.lang.Object

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

Field Details

subscriptions

private final Collection<Subscription> subscriptions

message

private final Object message

state

private volatile MessagePublication.State state

dispatched

private volatile boolean dispatched

runtime

private final BusRuntime runtime

error

private PublicationError error

Constructor Details

MessagePublication

protected MessagePublication(BusRuntime runtime,
 Collection<Subscription> subscriptions,
 Object message,
 MessagePublication.State initialState)

Method Details

add

public boolean add(Subscription subscription)

execute

public void execute()

Specified by:

execute in interface IMessagePublication

isFinished

public boolean isFinished()

Specified by:

isFinished in interface IMessagePublication

isRunning

public boolean isRunning()

Specified by:

isRunning in interface IMessagePublication

isScheduled

public boolean isScheduled()

Specified by:

isScheduled in interface IMessagePublication

hasError

public boolean hasError()

Specified by:

hasError in interface IMessagePublication

getError

public PublicationError getError()

Specified by:

getError in interface IMessagePublication

markDispatched

public void markDispatched()

markError

public void markError(PublicationError error)

markScheduled

public MessagePublication markScheduled()

isDeadMessage

public boolean isDeadMessage()

Specified by:

isDeadMessage in interface IMessagePublication

isFilteredMessage

public boolean isFilteredMessage()

Specified by:

isFilteredMessage in interface IMessagePublication

getMessage

public Object getMessage()

Specified by:

getMessage in interface IMessagePublication