org.eclipse.kura.message.store.provider

Interface MessageStoreProvider

@ProviderType
public interface MessageStoreProvider

Represents a service that allows to create MessageStore instances.

Since:

2.5

Method Summary

Modifier and Type	Method and Description
void	addListener(ConnectionListener listener) Adds a ConnectionListener.
MessageStore	openMessageStore(java.lang.String name) Opens or creates a MessageStore instance with the given name.
void	removeListener(ConnectionListener listener) Removes a ConnectionListener

Method Detail

openMessageStore

MessageStore openMessageStore(java.lang.String name)
                       throws KuraStoreException

Opens or creates a MessageStore instance with the given name. Invoking this method could allocate the resources required to support the returned MessageStore instance (for example tables in a RDBMS).*

Parameters:

name - the store name.

Returns:

the opened MessageStore

Throws:

KuraStoreException

addListener

void addListener(ConnectionListener listener)

Adds a ConnectionListener. A typical behavior of a client of this listener is to close the currently open MessageStore instances when a ConnectionListener.disconnected() event is received.

Parameters:

listener - to add

Since:

2.5.0

removeListener

void removeListener(ConnectionListener listener)

Removes a ConnectionListener

Parameters:

listener - to remove

Since:

2.5.0