Package com.caplin.motif.datasource

Class ObjectPublisher<S>

java.lang.Object

com.caplin.motif.datasource.ObjectPublisher<S>

Type Parameters:

S - the type of object this publisher publishes

public class ObjectPublisher<S>
extends Object

Publishes objects by serialising before sending on the wire.

Constructor Summary

Constructors

Constructor	Description
ObjectPublisher(@NotNull SubjectMessagePublisher<SubjectInfo> publisher, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method	Description
void	publish(String subject, S object)	Publish the specified object to clients subscribed to the specified subject.
void	publishError(SubjectInfo subjectInfo, com.caplin.datasource.SubjectError subjectError)	Publish the specified error to clients subscribed to the specified subject.
void	publishStatus(SubjectInfo subjectInfo, com.caplin.datasource.SubjectStatus subjectStatus)	Publish the specified SubjectStatus to clients subscribed to the specified subject.

Methods inherited from class java.lang.Object

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

Constructor Detail

ObjectPublisher

public ObjectPublisher(@NotNull
                       @NotNull SubjectMessagePublisher<SubjectInfo> publisher,
                       com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Detail

publish

public void publish(String subject,
                    S object)

Publish the specified object to clients subscribed to the specified subject.

Parameters:

subject - the subject to publish the object on

object - the object to publish

publishError

public void publishError(SubjectInfo subjectInfo,
                         com.caplin.datasource.SubjectError subjectError)

Publish the specified error to clients subscribed to the specified subject.

Parameters:

subjectInfo -

subjectError -

publishStatus

public void publishStatus(SubjectInfo subjectInfo,
                          com.caplin.datasource.SubjectStatus subjectStatus)

Publish the specified SubjectStatus to clients subscribed to the specified subject.

Parameters:

subjectInfo -

subjectStatus -