File tree Expand file tree Collapse file tree
main/java/com/iluwatar/queue/load/leveling
test/java/com/iluwatar/queue/load/leveling Expand file tree Collapse file tree Original file line number Diff line number Diff line change 11@startuml
2+ package com . iluwatar . queue . load . leveling {
3+ class App {
4+ - LOGGER : Logger {static}
5+ - SHUTDOWN_TIME : int {static}
6+ + App ()
7+ + main(args : String[]) {static}
8+ }
9+ class Message {
10+ - msg : String
11+ + Message(msg : String)
12+ + getMsg () : String
13+ + toString () : String
14+ }
15+ class MessageQueue {
16+ - LOGGER : Logger {static}
17+ - blkQueue : BlockingQueue<Message>
18+ + MessageQueue ()
19+ + retrieveMsg () : Message
20+ + submitMsg(msg : Message)
21+ }
22+ class ServiceExecutor {
23+ - LOGGER : Logger {static}
24+ - msgQueue : MessageQueue
25+ + ServiceExecutor(msgQueue : MessageQueue)
26+ + run ()
27+ }
28+ interface Task {
29+ + submit (Message ) {abstract }
30+ }
31+ class TaskGenerator {
32+ - LOGGER : Logger {static}
33+ - msgCount : int
34+ - msgQueue : MessageQueue
35+ + TaskGenerator(msgQueue : MessageQueue, msgCount : int)
36+ + run ()
37+ + submit(msg : Message)
38+ }
39+ }
40+ MessageQueue --> "- blkQueue " Message
41+ ServiceExecutor --> "- msgQueue " MessageQueue
42+ TaskGenerator --> "- msgQueue " MessageQueue
43+ TaskGenerator ..|> Task
244@enduml
Original file line number Diff line number Diff line change 2121 * THE SOFTWARE.
2222 */
2323
24- package org .queue .load .leveling ;
24+ package com . iluwatar .queue .load .leveling ;
2525
2626import java .util .concurrent .ExecutorService ;
2727import java .util .concurrent .Executors ;
Original file line number Diff line number Diff line change 2020 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
2121 * THE SOFTWARE.
2222 */
23- package org .queue .load .leveling ;
23+ package com . iluwatar .queue .load .leveling ;
2424
2525/**
2626 * Message class with only one parameter.
Original file line number Diff line number Diff line change 2020 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
2121 * THE SOFTWARE.
2222 */
23- package org .queue .load .leveling ;
23+ package com . iluwatar .queue .load .leveling ;
2424
2525import java .util .concurrent .ArrayBlockingQueue ;
2626import java .util .concurrent .BlockingQueue ;
Original file line number Diff line number Diff line change 2121 * THE SOFTWARE.
2222 */
2323
24- package org .queue .load .leveling ;
24+ package com . iluwatar .queue .load .leveling ;
2525
2626import org .slf4j .Logger ;
2727import org .slf4j .LoggerFactory ;
Original file line number Diff line number Diff line change 2020 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
2121 * THE SOFTWARE.
2222 */
23- package org .queue .load .leveling ;
23+ package com . iluwatar .queue .load .leveling ;
2424/**
2525 * Task Interface.
2626 *
Original file line number Diff line number Diff line change 2020 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
2121 * THE SOFTWARE.
2222 */
23- package org .queue .load .leveling ;
23+ package com . iluwatar .queue .load .leveling ;
2424
2525import org .slf4j .Logger ;
2626import org .slf4j .LoggerFactory ;
Original file line number Diff line number Diff line change 2020 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
2121 * THE SOFTWARE.
2222 */
23- package org .queue .load .leveling ;
23+ package com . iluwatar .queue .load .leveling ;
2424
2525import java .io .IOException ;
2626
Original file line number Diff line number Diff line change 2020 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
2121 * THE SOFTWARE.
2222 */
23- package org .queue .load .leveling ;
23+ package com . iluwatar .queue .load .leveling ;
2424
2525import static org .junit .Assert .assertEquals ;
2626
Original file line number Diff line number Diff line change 2020 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
2121 * THE SOFTWARE.
2222 */
23- package org .queue .load .leveling ;
23+ package com . iluwatar .queue .load .leveling ;
2424
2525import org .junit .Test ;
2626import static org .junit .Assert .assertEquals ;
You can’t perform that action at this time.
0 commit comments