Commit e89178f0 authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade métodos en la base de statestore 

Se renombra el método para hacerlo común y añade otro para obtener un
iterable para recorrer todos los elementos del statestore
parent b0e7b5a2

src/main/java/es/redmic/commandslib/streaming/statestore/StateStore.java

+9 −0
Original line number Diff line number Diff line
@@ -23,6 +23,7 @@ package es.redmic.commandslib.streaming.statestore; 
import org.apache.kafka.streams.KafkaStreams;

import org.apache.kafka.streams.StreamsBuilder;

import org.apache.kafka.streams.kstream.Materialized;

import org.apache.kafka.streams.state.KeyValueIterator;

import org.apache.kafka.streams.state.QueryableStoreTypes;

import org.apache.kafka.streams.state.ReadOnlyKeyValueStore;
@@ -56,4 +57,12 @@ public abstract class StateStore extends BaseStreams { 


		this.store = waitUntilStoreIsQueryable(topic, QueryableStoreTypes.<String, Event>keyValueStore(), streams);

	}



	public Event get(String id) {

		return this.store.get(id);

	}



	public KeyValueIterator<String, Event> getAll() {

		return this.store.all();

	}

}