Package com.smeup.jardis.endpoint

Class JardisMemory<R,E>

java.lang.Object

com.smeup.jardis.endpoint.JardisEndPoint

com.smeup.jardis.endpoint.JardisMemory<R,E>

Type Parameters:

E - event type

R - response type

Direct Known Subclasses:

JardisMemoryDap, JardisMemoryLsp

public abstract class JardisMemory<R,E>
extends JardisEndPoint

This class creates an instance of jardis in memory. You can use it for test purposes.

Author:

lana

Field Summary

Fields inherited from class com.smeup.jardis.endpoint.JardisEndPoint

configuration

Constructor Summary

Constructors

Constructor	Description
JardisMemory()
JardisMemory(com.smeup.jardis.core.JardisConfiguration jardisConfiguration)

Method Summary

Modifier and Type	Method	Description
abstract com.smeup.jardis.core.commons.JardisResponse<R>	convertJardisResponse(R r)
void	dispatchBroadcastMessage(com.smeup.jardis.core.Message message)	Send a broadcast message to all instances of Handler
boolean	dispatchConsumableMessage(com.smeup.jardis.core.Message message)	Sends a consumable message to all instances of Handler Dispathing is blocked if message is consumed by an Handler
abstract boolean	isEvent(Object payload)
abstract void	notifyLocker(StringBuilder locker)
void	onChannelEvent(Consumer<E> event)
<T> T	sendObject(Object object, Class<T> responseType)
void	shutdown()
void	start()

Methods inherited from class com.smeup.jardis.endpoint.JardisEndPoint

getConfiguration

Methods inherited from class java.lang.Object

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

Constructor Detail

JardisMemory

public JardisMemory(com.smeup.jardis.core.JardisConfiguration jardisConfiguration)

JardisMemory

public JardisMemory()

Method Detail

convertJardisResponse

public abstract com.smeup.jardis.core.commons.JardisResponse<R> convertJardisResponse(R r)

isEvent

public abstract boolean isEvent(Object payload)

notifyLocker

public abstract void notifyLocker(StringBuilder locker)

start

public void start()

Specified by:

start in class JardisEndPoint

shutdown

public void shutdown()

Specified by:

shutdown in class JardisEndPoint

dispatchConsumableMessage

public boolean dispatchConsumableMessage(com.smeup.jardis.core.Message message)

Description copied from class: JardisEndPoint

Sends a consumable message to all instances of Handler Dispathing is blocked if message is consumed by an Handler

Specified by:

dispatchConsumableMessage in class JardisEndPoint

Parameters:

message - The message

Returns:

true if one Handler consumed the message, false elsewhere

dispatchBroadcastMessage

public void dispatchBroadcastMessage(com.smeup.jardis.core.Message message)

Description copied from class: JardisEndPoint

Send a broadcast message to all instances of Handler

Specified by:

dispatchBroadcastMessage in class JardisEndPoint

Parameters:

message - The message

onChannelEvent

public void onChannelEvent(Consumer<E> event)

sendObject

public <T> T sendObject(Object object,
                        Class<T> responseType)
                 throws IOException,
                        InterruptedException

Throws:

IOException

InterruptedException