org.springframework.integration.x.kafka

Class NamespaceDelegatingMetadataStore

java.lang.Object

org.springframework.integration.x.kafka.NamespaceDelegatingMetadataStore

All Implemented Interfaces:

org.springframework.integration.metadata.MetadataStore

public class NamespaceDelegatingMetadataStore
extends java.lang.Object
implements org.springframework.integration.metadata.MetadataStore

Wraps a delegate MetadataStore and adds a prefix to all the handled keys. Useful for sharing the same MetadataStore or underlying location without interference between clients.

Author:

Marius Bogoevici

Constructor Summary

Constructors

Constructor and Description
NamespaceDelegatingMetadataStore(org.springframework.integration.metadata.MetadataStore delegate, java.lang.String namespace)

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	get(java.lang.String key)
void	put(java.lang.String key, java.lang.String value)
java.lang.String	remove(java.lang.String key)

Methods inherited from class java.lang.Object

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

Constructor Detail

NamespaceDelegatingMetadataStore

public NamespaceDelegatingMetadataStore(org.springframework.integration.metadata.MetadataStore delegate,
                                java.lang.String namespace)

Method Detail

put

public void put(java.lang.String key,
       java.lang.String value)

Specified by:

put in interface org.springframework.integration.metadata.MetadataStore

get

@ManagedAttribute
public java.lang.String get(java.lang.String key)

Specified by:

get in interface org.springframework.integration.metadata.MetadataStore

remove

@ManagedAttribute
public java.lang.String remove(java.lang.String key)

Specified by:

remove in interface org.springframework.integration.metadata.MetadataStore