io.spine.server.transport.memory

Class InMemoryPublisher

java.lang.Object

io.spine.server.transport.AbstractChannel

io.spine.server.transport.memory.InMemoryPublisher

All Implemented Interfaces:

MessageChannel, Publisher, java.lang.AutoCloseable

public final class InMemoryPublisher
extends AbstractChannel
implements Publisher

An in-memory implementation of the Publisher.

To use only in scope of the same JVM as subscribers.

Method Summary

Modifier and Type	Method and Description
void	close() Does nothing as there are no resources to close in the in-memory implementation.
boolean	isStale() Always returns false as publishers don't get stale.
io.spine.core.Ack	publish(com.google.protobuf.Any messageId, io.spine.server.integration.ExternalMessage message) Publishes a given ExternalMessage to the channel under a given ID.

Methods inherited from class io.spine.server.transport.AbstractChannel

id

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.spine.server.transport.MessageChannel

channelIdFor, id, targetType

Method Detail

publish

public io.spine.core.Ack publish(com.google.protobuf.Any messageId,
                                 io.spine.server.integration.ExternalMessage message)

Description copied from interface: Publisher

Publishes a given ExternalMessage to the channel under a given ID.

Specified by:

publish in interface Publisher

Parameters:

messageId - an ID of the message packed into Any.

message - the message to publish

Returns:

an acknowledgment of message publishing

See Also:

Ack

isStale

public boolean isStale()

Always returns false as publishers don't get stale.

Specified by:

isStale in interface MessageChannel

Returns:

false always.

close

public void close()

Does nothing as there are no resources to close in the in-memory implementation.

Specified by:

close in interface java.lang.AutoCloseable