Package io.jans.service

Class BaseMessageService

java.lang.Object

io.jans.service.BaseMessageService

All Implemented Interfaces:

MessageInterface

Direct Known Subclasses:

MessageService

public abstract class BaseMessageService
extends Object
implements MessageInterface

Provides operations with messages

Author:

Yuriy Movchan Date: 30/11/2023

Field Summary

Fields

Modifier and Type	Field	Description
static int	DEFAULT_EXPIRATION

Constructor Summary

Constructors

Constructor	Description
BaseMessageService()

Method Summary

Modifier and Type	Method	Description
protected abstract MessageProvider	getMessageProvider()
boolean	publish(String channel, String message)
void	subscribe(PubSubInterface pubSubAdapter, String... channels)
void	unsubscribe(PubSubInterface pubSubAdapter)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_EXPIRATION

public static int DEFAULT_EXPIRATION

Constructor Details

BaseMessageService

public BaseMessageService()

Method Details

subscribe

public void subscribe(PubSubInterface pubSubAdapter,
 String... channels)

Specified by:

subscribe in interface MessageInterface

unsubscribe

public void unsubscribe(PubSubInterface pubSubAdapter)

Specified by:

unsubscribe in interface MessageInterface

publish

public boolean publish(String channel,
 String message)

Specified by:

publish in interface MessageInterface

getMessageProvider

protected abstract MessageProvider getMessageProvider()