gaspersic/java-design-patterns
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

#467 data-bus: remove lombok

Browse Source
This commit is contained in:
Paul Campbell
2017-04-01 18:12:32 +01:00
parent bc4d029a87
commit 146f367188
7 changed files with 34 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
data-bus/src/main/java/com/iluwatar/databus/App.java
View File

@@ -23,12 +23,11 @@
package com.iluwatar.databus;
import com.iluwatar.databus.data.StoppingData;
import com.iluwatar.databus.data.StartingData;
import com.iluwatar.databus.data.MessageData;
import com.iluwatar.databus.data.StartingData;
import com.iluwatar.databus.data.StoppingData;
import com.iluwatar.databus.members.CounterMember;
import com.iluwatar.databus.members.StatusMember;
import lombok.extern.slf4j.Slf4j;
import java.time.LocalDateTime;
@@ -39,7 +38,6 @@ import java.time.LocalDateTime;
*
* @author Paul Campbell (pcampbell@kemitix.net)
*/
@Slf4j
class App {
public static void main(String[] args) {

6
data-bus/src/main/java/com/iluwatar/databus/data/MessageData.java
View File

@@ -25,18 +25,20 @@ package com.iluwatar.databus.data;
import com.iluwatar.databus.AbstractDataType;
import com.iluwatar.databus.DataType;
import lombok.RequiredArgsConstructor;
/**
* .
*
* @author Paul Campbell (pcampbell@kemitix.net)
*/
@RequiredArgsConstructor
public class MessageData extends AbstractDataType {
private final String message;
public MessageData(String message) {
this.message = message;
}
public String getMessage() {
return message;
}

6
data-bus/src/main/java/com/iluwatar/databus/data/StartingData.java
View File

@@ -25,7 +25,6 @@ package com.iluwatar.databus.data;
import com.iluwatar.databus.AbstractDataType;
import com.iluwatar.databus.DataType;
import lombok.RequiredArgsConstructor;
import java.time.LocalDateTime;
@@ -34,11 +33,14 @@ import java.time.LocalDateTime;
*
* @author Paul Campbell (pcampbell@kemitix.net)
*/
@RequiredArgsConstructor
public class StartingData extends AbstractDataType {
private final LocalDateTime when;
public StartingData(LocalDateTime when) {
this.when = when;
}
public LocalDateTime getWhen() {
return when;
}

6
data-bus/src/main/java/com/iluwatar/databus/data/StoppingData.java
View File

@@ -25,7 +25,6 @@ package com.iluwatar.databus.data;
import com.iluwatar.databus.AbstractDataType;
import com.iluwatar.databus.DataType;
import lombok.RequiredArgsConstructor;
import java.time.LocalDateTime;
@@ -34,11 +33,14 @@ import java.time.LocalDateTime;
*
* @author Paul Campbell (pcampbell@kemitix.net)
*/
@RequiredArgsConstructor
public class StoppingData extends AbstractDataType {
private final LocalDateTime when;
public StoppingData(LocalDateTime when) {
this.when = when;
}
public LocalDateTime getWhen() {
return when;
}

14
data-bus/src/main/java/com/iluwatar/databus/members/CounterMember.java
View File

@@ -26,20 +26,24 @@ package com.iluwatar.databus.members;
import com.iluwatar.databus.DataType;
import com.iluwatar.databus.Member;
import com.iluwatar.databus.data.MessageData;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import java.util.logging.Logger;
/**
* Receiver of Data-Bus events.
*
* @author Paul Campbell (pcampbell@kemitix.net)
*/
@Slf4j
@RequiredArgsConstructor
public class CounterMember implements Member {
private static final Logger LOGGER = Logger.getLogger(CounterMember.class.getName());
private final String name;
public CounterMember(String name) {
this.name = name;
}
@Override
public void accept(final DataType data) {
if (data instanceof MessageData) {
@@ -48,6 +52,6 @@ public class CounterMember implements Member {
}
private void handleEvent(MessageData data) {
log.info("{} sees message {}", name, data.getMessage());
LOGGER.info(String.format("%s sees message %s", name, data.getMessage()));
}
}

18
data-bus/src/main/java/com/iluwatar/databus/members/StatusMember.java
View File

@@ -28,20 +28,24 @@ import com.iluwatar.databus.Member;
import com.iluwatar.databus.data.MessageData;
import com.iluwatar.databus.data.StartingData;
import com.iluwatar.databus.data.StoppingData;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import java.util.logging.Logger;
/**
* Receiver of Data-Bus events.
*
* @author Paul Campbell (pcampbell@kemitix.net)
*/
@Slf4j
@RequiredArgsConstructor
public class StatusMember implements Member {
private static final Logger LOGGER = Logger.getLogger(StatusMember.class.getName());
private final int id;
public StatusMember(int id) {
this.id = id;
}
@Override
public void accept(final DataType data) {
if (data instanceof StartingData) {
@@ -52,12 +56,12 @@ public class StatusMember implements Member {
}
private void handleEvent(StartingData data) {
log.info("Receiver #{} sees application started at {}", id, data.getWhen());
LOGGER.info(String.format("Receiver #%d sees application started at %s", id, data.getWhen()));
}
private void handleEvent(StoppingData data) {
log.info("Receiver #{} sees application stopping at {}", id, data.getWhen());
log.info("Receiver #{} sending goodbye message", id);
LOGGER.info(String.format("Receiver #%d sees application stopping at %s", id, data.getWhen()));
LOGGER.info(String.format("Receiver #%d sending goodbye message", id));
data.getDataBus().publish(MessageData.of(String.format("Goodbye cruel world from #%d!", id)));
}
}