MCPcopy Create free account

hub / github.com/Splitet/SplitetFramework / functions

Functions386 in github.com/Splitet/SplitetFramework

MethodonPartitionsAssigned
(Map<TopicPartition, Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback)
emon-lib/src/main/java/io/splitet/core/api/emon/service/EventListener.java:46
MethodonPartitionsAssigned
(Collection<TopicPartition> partitions)
emon-lib/src/main/java/io/splitet/core/api/emon/service/MultipleEventMessageListener.java:48
MethodonPartitionsRevoked
(Collection<TopicPartition> partitions)
emon-lib/src/main/java/io/splitet/core/api/emon/service/MultipleEventMessageListener.java:43
MethodopIdInterceptor
(@Autowired OperationContext operationContext)
spring-integration/src/main/java/io/splitet/core/spring/configuration/EventApisFactory.java:82
MethodoperationExpirationListener
(@Autowired @Qualifier("operationsHistoryMap") IMap<String, Topology> operationsHistoryMap,
emon-lib/src/main/java/io/splitet/core/api/emon/configuration/InMemoryComponents.java:77
MethodoperationListenerContainer
()
emon-lib/src/main/java/io/splitet/core/api/emon/configuration/EventListenConfiguration.java:52
MethodoperationsHistoryMap
(@Autowired @Qualifier("hazelcastInstance") HazelcastInstance hazelcastInstance)
emon-lib/src/main/java/io/splitet/core/api/emon/configuration/hazelcast/MapsConfig.java:71
MethodoperationsKafkaListenerContainerFactory
( ConsumerFactory<String, Operation> consumerFactory)
spring-integration/src/main/java/io/splitet/core/spring/configuration/EventApisFactory.java:159
MethodoperationsMap
(@Autowired @Qualifier("hazelcastInstance") HazelcastInstance hazelcastInstance, OperationExpirationListener o
emon-lib/src/main/java/io/splitet/core/api/emon/configuration/hazelcast/MapsConfig.java:63
MethodoperationsTopic
(@Autowired @Qualifier("hazelcastInstance") HazelcastInstance hazelcastInstance)
emon-lib/src/main/java/io/splitet/core/api/emon/configuration/hazelcast/MapsConfig.java:89
MethodpostConstruct
()
emon/src/main/java/io/splitet/core/api/emon/service/OperationsBroadcaster.java:26
Methodprepare
(String statement)
java-api/src/main/java/io/splitet/core/cassandra/CassandraSession.java:147
Methodprocess
(Map.Entry entry)
emon-lib/src/test/java/io/splitet/core/pojos/OperationTest.java:22
Methodprocess
(Map.Entry<String, Topology> entry)
emon-lib/src/main/java/io/splitet/core/api/emon/service/TopologyService.java:122
Methodprocess
(Map.Entry<String, Topology> entry)
emon-lib/src/main/java/io/splitet/core/api/emon/service/TopologyService.java:159
Methodprocess
(Map.Entry<String, Topic> entry)
emon-lib/src/main/java/io/splitet/core/api/emon/service/processor/ConsumerOffsetChangeEntryProcessor.java:25
Methodprocess
(Map.Entry<String, Topic> entry)
emon-lib/src/main/java/io/splitet/core/api/emon/service/processor/EndOffsetSetter.java:23
MethodpublishEvent
(String topic, String event, long opDate)
java-api/src/main/java/io/splitet/core/kafka/KafkaOperationRepository.java:70
MethodqueryByOpId
(String opId)
java-api/src/main/java/io/splitet/core/cassandra/OptimizedCassandraViewQuery.java:53
MethodqueryByOpId
(String opId)
java-api/src/main/java/io/splitet/core/cassandra/BaseCassandraViewQuery.java:160
MethodqueryEvent
(String entityId, int version)
java-api/src/main/java/io/splitet/core/api/ViewQuery.java:32
MethodqueryEventData
(String entityId, int version)
java-api/src/main/java/io/splitet/core/api/ViewQuery.java:34
MethodqueryEventData
(String entityId, int version)
java-api/src/main/java/io/splitet/core/cassandra/BaseCassandraViewQuery.java:214
MethodqueryEventKeysByOpId
(String opId)
java-api/src/main/java/io/splitet/core/cassandra/OptimizedCassandraViewQuery.java:68
MethodqueryEventKeysByOpId
(String opId)
java-api/src/main/java/io/splitet/core/cassandra/BaseCassandraViewQuery.java:221
MethodqueryHistory
(String entityId)
java-api/src/main/java/io/splitet/core/api/ViewQuery.java:30
MethodqueryHistory
(String entityId)
java-api/src/main/java/io/splitet/core/cassandra/BaseCassandraViewQuery.java:151
MethodreadExternal
(ObjectInput in)
java-api/src/main/java/io/splitet/core/pojos/Event.java:30
MethodrecordAndPublish
(P publishedEvent)
java-api/src/main/java/io/splitet/core/core/CompositeRepositoryImpl.java:49
MethodrecordEntityEvent
( R event, long opDate, Optional<EventKey> previousEventKey, S
java-api/src/main/java/io/splitet/core/cassandra/CassandraEventRecorder.java:132
Methodrecover
(Exception exception)
spring-integration/src/main/java/io/splitet/core/spring/configuration/SpringKafkaOpListener.java:30
MethodregexpTest
()
emon-lib/src/test/java/io/splitet/core/pojos/OperationTest.java:39
MethodregexpTest2
()
emon-lib/src/test/java/io/splitet/core/pojos/OperationTest.java:51
MethodregisterSeekCallback
(ConsumerSeekAware.ConsumerSeekCallback callback)
emon-lib/src/main/java/io/splitet/core/api/emon/service/ConsumerOffsetListener.java:83
MethodregisterSeekCallback
(ConsumerSeekCallback callback)
emon-lib/src/main/java/io/splitet/core/api/emon/service/MultipleEventMessageListener.java:53
Methodrollback
(CommandRecord record)
java-api/src/main/java/io/splitet/core/api/RollbackCommandSpec.java:33
Methodrollback
(TransactionStatus status)
spring-integration/src/main/java/io/splitet/core/spring/configuration/EventApisFactory.java:211
Methodserialize
(String topic, T data)
java-api/src/main/java/io/splitet/core/kafka/JsonSerializer.java:47
MethodsetConsumerGroupRegex
(Pattern consumerGroupRegex)
emon-lib/src/main/java/io/splitet/core/api/emon/service/ConsumerOffsetListener.java:70
MethodsetEvent
(ObjectNode event)
java-api/src/main/java/io/splitet/core/kafka/PublishedEventWrapper.java:46
MethodsetEventTopicRegex
(Pattern eventTopicRegex)
emon-lib/src/main/java/io/splitet/core/api/emon/service/ConsumerOffsetListener.java:65
MethodsetKeyPassword
(String keyPassword)
java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:381
MethodsetKeystoreLocation
(String keystoreLocation)
java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:389
MethodsetKeystorePassword
(String keystorePassword)
java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:397
MethodsetLeafs
(ProducedEvent producedEvent)
emon-lib/src/main/java/io/splitet/core/api/emon/service/OperationExpirationListener.java:52
MethodsetOperation
(OperationEvent operation)
emon-lib/src/main/java/io/splitet/core/api/emon/domain/ProducedEvent.java:118
MethodsetOperation
(OperationEvent operation)
emon-lib/src/main/java/io/splitet/core/api/emon/domain/NoneHandled.java:31
MethodsetOperation
(OperationEvent operation)
emon-lib/src/main/java/io/splitet/core/api/emon/domain/IProducedEvent.java:24
MethodsetParameters
(Map<Integer, JsonNode> parameters)
java-api/src/main/java/io/splitet/core/pojos/CommandRecord.java:22
MethodsetPartitions
(List<Partition> value)
emon-lib/src/main/java/io/splitet/core/api/emon/domain/Topic.java:56
MethodsetTruststoreLocation
(String truststoreLocation)
java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:405
MethodsetTruststorePassword
(String truststorePassword)
java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:413
MethodsetUp
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:87
MethodshouldClearCommandContext
()
java-api/src/test/java/io/splitet/core/common/OperationContextTest.java:74
MethodshouldClearContext
()
java-api/src/test/java/io/splitet/core/common/OperationContextTest.java:63
MethodshouldClearUserContext
()
java-api/src/test/java/io/splitet/core/api/impl/EmptyUserContextTest.java:44
MethodshouldExtractUserContext
()
java-api/src/test/java/io/splitet/core/api/impl/EmptyUserContextTest.java:32
MethodshouldFailOperationWithFailEvent
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:226
MethodshouldGenerateContext
()
java-api/src/test/java/io/splitet/core/common/OperationContextTest.java:85
MethodshouldGetAuditInfo
()
java-api/src/test/java/io/splitet/core/api/impl/EmptyUserContextTest.java:55
MethodshouldGetCommandContext
()
java-api/src/test/java/io/splitet/core/common/OperationContextTest.java:43
MethodshouldGetContext
()
java-api/src/test/java/io/splitet/core/common/OperationContextTest.java:33
MethodshouldGetNextId
()
java-api/src/test/java/io/splitet/core/api/impl/UUIDCreationStrategyTest.java:19
MethodshouldGetUserContext
()
java-api/src/test/java/io/splitet/core/api/impl/EmptyUserContextTest.java:21
MethodshouldMarkFail
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:106
MethodshouldRecordAndPublishWithPreviousEventAndPublishedEvent
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:139
MethodshouldRecordAndPublishWithPreviousEventAndPublishedEventAndConcurrencyResolverFactory
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:173
MethodshouldRecordAndPublishWithPreviousEventKeyAndPublishedEvent
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:157
MethodshouldRecordAndPublishWithPreviousEventKeyAndPublishedEventAndConcurrencyResolverFactory
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:193
MethodshouldRecordAndPublishWithPublishedEvent
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:126
MethodshouldSetCommandContext
()
java-api/src/test/java/io/splitet/core/common/OperationContextTest.java:53
MethodshouldSuccessOperationWithSuccessEvent
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:211
MethodshouldSwitchContext
()
java-api/src/test/java/io/splitet/core/common/OperationContextTest.java:23
MethodshouldThrowExceptionWhenObjectWriterThrowsException
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:241
MethodsnapshotOnly
(String entityId)
spring-integration/src/main/java/io/splitet/core/spring/configuration/DataMigrationService.java:39
MethodsuccessOperation
(String eventId, SerializableConsumer<Event> action)
java-api/src/main/java/io/splitet/core/kafka/KafkaOperationRepository.java:57
MethodtestCalculateNext
()
java-api/src/test/java/io/splitet/core/cassandra/DefaultConcurrencyResolverTest.java:29
MethodtestReadWriteExternal
()
emon-lib/src/test/java/io/splitet/core/pojos/OperationTest.java:17
MethodtestReadWriteExternal
()
emon/src/test/java/io/splitet/core/pojos/OperationTest.java:9
MethodtestTryMore
()
java-api/src/test/java/io/splitet/core/cassandra/DefaultConcurrencyResolverTest.java:19
MethodtopicsMap
(@Autowired @Qualifier("hazelcastInstance") HazelcastInstance hazelcastInstance)
emon-lib/src/main/java/io/splitet/core/api/emon/configuration/hazelcast/MapsConfig.java:77
MethodtryMore
()
java-api/src/main/java/io/splitet/core/cassandra/ConcurrentEventResolver.java:10
MethodtryMore
()
java-api/src/main/java/io/splitet/core/cassandra/DefaultConcurrencyResolver.java:7
MethodupdateEvent
(EventKey eventKey, @Nullable RecordedEvent newEventData, @Nullable EventState newEventState, @Nullable String
java-api/src/main/java/io/splitet/core/cassandra/CassandraEventRecorder.java:190
MethodupdateEvent
(EventKey eventKey, boolean snapshot, @Nullable RecordedEvent newEventData, @Nullable EventState newEventState
spring-integration/src/main/java/io/splitet/core/spring/configuration/DataMigrationService.java:27
MethodwriteExternal
(ObjectOutput out)
java-api/src/main/java/io/splitet/core/pojos/Event.java:25
← previous301–386 of 386, ranked by callers