fixed

Author: Wessam100

FiniteStateMachine/etc/FiniteStateMachine.urm.puml

@@ -0,0 +1,34 @@
+@startuml
+package com.iluwatar.trafficlight {
+  class GreenLightState {
+    + GreenLightState()
+    + handleEvent(context : TrafficLightContext)
+  }
+  class RedLightState {
+    + RedLightState()
+    + handleEvent(context : TrafficLightContext)
+  }
+  class TrafficLightContext {
+    - currentState : TrafficLightState
+    + TrafficLightContext(initialState : TrafficLightState)
+    + getCurrentState() : TrafficLightState
+    + handleEvent()
+    + setState(newState : TrafficLightState)
+  }
+  class TrafficLightFsm {
+    + TrafficLightFsm()
+    + main(args : String[]) {static}
+  }
+  interface TrafficLightState {
+    + handleEvent(TrafficLightContext) {abstract}
+  }
+  class YellowLightState {
+    + YellowLightState()
+    + handleEvent(context : TrafficLightContext)
+  }
+}
+TrafficLightContext -->  "-currentState" TrafficLightState
+GreenLightState ..|> TrafficLightState 
+RedLightState ..|> TrafficLightState 
+YellowLightState ..|> TrafficLightState 
+@enduml

FiniteStateMachine/pom.xml

@@ -17,8 +17,13 @@
     </properties>
     <dependencies>
         <dependency>
-            <groupId>junit</groupId>
-            <artifactId>junit</artifactId>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-api</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.mockito</groupId>
+            <artifactId>mockito-core</artifactId>
             <scope>test</scope>
         </dependency>
     </dependencies>

function-composition/etc/function-composition.urm.puml

@@ -0,0 +1,12 @@
+@startuml
+package com.iluwatar.function.composition {
+  class App {
+    + App()
+    + main(args : String[]) {static}
+  }
+  class FunctionComposer {
+    + FunctionComposer()
+    + composeFunctions(f1 : Function<Integer, Integer>, f2 : Function<Integer, Integer>) : Function<Integer, Integer> {static}
+  }
+}
+@enduml

marker-interface/etc/marker-interface.urm.puml

@@ -0,0 +1,2 @@
+@startuml
+@enduml

microservices-aggregrator/etc/microservices-aggregrator.urm.puml

@@ -0,0 +1,2 @@
+@startuml
+@enduml

microservices-idempotent-consumer/etc/microservices-idempotent-consumer.urm.puml

@@ -0,0 +1,49 @@
+@startuml
+package com.iluwatar.idempotentconsumer {
+  class App {
+    - LOGGER : Logger {static}
+    + App()
+    + main(args : String[]) {static}
+    + run(requestService : RequestService, requestRepository : RequestRepository) : CommandLineRunner
+  }
+  class Request {
+    - status : Status
+    - uuid : UUID
+    + Request()
+    + Request(uuid : UUID)
+    + Request(uuid : UUID, status : Status)
+    # canEqual(other : Object) : boolean
+    + equals(o : Object) : boolean
+    + getStatus() : Status
+    + getUuid() : UUID
+    + hashCode() : int
+    + setStatus(status : Status)
+    + setUuid(uuid : UUID)
+    + toString() : String
+  }
+  ~enum Status {
+    + COMPLETED {static}
+    + PENDING {static}
+    + STARTED {static}
+    + valueOf(name : String) : Status {static}
+    + values() : Status[] {static}
+  }
+  interface RequestRepository {
+  }
+  class RequestService {
+    ~ requestRepository : RequestRepository
+    ~ requestStateMachine : RequestStateMachine
+    + RequestService(requestRepository : RequestRepository, requestStateMachine : RequestStateMachine)
+    + complete(uuid : UUID) : Request
+    + create(uuid : UUID) : Request
+    + start(uuid : UUID) : Request
+  }
+  class RequestStateMachine {
+    + RequestStateMachine()
+    + next(req : Request, nextStatus : Status) : Request
+  }
+}
+RequestService -->  "-requestRepository" RequestRepository
+Request -->  "-status" Status
+RequestService -->  "-requestStateMachine" RequestStateMachine
+@enduml

microservices-log-aggregation/etc/microservices-log-aggregation.urm.puml

@@ -0,0 +1,68 @@
+@startuml
+package com.iluwatar.logaggregation {
+  class App {
+    + App()
+    + main(args : String[]) {static}
+  }
+  class CentralLogStore {
+    - LOGGER : Logger {static}
+    - logs : ConcurrentLinkedQueue<LogEntry>
+    + CentralLogStore()
+    + displayLogs()
+    + storeLog(logEntry : LogEntry)
+  }
+  class LogAggregator {
+    - BUFFER_THRESHOLD : int {static}
+    - LOGGER : Logger {static}
+    - buffer : ConcurrentLinkedQueue<LogEntry>
+    - centralLogStore : CentralLogStore
+    - executorService : ExecutorService
+    - logCount : AtomicInteger
+    - minLogLevel : LogLevel
+    + LogAggregator(centralLogStore : CentralLogStore, minLogLevel : LogLevel)
+    + collectLog(logEntry : LogEntry)
+    - flushBuffer()
+    - startBufferFlusher()
+    + stop()
+  }
+  class LogEntry {
+    - level : LogLevel
+    - message : String
+    - serviceName : String
+    - timestamp : LocalDateTime
+    + LogEntry(serviceName : String, level : LogLevel, message : String, timestamp : LocalDateTime)
+    # canEqual(other : Object) : boolean
+    + equals(o : Object) : boolean
+    + getLevel() : LogLevel
+    + getMessage() : String
+    + getServiceName() : String
+    + getTimestamp() : LocalDateTime
+    + hashCode() : int
+    + setLevel(level : LogLevel)
+    + setMessage(message : String)
+    + setServiceName(serviceName : String)
+    + setTimestamp(timestamp : LocalDateTime)
+    + toString() : String
+  }
+  enum LogLevel {
+    + DEBUG {static}
+    + ERROR {static}
+    + INFO {static}
+    + valueOf(name : String) : LogLevel {static}
+    + values() : LogLevel[] {static}
+  }
+  class LogProducer {
+    - LOGGER : Logger {static}
+    - aggregator : LogAggregator
+    - serviceName : String
+    + LogProducer(serviceName : String, aggregator : LogAggregator)
+    + generateLog(level : LogLevel, message : String)
+  }
+}
+LogAggregator -->  "-centralLogStore" CentralLogStore
+LogEntry -->  "-level" LogLevel
+CentralLogStore -->  "-logs" LogEntry
+LogAggregator -->  "-buffer" LogEntry
+LogAggregator -->  "-minLogLevel" LogLevel
+LogProducer -->  "-aggregator" LogAggregator
+@enduml

pom.xml

@@ -218,7 +218,7 @@
     <module>function-composition</module>
     <module>microservices-distributed-tracing</module>
     <module>microservices-idempotent-consumer</module>
-      <module>FiniteStateMachine</module>
+    <module>FiniteStateMachine</module>
   </modules>
   <repositories>
     <repository>

queue-based-load-leveling/etc/queue-based-load-leveling.urm.puml

@@ -0,0 +1,44 @@
+@startuml
+package com.iluwatar.queue.load.leveling {
+  class App {
+    - LOGGER : Logger {static}
+    - SHUTDOWN_TIME : int {static}
+    + App()
+    + main(args : String[]) {static}
+  }
+  class Message {
+    - msg : String
+    + Message(msg : String)
+    + getMsg() : String
+    + toString() : String
+  }
+  class MessageQueue {
+    - LOGGER : Logger {static}
+    - blkQueue : BlockingQueue<Message>
+    + MessageQueue()
+    + retrieveMsg() : Message
+    + submitMsg(msg : Message)
+  }
+  class ServiceExecutor {
+    - LOGGER : Logger {static}
+    - msgQueue : MessageQueue
+    + ServiceExecutor(msgQueue : MessageQueue)
+    + run()
+  }
+  interface Task {
+    + submit(Message) {abstract}
+  }
+  class TaskGenerator {
+    - LOGGER : Logger {static}
+    - msgCount : int
+    - msgQueue : MessageQueue
+    + TaskGenerator(msgQueue : MessageQueue, msgCount : int)
+    + run()
+    + submit(msg : Message)
+  }
+}
+MessageQueue -->  "-blkQueue" Message
+ServiceExecutor -->  "-msgQueue" MessageQueue
+TaskGenerator -->  "-msgQueue" MessageQueue
+TaskGenerator ..|> Task 
+@enduml

virtual-proxy/etc/virtual-proxy.urm.puml

@@ -0,0 +1,26 @@
+@startuml
+package com.iluwatar.virtual.proxy {
+  class App {
+    + App()
+    + main(args : String[]) {static}
+  }
+  interface ExpensiveObject {
+    + process() {abstract}
+  }
+  class RealVideoObject {
+    - LOGGER : Logger {static}
+    + RealVideoObject()
+    - heavyInitialConfiguration()
+    + process()
+  }
+  class VideoObjectProxy {
+    - realVideoObject : RealVideoObject
+    + VideoObjectProxy()
+    + getRealVideoObject() : RealVideoObject
+    + process()
+  }
+}
+VideoObjectProxy -->  "-realVideoObject" RealVideoObject
+RealVideoObject ..|> ExpensiveObject 
+VideoObjectProxy ..|> ExpensiveObject 
+@enduml